北科大審計(jì)處值得去嗎？-招聘街

一、北科大審計(jì)處值得去嗎？

北京科技大學(xué)審計(jì)處是一個(gè)負(fù)責(zé)學(xué)校內(nèi)部審計(jì)和監(jiān)督的部門，其職責(zé)包括對(duì)學(xué)校財(cái)務(wù)、經(jīng)濟(jì)活動(dòng)進(jìn)行審計(jì)和監(jiān)督，對(duì)學(xué)校內(nèi)部管理進(jìn)行評(píng)估和改進(jìn)等。如果你對(duì)審計(jì)和財(cái)務(wù)方面的工作感興趣，并且想要在一個(gè)有良好發(fā)展前景的部門工作，那么北京科技大學(xué)審計(jì)處是一個(gè)不錯(cuò)的選擇。

不過，具體是否值得去還需要考慮個(gè)人的情況和需求。如果你希望在工作中積累更多的經(jīng)驗(yàn)和技能，或者想要在更大的平臺(tái)上發(fā)展自己的職業(yè)生涯，那么可以考慮其他的大型企業(yè)或會(huì)計(jì)師事務(wù)所等機(jī)構(gòu)。如果你對(duì)教育和研究領(lǐng)域感興趣，并且想要在大學(xué)里工作，那么可以考慮其他相關(guān)的職位或部門，如財(cái)務(wù)處、資產(chǎn)管理處等。

總之，選擇工作需要考慮自己的興趣、職業(yè)規(guī)劃和需求等多個(gè)因素，而北京科技大學(xué)審計(jì)處是否值得去也需要根據(jù)你的具體情況來(lái)評(píng)估。

二、河海大學(xué)審計(jì)處上班時(shí)間？

河海大學(xué)審計(jì)處每天8點(diǎn)半至12點(diǎn)，14點(diǎn)至18點(diǎn)上班，周六周日休息。

三、交通局的審計(jì)處是干嘛？

交通局審計(jì)處的主要職責(zé)通常包括以下幾個(gè)方面：

1. 內(nèi)部審計(jì)：對(duì)交通局內(nèi)部的財(cái)務(wù)收支、預(yù)算執(zhí)行、資金使用等進(jìn)行審計(jì)，確保資金合法合規(guī)使用。

2. 項(xiàng)目審計(jì)：對(duì)交通局承擔(dān)的建設(shè)項(xiàng)目、工程項(xiàng)目進(jìn)行審計(jì)，包括預(yù)算審計(jì)、成本審計(jì)、竣工決算審計(jì)等，確保項(xiàng)目建設(shè)合規(guī)、資金使用合理。

3. 合規(guī)審計(jì)：對(duì)交通局的各項(xiàng)業(yè)務(wù)活動(dòng)進(jìn)行合規(guī)性審計(jì)，確保遵守相關(guān)法律法規(guī)和政策要求。

4. 績(jī)效審計(jì)：評(píng)估交通局各項(xiàng)業(yè)務(wù)的績(jī)效情況，包括項(xiàng)目實(shí)施效果、資源利用效率等，提供改進(jìn)建議。

5. 風(fēng)險(xiǎn)管理：協(xié)助交通局識(shí)別和評(píng)估風(fēng)險(xiǎn)，提出風(fēng)險(xiǎn)管理建議，確保交通局的運(yùn)營(yíng)和管理風(fēng)險(xiǎn)得到有效控制。

交通局審計(jì)處的工作旨在保障交通局的財(cái)務(wù)合規(guī)性、提高資金使用效益、加強(qiáng)內(nèi)部管理和風(fēng)險(xiǎn)控制，以促進(jìn)交通事業(yè)的健康發(fā)展。具體的工作內(nèi)容和職責(zé)可能因不同地區(qū)和交通局的組織結(jié)構(gòu)而有所差異。如果你需要更詳細(xì)的信息，建議查閱相關(guān)資料或咨詢當(dāng)?shù)亟煌ň值南嚓P(guān)部門。

四、農(nóng)行審計(jì)處處長(zhǎng)官有多大？

中國(guó)農(nóng)業(yè)銀行，集團(tuán)公司的相應(yīng)部門叫審計(jì)委員會(huì)，所以你說(shuō)的審計(jì)處應(yīng)該是指地方分支機(jī)構(gòu)下設(shè)的審計(jì)辦事處。

應(yīng)該是比相應(yīng)分行行長(zhǎng)低兩級(jí)，跟支行行長(zhǎng)平級(jí)，也就是副處，當(dāng)然不排除某些重要的辦事處高配正處，或者同理低配正科。

五、甘肅省審計(jì)處創(chuàng)建的經(jīng)過？

甘肅省審計(jì)處的創(chuàng)建經(jīng)過如下：

1.甘肅省政府于2006年4月26日發(fā)布《關(guān)于建立甘肅省審計(jì)處的決定》，正式建立甘肅省審計(jì)處；

2.2007年1月，甘肅省審計(jì)處正式成立，甘肅省審計(jì)處長(zhǎng)陳曉林出任甘肅省審計(jì)處長(zhǎng)；

3.2007年4月，甘肅省審計(jì)處正式投入使用，開展審計(jì)工作；

4.2008年，甘肅省審計(jì)處正式獲得國(guó)家審計(jì)總局頒發(fā)的審計(jì)機(jī)構(gòu)資質(zhì)證書，正式成為國(guó)家審計(jì)機(jī)構(gòu)。

六、企業(yè)內(nèi)部審計(jì)處罰處理規(guī)定？

一、審計(jì)處罰種類與權(quán)限

1、審計(jì)處罰的種類:

（1）限期改正:責(zé)令責(zé)任人限定期限內(nèi)糾正錯(cuò)誤

（2）警告:向責(zé)任人提出警告

（3）通報(bào)批評(píng):在科室內(nèi)部通報(bào)批評(píng)

（4）罰款:報(bào)公司高層，由其確定罰款金額

（5）其他處理措施:報(bào)公司高層，由其確定處理措施

2、審計(jì)處罰的權(quán)限:“限期改正”、“警告”及“通報(bào)批評(píng)”由內(nèi)審主管

簽批;“罰款”及“其他處理措施”由市場(chǎng)財(cái)務(wù)主管報(bào)集團(tuán)財(cái)務(wù)部主

任審批。

二、審計(jì)結(jié)果的通知及落實(shí)

1、審計(jì)結(jié)果由內(nèi)審會(huì)計(jì)及內(nèi)審主管在“釘釘”軟件告知結(jié)算主管及責(zé)任結(jié)算會(huì)計(jì)，結(jié)算會(huì)計(jì)在收到審計(jì)意見后三日內(nèi)必須予以反饋。

2、若未在“限期改正”規(guī)定的時(shí)間內(nèi)糾正錯(cuò)誤或未在審計(jì)意見發(fā)出后三日內(nèi)予以反饋的，在原有處罰種類上再加一級(jí)處罰。

3、若結(jié)算對(duì)內(nèi)審處理結(jié)果有異議的，由市場(chǎng)財(cái)務(wù)主管判定:若市場(chǎng)財(cái)務(wù)主管難以判定的上報(bào)集團(tuán)財(cái)務(wù)部主任處理。

七、社會(huì)保障審計(jì)處崗位職責(zé)

社會(huì)保障審計(jì)處崗位職責(zé)

社會(huì)保障審計(jì)處概述

社會(huì)保障審計(jì)處是負(fù)責(zé)對(duì)社會(huì)保障系統(tǒng)進(jìn)行審計(jì)的機(jī)構(gòu)，其職責(zé)是確保社會(huì)保障資金的合理使用、安全運(yùn)作，并提出改進(jìn)建議以提高社會(huì)保障體系的效率和公平性。

審計(jì)處主要職責(zé)

1. 對(duì)社會(huì)保障基金的來(lái)源、使用及管理進(jìn)行審計(jì)，確保社會(huì)保障資金的安全性和合理性。

2. 檢查社會(huì)保障基金的征繳情況，防止違規(guī)行為和濫用社會(huì)保障資金的現(xiàn)象。

3. 分析社會(huì)保障制度的實(shí)施效果，提出改進(jìn)建議，促進(jìn)社會(huì)保障體系的健康發(fā)展。

4. 協(xié)助相關(guān)部門開展社會(huì)保障方面的專項(xiàng)審計(jì)工作，提供數(shù)據(jù)支持和意見建議。

具體崗位職責(zé)

1. 制定社會(huì)保障審計(jì)工作計(jì)劃，明確審計(jì)目標(biāo)、范圍和重點(diǎn)，并組織實(shí)施。

2. 對(duì)社會(huì)保障基金的存量和增量進(jìn)行核查，分析資金流向和使用情況。

3. 協(xié)助建立健全社會(huì)保障審計(jì)工作制度，推動(dòng)工作規(guī)范化和制度化。

4. 分析社會(huì)保障政策的實(shí)施情況，督促履行社會(huì)保障相關(guān)法律法規(guī)。

5. 撰寫社會(huì)保障審計(jì)報(bào)告，總結(jié)審計(jì)發(fā)現(xiàn)和問題，并提出改進(jìn)建議。

6. 協(xié)助監(jiān)督社會(huì)保障基金的使用情況，防范風(fēng)險(xiǎn)和避免損失。

7. 參與社會(huì)保障審計(jì)工作的外聯(lián)合作和協(xié)調(diào)，保障審計(jì)工作的順利進(jìn)行。

崗位要求

1. 具有相關(guān)專業(yè)背景，如審計(jì)、財(cái)會(huì)等，具備一定的社會(huì)保障制度知識(shí)和技能。

2. 熟悉社會(huì)保障相關(guān)政策法規(guī)，具有較強(qiáng)的數(shù)據(jù)分析和問題發(fā)現(xiàn)能力。

3. 具備良好的溝通協(xié)調(diào)能力和團(tuán)隊(duì)合作精神，能夠獨(dú)立開展工作。

4. 具有責(zé)任心和執(zhí)行力，能夠按時(shí)按質(zhì)完成審計(jì)任務(wù)，并且具備較強(qiáng)的抗壓能力。

5. 具有較強(qiáng)的文字表達(dá)能力和報(bào)告撰寫能力，能夠清晰準(zhǔn)確地傳達(dá)審計(jì)結(jié)論和建議。

結(jié)語(yǔ)

社會(huì)保障審計(jì)處的崗位是一項(xiàng)重要的工作，需要審計(jì)人員具備專業(yè)知識(shí)和能力，能夠保障社會(huì)保障資金的安全運(yùn)作，促進(jìn)社會(huì)保障體系的健康發(fā)展。希望有意從事社會(huì)保障審計(jì)工作的同仁，能夠根據(jù)以上介紹的崗位職責(zé)和要求，認(rèn)真準(zhǔn)備和努力工作，為社會(huì)保障事業(yè)的發(fā)展貢獻(xiàn)自己的力量。

八、審計(jì)處崗位職責(zé)履行情況

審計(jì)處崗位職責(zé)履行情況是評(píng)估一個(gè)組織內(nèi)審計(jì)部門或?qū)徲?jì)人員在執(zhí)行其職責(zé)和任務(wù)時(shí)的表現(xiàn)和效果的重要指標(biāo)。審計(jì)處崗位職責(zé)的履行情況直接關(guān)系到組織的內(nèi)部控制、風(fēng)險(xiǎn)管理、合規(guī)性和治理效果。而一個(gè)審計(jì)處在職責(zé)履行方面是否到位、規(guī)范和有效，關(guān)系到組織的運(yùn)行和發(fā)展方向。

為什么審計(jì)處崗位職責(zé)履行情況如此重要？

審計(jì)處是組織內(nèi)部的重要部門之一，其主要職責(zé)是通過獨(dú)立的審計(jì)工作，幫助組織管理層了解和評(píng)估內(nèi)部控制的有效性，識(shí)別風(fēng)險(xiǎn)，并提出改進(jìn)建議。因此，審計(jì)處崗位職責(zé)的履行情況對(duì)于保障組織的利益、提高經(jīng)營(yíng)效率、確保信息的準(zhǔn)確性和保護(hù)資產(chǎn)至關(guān)重要。

審計(jì)處崗位職責(zé)的履行情況不僅關(guān)系到內(nèi)部控制和風(fēng)險(xiǎn)管理的有效性，還關(guān)系到合規(guī)性和管理層決策的科學(xué)性。只有當(dāng)審計(jì)處在職責(zé)履行方面做到位、規(guī)范和有效，才能為組織提供有力支持，幫助其實(shí)現(xiàn)長(zhǎng)期發(fā)展和持續(xù)增長(zhǎng)。

如何評(píng)估審計(jì)處崗位職責(zé)履行情況？

評(píng)估審計(jì)處崗位職責(zé)的履行情況需要綜合考慮多個(gè)方面的因素，包括內(nèi)部審計(jì)的獨(dú)立性、客觀性、專業(yè)性和效益性等。通常可以從以下幾個(gè)角度入手進(jìn)行評(píng)估：

審計(jì)部門的組織結(jié)構(gòu)和人員配置是否合理
審計(jì)程序和方法是否科學(xué)、規(guī)范
審計(jì)報(bào)告的準(zhǔn)確性、及時(shí)性和完整性
審計(jì)工作的影響力和改進(jìn)效果
審計(jì)部門與管理層、監(jiān)管部門和其他部門的溝通和協(xié)作情況

在評(píng)估審計(jì)處崗位職責(zé)的履行情況時(shí)，應(yīng)該注重定性和定量相結(jié)合，既要考慮審計(jì)工作的質(zhì)量和效果，也要考慮審計(jì)部門的運(yùn)作效率和資源利用情況。

提升審計(jì)處崗位職責(zé)履行情況的建議

為了提升審計(jì)處崗位職責(zé)的履行情況，組織管理層和審計(jì)部門可以采取以下措施：

加強(qiáng)對(duì)審計(jì)部門的投資，提升其人員素質(zhì)和專業(yè)技能
建立健全的內(nèi)部審計(jì)制度和流程，強(qiáng)化審核和監(jiān)督機(jī)制
推動(dòng)審計(jì)部門與各業(yè)務(wù)部門和管理層的密切合作和溝通
持續(xù)改進(jìn)審計(jì)工作方法和技術(shù)，提高工作效率和效益
加強(qiáng)內(nèi)部控制和風(fēng)險(xiǎn)管理的協(xié)調(diào)和整合

通過以上措施的實(shí)施，可以有效提升審計(jì)處崗位職責(zé)的履行情況，為組織的長(zhǎng)期可持續(xù)發(fā)展提供有力支持。

結(jié)語(yǔ)

審計(jì)處崗位職責(zé)的履行情況直接關(guān)系到組織的管理和運(yùn)行效果，是組織內(nèi)部控制和風(fēng)險(xiǎn)管理的重要保障。通過評(píng)估和提升審計(jì)處崗位職責(zé)的履行情況，可以幫助組織做好內(nèi)部管理和控制，提高經(jīng)營(yíng)效率，確保信息真實(shí)可靠，保護(hù)資產(chǎn)安全，達(dá)到長(zhǎng)期穩(wěn)健發(fā)展的目標(biāo)。

九、事業(yè)單位審計(jì)處做什么的？

在行政事業(yè)單位做審計(jì)工作的主要職責(zé)包括：

1. 對(duì)單位的財(cái)務(wù)、會(huì)計(jì)、資產(chǎn)、預(yù)算等方面的工作進(jìn)行審核、審計(jì)，確保其合法性、合規(guī)性和準(zhǔn)確性；

2. 對(duì)單位的管理制度、規(guī)章制度、政策措施等方面進(jìn)行審查，發(fā)現(xiàn)問題并提出改進(jìn)意見；

3. 對(duì)單位的風(fēng)險(xiǎn)管理、內(nèi)部控制等方面進(jìn)行評(píng)估，提出風(fēng)險(xiǎn)預(yù)警和防范措施；

4. 對(duì)單位的經(jīng)濟(jì)責(zé)任審計(jì)、績(jī)效評(píng)價(jià)等方面進(jìn)行工作，評(píng)估單位的經(jīng)濟(jì)效益和社會(huì)效益；

5. 對(duì)單位的重大經(jīng)濟(jì)活動(dòng)、項(xiàng)目實(shí)施等方面進(jìn)行審計(jì)，發(fā)現(xiàn)問題并提出改進(jìn)措施。總之，審計(jì)工作旨在幫助行政事業(yè)單位加強(qiáng)內(nèi)部管理，提高經(jīng)濟(jì)效益和社會(huì)效益，保障公共資源的合理利用和管理。

十、mahout面試題？

之前看了Mahout官方示例 20news 的調(diào)用實(shí)現(xiàn)；于是想根據(jù)示例的流程實(shí)現(xiàn)其他例子。網(wǎng)上看到了一個(gè)關(guān)于天氣適不適合打羽毛球的例子。

訓(xùn)練數(shù)據(jù)：

Day Outlook Temperature Humidity Wind PlayTennis

D1 Sunny Hot High Weak No

D2 Sunny Hot High Strong No

D3 Overcast Hot High Weak Yes

D4 Rain Mild High Weak Yes

D5 Rain Cool Normal Weak Yes

D6 Rain Cool Normal Strong No

D7 Overcast Cool Normal Strong Yes

D8 Sunny Mild High Weak No

D9 Sunny Cool Normal Weak Yes

D10 Rain Mild Normal Weak Yes

D11 Sunny Mild Normal Strong Yes

D12 Overcast Mild High Strong Yes

D13 Overcast Hot Normal Weak Yes

D14 Rain Mild High Strong No

檢測(cè)數(shù)據(jù)：

sunny，hot，high，weak

結(jié)果：

Yes=》 0.007039

No=》 0.027418

于是使用Java代碼調(diào)用Mahout的工具類實(shí)現(xiàn)分類。

基本思想：

1. 構(gòu)造分類數(shù)據(jù)。

2. 使用Mahout工具類進(jìn)行訓(xùn)練，得到訓(xùn)練模型。

3。將要檢測(cè)數(shù)據(jù)轉(zhuǎn)換成vector數(shù)據(jù)。

4. 分類器對(duì)vector數(shù)據(jù)進(jìn)行分類。

接下來(lái)貼下我的代碼實(shí)現(xiàn)=》

1. 構(gòu)造分類數(shù)據(jù)：

在hdfs主要?jiǎng)?chuàng)建一個(gè)文件夾路徑 /zhoujainfeng/playtennis/input 并將分類文件夾 no 和 yes 的數(shù)據(jù)傳到hdfs上面。

數(shù)據(jù)文件格式，如D1文件內(nèi)容： Sunny Hot High Weak

2. 使用Mahout工具類進(jìn)行訓(xùn)練，得到訓(xùn)練模型。

3。將要檢測(cè)數(shù)據(jù)轉(zhuǎn)換成vector數(shù)據(jù)。

4. 分類器對(duì)vector數(shù)據(jù)進(jìn)行分類。

這三步，代碼我就一次全貼出來(lái)；主要是兩個(gè)類 PlayTennis1 和 BayesCheckData = =》

package myTesting.bayes;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.fs.FileSystem;

import org.apache.hadoop.fs.Path;

import org.apache.hadoop.util.ToolRunner;

import org.apache.mahout.classifier.naivebayes.training.TrainNaiveBayesJob;

import org.apache.mahout.text.SequenceFilesFromDirectory;

import org.apache.mahout.vectorizer.SparseVectorsFromSequenceFiles;

public class PlayTennis1 {

private static final String WORK_DIR = "hdfs://192.168.9.72:9000/zhoujianfeng/playtennis";

* 測(cè)試代碼

public static void main(String[] args) {

//將訓(xùn)練數(shù)據(jù)轉(zhuǎn)換成 vector數(shù)據(jù)

makeTrainVector();

//產(chǎn)生訓(xùn)練模型

makeModel(false);

//測(cè)試檢測(cè)數(shù)據(jù)

BayesCheckData.printResult();

}

public static void makeCheckVector(){

//將測(cè)試數(shù)據(jù)轉(zhuǎn)換成序列化文件

try {

Configuration conf = new Configuration();

conf.addResource(new Path("/usr/local/hadoop/conf/core-site.xml"));

String input = WORK_DIR+Path.SEPARATOR+"testinput";

String output = WORK_DIR+Path.SEPARATOR+"tennis-test-seq";

Path in = new Path(input);

Path out = new Path(output);

FileSystem fs = FileSystem.get(conf);

if(fs.exists(in)){

if(fs.exists(out)){

//boolean參數(shù)是，是否遞歸刪除的意思

fs.delete(out, true);

}

SequenceFilesFromDirectory sffd = new SequenceFilesFromDirectory();

String[] params = new String[]{"-i",input,"-o",output,"-ow"};

ToolRunner.run(sffd, params);

}

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

System.out.println("文件序列化失敗！");

System.exit(1);

}

//將序列化文件轉(zhuǎn)換成向量文件

try {

Configuration conf = new Configuration();

conf.addResource(new Path("/usr/local/hadoop/conf/core-site.xml"));

String input = WORK_DIR+Path.SEPARATOR+"tennis-test-seq";

String output = WORK_DIR+Path.SEPARATOR+"tennis-test-vectors";

Path in = new Path(input);

Path out = new Path(output);

FileSystem fs = FileSystem.get(conf);

if(fs.exists(in)){

if(fs.exists(out)){

//boolean參數(shù)是，是否遞歸刪除的意思

fs.delete(out, true);

}

SparseVectorsFromSequenceFiles svfsf = new SparseVectorsFromSequenceFiles();

String[] params = new String[]{"-i",input,"-o",output,"-lnorm","-nv","-wt","tfidf"};

ToolRunner.run(svfsf, params);

}

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

System.out.println("序列化文件轉(zhuǎn)換成向量失敗！");

System.out.println(2);

}

public static void makeTrainVector(){

//將測(cè)試數(shù)據(jù)轉(zhuǎn)換成序列化文件

try {

Configuration conf = new Configuration();

conf.addResource(new Path("/usr/local/hadoop/conf/core-site.xml"));

String input = WORK_DIR+Path.SEPARATOR+"input";

String output = WORK_DIR+Path.SEPARATOR+"tennis-seq";

Path in = new Path(input);

Path out = new Path(output);

FileSystem fs = FileSystem.get(conf);

if(fs.exists(in)){

if(fs.exists(out)){

//boolean參數(shù)是，是否遞歸刪除的意思

fs.delete(out, true);

}

SequenceFilesFromDirectory sffd = new SequenceFilesFromDirectory();

String[] params = new String[]{"-i",input,"-o",output,"-ow"};

ToolRunner.run(sffd, params);

}

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

System.out.println("文件序列化失敗！");

System.exit(1);

}

//將序列化文件轉(zhuǎn)換成向量文件

try {

Configuration conf = new Configuration();

conf.addResource(new Path("/usr/local/hadoop/conf/core-site.xml"));

String input = WORK_DIR+Path.SEPARATOR+"tennis-seq";

String output = WORK_DIR+Path.SEPARATOR+"tennis-vectors";

Path in = new Path(input);

Path out = new Path(output);

FileSystem fs = FileSystem.get(conf);

if(fs.exists(in)){

if(fs.exists(out)){

//boolean參數(shù)是，是否遞歸刪除的意思

fs.delete(out, true);

}

SparseVectorsFromSequenceFiles svfsf = new SparseVectorsFromSequenceFiles();

String[] params = new String[]{"-i",input,"-o",output,"-lnorm","-nv","-wt","tfidf"};

ToolRunner.run(svfsf, params);

}

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

System.out.println("序列化文件轉(zhuǎn)換成向量失敗！");

System.out.println(2);

}

public static void makeModel(boolean completelyNB){

try {

Configuration conf = new Configuration();

conf.addResource(new Path("/usr/local/hadoop/conf/core-site.xml"));

String input = WORK_DIR+Path.SEPARATOR+"tennis-vectors"+Path.SEPARATOR+"tfidf-vectors";

String model = WORK_DIR+Path.SEPARATOR+"model";

String labelindex = WORK_DIR+Path.SEPARATOR+"labelindex";

Path in = new Path(input);

Path out = new Path(model);

Path label = new Path(labelindex);

FileSystem fs = FileSystem.get(conf);

if(fs.exists(in)){

if(fs.exists(out)){

//boolean參數(shù)是，是否遞歸刪除的意思

fs.delete(out, true);

}

if(fs.exists(label)){

//boolean參數(shù)是，是否遞歸刪除的意思

fs.delete(label, true);

}

TrainNaiveBayesJob tnbj = new TrainNaiveBayesJob();

String[] params =null;

if(completelyNB){

params = new String[]{"-i",input,"-el","-o",model,"-li",labelindex,"-ow","-c"};

}else{

params = new String[]{"-i",input,"-el","-o",model,"-li",labelindex,"-ow"};

}

ToolRunner.run(tnbj, params);

}

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

System.out.println("生成訓(xùn)練模型失敗！");

System.exit(3);

}

package myTesting.bayes;

import java.io.IOException;

import java.util.HashMap;

import java.util.Map;

import org.apache.commons.lang.StringUtils;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.fs.Path;

import org.apache.hadoop.fs.PathFilter;

import org.apache.hadoop.io.IntWritable;

import org.apache.hadoop.io.LongWritable;

import org.apache.hadoop.io.Text;

import org.apache.mahout.classifier.naivebayes.BayesUtils;

import org.apache.mahout.classifier.naivebayes.NaiveBayesModel;

import org.apache.mahout.classifier.naivebayes.StandardNaiveBayesClassifier;

import org.apache.mahout.common.Pair;

import org.apache.mahout.common.iterator.sequencefile.PathType;

import org.apache.mahout.common.iterator.sequencefile.SequenceFileDirIterable;

import org.apache.mahout.math.RandomAccessSparseVector;

import org.apache.mahout.math.Vector;

import org.apache.mahout.math.Vector.Element;

import org.apache.mahout.vectorizer.TFIDF;

import com.google.common.collect.ConcurrentHashMultiset;

import com.google.common.collect.Multiset;

public class BayesCheckData {

private static StandardNaiveBayesClassifier classifier;

private static Map<String, Integer> dictionary;

private static Map<Integer, Long> documentFrequency;

private static Map<Integer, String> labelIndex;

public void init(Configuration conf){

try {

String modelPath = "/zhoujianfeng/playtennis/model";

String dictionaryPath = "/zhoujianfeng/playtennis/tennis-vectors/dictionary.file-0";

String documentFrequencyPath = "/zhoujianfeng/playtennis/tennis-vectors/df-count";

String labelIndexPath = "/zhoujianfeng/playtennis/labelindex";

dictionary = readDictionnary(conf, new Path(dictionaryPath));

documentFrequency = readDocumentFrequency(conf, new Path(documentFrequencyPath));

labelIndex = BayesUtils.readLabelIndex(conf, new Path(labelIndexPath));

NaiveBayesModel model = NaiveBayesModel.materialize(new Path(modelPath), conf);

classifier = new StandardNaiveBayesClassifier(model);

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

System.out.println("檢測(cè)數(shù)據(jù)構(gòu)造成vectors初始化時(shí)報(bào)錯(cuò)。。。。");

System.exit(4);

}

/**

* 加載字典文件，Key: TermValue； Value：TermID

* @param conf

* @param dictionnaryDir

* @return

private static Map<String, Integer> readDictionnary(Configuration conf, Path dictionnaryDir) {

Map<String, Integer> dictionnary = new HashMap<String, Integer>();

PathFilter filter = new PathFilter() {

@Override

public boolean accept(Path path) {

String name = path.getName();

return name.startsWith("dictionary.file");

}

};

for (Pair<Text, IntWritable> pair : new SequenceFileDirIterable<Text, IntWritable>(dictionnaryDir, PathType.LIST, filter, conf)) {

dictionnary.put(pair.getFirst().toString(), pair.getSecond().get());

}

return dictionnary;

}

/**

* 加載df-count目錄下TermDoc頻率文件，Key: TermID； Value：DocFreq

* @param conf

* @param dictionnaryDir

* @return

private static Map<Integer, Long> readDocumentFrequency(Configuration conf, Path documentFrequencyDir) {

Map<Integer, Long> documentFrequency = new HashMap<Integer, Long>();

PathFilter filter = new PathFilter() {

@Override

public boolean accept(Path path) {

return path.getName().startsWith("part-r");

}

};

for (Pair<IntWritable, LongWritable> pair : new SequenceFileDirIterable<IntWritable, LongWritable>(documentFrequencyDir, PathType.LIST, filter, conf)) {

documentFrequency.put(pair.getFirst().get(), pair.getSecond().get());

}

return documentFrequency;

}

public static String getCheckResult(){

Configuration conf = new Configuration();

conf.addResource(new Path("/usr/local/hadoop/conf/core-site.xml"));

String classify = "NaN";

BayesCheckData cdv = new BayesCheckData();

cdv.init(conf);

System.out.println("init done...............");

Vector vector = new RandomAccessSparseVector(10000);