答：衛(wèi)生健康局也是有行政處罰權(quán)的；
衛(wèi)生健康局行政處罰 條例中規(guī)定：有下列行為之一的，由縣級以上人民政府衛(wèi)生行政部門給予警告或者責(zé)令暫停六個月以上一年以下執(zhí)業(yè)活動；情節(jié)嚴(yán)重的，吊銷其執(zhí)業(yè)證書；構(gòu)成犯罪的，依法追究刑事責(zé)任：
（一）違反衛(wèi)生行政規(guī)章制度或者技術(shù)操作規(guī)范，造成嚴(yán)重后果的；”
（二）由于不負(fù)責(zé)任延誤急危患者的搶救和診治，造成嚴(yán)重后果的；”
（三）造成醫(yī)療責(zé)任事故的；”
（四）未經(jīng)親自診查、調(diào)查，簽署診斷、治療、流行病學(xué)等證明文件或者有關(guān)出生、死亡等證明文件的；”
（五）隱匿、偽造或者擅自銷毀醫(yī)學(xué)文書及有關(guān)資料的；”
（六）使用未經(jīng)批準(zhǔn)使用的藥品、消毒藥劑和醫(yī)療器械的；”
（七）不按照規(guī)定使用麻醉藥品、醫(yī)療用毒性藥品、精神藥品和放射性藥品的；”
（八）未經(jīng)患者或者其家屬同意，對患者進(jìn)行實驗性臨床醫(yī)療的；”
（九）泄露患者隱私，造成嚴(yán)重后果的；”
（十）利用職務(wù)之便，索取、非法收受患者財物或者牟取其他不正當(dāng)利益的；”
（十一）發(fā)生自然災(zāi)害、傳染病流行、突發(fā)重大傷亡事故以及其他嚴(yán)重威脅人民生命健康的緊急情況時，不服從衛(wèi)生行政部門調(diào)遣的
（十二）發(fā)生醫(yī)療事故或者發(fā)現(xiàn)傳染病疫情，患者涉嫌傷害事件或者非正常死亡，不按照規(guī)定報告的。”
衛(wèi)生健康綜合行政執(zhí)法大隊是隸屬縣衛(wèi)生健康委員會管理的副科級公益一類事業(yè)單位。
一、主要職責(zé)
（一）依法開展醫(yī)療衛(wèi)生機(jī)構(gòu)監(jiān)督執(zhí)法，打擊非法行醫(yī)和非法采供血行為，規(guī)范醫(yī)療服務(wù)秩序。
（二）依法開展公共場所衛(wèi)生、學(xué)校衛(wèi)生、生活飲用水衛(wèi)生、職業(yè)衛(wèi)生、放射衛(wèi)生監(jiān)督執(zhí)法。
（三）依法開展消毒產(chǎn)品、餐飲具集中消毒單位監(jiān)督執(zhí)法。
（四）依法開展婦幼保健計劃生育服務(wù)監(jiān)督執(zhí)法，打擊非醫(yī)學(xué)需要的胎兒性別鑒定和非醫(yī)學(xué)需要選擇性別的人工終止妊娠行為。
（五）依法開展中醫(yī)醫(yī)療服務(wù)監(jiān)督執(zhí)法。
（六）依法開展傳染病防治監(jiān)督執(zhí)法。承擔(dān)國家食品安全標(biāo)準(zhǔn)跟蹤評價。
（一）生活飲用水衛(wèi)生監(jiān)督檢查。
1、適用范圍：轄區(qū)內(nèi)集中式供水單位、二次供水單位、學(xué)校自備水單位、農(nóng)村集中式供水單位。
2、職責(zé)：日常性衛(wèi)生監(jiān)督、飲用水污染事故對人體健康影響的調(diào)查處理、行政處罰。
3、執(zhí)法依據(jù)：《中華人民共和國傳染病防治法》、《生活飲用水衛(wèi)生監(jiān)督管理辦法》、《生活飲用水衛(wèi)生標(biāo)準(zhǔn)》等。?
??（二）學(xué)校衛(wèi)生監(jiān)督檢查。
?? 1、適用范圍：轄區(qū)內(nèi)各級各類學(xué)校；?
2、主要職責(zé)：日常性衛(wèi)生監(jiān)督、桌椅等學(xué)生用品衛(wèi)生監(jiān)督。
?? 3、執(zhí)法依據(jù)：《中華人民共和國傳染病防治法》、《學(xué)校衛(wèi)生管理條例》。?
（三）學(xué)校、幼兒園傳染病防治衛(wèi)生監(jiān)督檢查。
?? 1、適用范圍：轄區(qū)內(nèi)各級各類學(xué)校、幼兒園；??
? 2、主要職責(zé)：日常性衛(wèi)生監(jiān)督、傳染病疫情的調(diào)查和處理；?? ?3、執(zhí)法依據(jù)：《中華人民共和國傳染病防治法》、《突發(fā)公共衛(wèi)生事件與傳染病疫情監(jiān)測信息報告管理辦法》、《學(xué)校和托幼機(jī)構(gòu)傳染病疫情報告工作規(guī)范》等。?????
（四）公共場所衛(wèi)生監(jiān)督檢查。
1、適用范圍：??
（1）賓館、旅店、招待所、車馬店。???
? （2）公共浴室、理發(fā)店、美容店；??? ????
（3）影劇院、錄像廳（室）、游藝廳（室）、舞廳、音樂廳；???????
（4）體育場（館）、游泳場（館）、公園；???????
（5）展覽館、博物館、美術(shù)館、圖書館；???
（6）商場（店）、書店；??
（7）候診室、候車（機(jī)、船）室、公共交通工具。
2、主要職責(zé)：轄區(qū)內(nèi)公共場所衛(wèi)生行政許可、日常監(jiān)督和違法行為查處的工作；對公共場所進(jìn)行衛(wèi)生監(jiān)測和衛(wèi)生技術(shù)指導(dǎo)；監(jiān)督從業(yè)人員健康檢查，指導(dǎo)有關(guān)部門對從業(yè)人員進(jìn)行衛(wèi)生知識的教育和培訓(xùn)；對新建、擴(kuò)建、改建的公共場所的選址和設(shè)計進(jìn)行衛(wèi)生審查，并參加竣工驗收。???
3、執(zhí)法依據(jù)：《公共場所衛(wèi)生管理條例》、《公共場所衛(wèi)生管理條例實施細(xì)則》等。
（五）對醫(yī)療機(jī)構(gòu)、采供血機(jī)構(gòu)、母嬰保健技術(shù)服務(wù)機(jī)構(gòu)、疾病預(yù)防控制機(jī)構(gòu)和蒙中醫(yī)藥機(jī)構(gòu)執(zhí)業(yè)人員的執(zhí)業(yè)活動及傳染病防治進(jìn)行檢查，查處違法行為。
1、適用范圍：轄區(qū)內(nèi)醫(yī)療機(jī)構(gòu)、采供血機(jī)構(gòu)、母嬰保健技術(shù)服務(wù)機(jī)構(gòu)、疾病預(yù)防控制機(jī)構(gòu)和蒙中醫(yī)藥機(jī)構(gòu)。
2、工作職責(zé)：對醫(yī)療機(jī)構(gòu)、采供血機(jī)構(gòu)、母嬰保健技術(shù)服務(wù)機(jī)構(gòu)、疾病預(yù)防控制機(jī)構(gòu)和蒙中醫(yī)藥機(jī)構(gòu)及其執(zhí)業(yè)人員的執(zhí)業(yè)活動進(jìn)行檢查，查處違法行為；對醫(yī)療機(jī)構(gòu)、采供血機(jī)構(gòu)、母嬰保健技術(shù)服務(wù)機(jī)構(gòu)、疾病預(yù)防控制機(jī)構(gòu)和蒙中醫(yī)藥機(jī)構(gòu)的傳染病疫情報告、疫情控制措施、消毒隔離制度執(zhí)行情況、醫(yī)療廢棄物處置情況和菌(毒)種管理情況、疫苗接種等進(jìn)行日常監(jiān)督檢查，查處違法行為；受理違法行為和事件的投訴、舉報和查處工作；依法打擊“兩非”(非醫(yī)學(xué)需要的胎兒性別鑒定和非醫(yī)學(xué)需要的人工終止妊娠行為)行為，對違法違紀(jì)案件查處。
3、執(zhí)法依據(jù)：《中華人民共和國傳染病防治法》、《中華人民共和國基本醫(yī)療和健康促進(jìn)法》、《中華人民共和國執(zhí)業(yè)醫(yī)師法》、《中華人民共和國母嬰保健法》、《中華人民共和國獻(xiàn)血法》《醫(yī)療廢物管理條例》、《疫苗流通和預(yù)防接種管理條例》和《醫(yī)療機(jī)構(gòu)管理條例》等?
（六）職業(yè)衛(wèi)生監(jiān)督檢查。
1、適應(yīng)范圍：轄區(qū)內(nèi)職業(yè)病防治活動。??
? ?2、主要職責(zé)：查閱或者復(fù)制單位和個人與違反職業(yè)病防治法律、法規(guī)的行為有關(guān)的資料和采集樣品；責(zé)令違反職業(yè)病防治法律、法規(guī)的單位和個人停止違法行為；對職業(yè)病防治工作進(jìn)行監(jiān)督檢查；責(zé)令暫停導(dǎo)致職業(yè)病危害事故的作業(yè)；封存造成職業(yè)病危害事故或者可能導(dǎo)致職業(yè)病危害事故發(fā)生的材料和設(shè)備；組織控制職業(yè)病危害事故現(xiàn)場。
3.執(zhí)法依據(jù)：《中華人民共和國職業(yè)病防治法》、《用人單位職業(yè)健康監(jiān)護(hù)監(jiān)督管理辦法》、《工作場所職業(yè)衛(wèi)生監(jiān)督管理規(guī)定》、《職業(yè)病危害項目申報辦法》和《建設(shè)項目職業(yè)衛(wèi)生“三同時”監(jiān)督管理暫行辦法》等。
（七）餐具、飲具集中消毒服務(wù)單位衛(wèi)生監(jiān)督檢查。
1.適應(yīng)范圍：轄區(qū)內(nèi)餐具、飲具集中消毒服務(wù)單位
2.主要職責(zé)：對餐具、飲具集中消毒服務(wù)單位的監(jiān)督檢查、對餐具、飲具集中消毒服務(wù)單位違反《?中華人民共和國食品安全法》進(jìn)行查處。
3.執(zhí)法依據(jù)：《?中華人民共和國食品安全法》、《餐具、飲具集中消毒服務(wù)單位衛(wèi)生監(jiān)督工作規(guī)范》
（八）消毒產(chǎn)品的經(jīng)營、使用單位衛(wèi)生監(jiān)督檢查。
1.適應(yīng)范圍：轄區(qū)內(nèi)消毒產(chǎn)品的經(jīng)營、使用單位
2.主要職責(zé)：負(fù)責(zé)轄區(qū)內(nèi)消毒產(chǎn)品監(jiān)督檢查；負(fù)責(zé)開展轄區(qū)內(nèi)消毒產(chǎn)品違法案件的查處。
3.執(zhí)法依據(jù)：《?中華人民共和國傳染病防治法》、《 消毒管理辦法》和《消毒產(chǎn)品衛(wèi)生監(jiān)督工作規(guī)范》。
（九）完成區(qū)委、區(qū)政府交辦的其他任務(wù)。
一般會先約談。
職業(yè)健康監(jiān)管人員指出了近期檢查中發(fā)現(xiàn)的主要職業(yè)健康問題包括職業(yè)衛(wèi)生管理組織和制度不健全、職業(yè)病危害項目申報不及時、工作場所職業(yè)病危害因素未定期檢測、勞動者未進(jìn)行職業(yè)健康檢查、職業(yè)病危害警示標(biāo)識設(shè)置不全和個人防護(hù)用品配備不全等，對企業(yè)存在問題應(yīng)承擔(dān)的法律責(zé)任進(jìn)行了說明，
同時指導(dǎo)企業(yè)制定切實可行的整改方案，要求企業(yè)務(wù)必高度重視職業(yè)健康管理工作，迅速落實整改措施，切實保障勞動者身體健康。
通過約談，參會負(fù)責(zé)人表示將高度重視職業(yè)健康工作，對執(zhí)法人員檢查中發(fā)現(xiàn)的問題立即整改到位。下一步，市衛(wèi)生健康綜合執(zhí)法大隊將繼續(xù)加大轄區(qū)內(nèi)企業(yè)職業(yè)健康工作監(jiān)督檢查力度，對發(fā)現(xiàn)問題進(jìn)行行政處罰。
不需要找任何執(zhí)法大隊，辦理健康證只需要帶上本人身份證，去衛(wèi)生局指定的醫(yī)院免費(fèi)辦理，醫(yī)院有專的健康證辦理窗口，早晨空腹憑身份證領(lǐng)取體檢表，檢查大便，血常規(guī)，胸透三個項目，五個工作日后，帶身份證和體檢表去發(fā)放窗口查詢，合格就能拿到健康證。
網(wǎng)絡(luò)執(zhí)法通常通過監(jiān)控、調(diào)查和打擊違法行為來維護(hù)網(wǎng)絡(luò)秩序和安全。執(zhí)法部門會利用技術(shù)手段對網(wǎng)絡(luò)進(jìn)行跟蹤和監(jiān)視，收集證據(jù)并對違法行為進(jìn)行調(diào)查。一旦發(fā)現(xiàn)違法行為，執(zhí)法部門會采取相應(yīng)的行動，比如對違法人員進(jìn)行逮捕、起訴或罰款。此外，執(zhí)法部門還會加強(qiáng)對網(wǎng)絡(luò)安全的監(jiān)督，防范網(wǎng)絡(luò)犯罪活動。總之，網(wǎng)絡(luò)執(zhí)法需要高度的技術(shù)和專業(yè)知識，以及法律的支持和合作來維護(hù)網(wǎng)絡(luò)秩序和社會安全。
隨著現(xiàn)代社會的不斷發(fā)展和進(jìn)步，心理健康教育越來越受到人們的關(guān)注。作為一名心理健康教師，無論是在學(xué)校還是在社會上，都承擔(dān)著重要的任務(wù)和責(zé)任。面對面試的機(jī)會，我們必須充分準(zhǔn)備，以展現(xiàn)出我們的專業(yè)知識和才能。
面試題目
在準(zhǔn)備心理健康教師面試時，我們需要關(guān)注一些常見的面試題目。這些問題幫助面試官了解我們的專業(yè)背景和能力，同時也是對我們面試準(zhǔn)備的一種考驗。以下是一些常見的心理健康教師面試題目：
- 1. 請介紹一下您的個人背景和學(xué)術(shù)經(jīng)歷。
- 2. 您是如何理解心理健康教育的？
- 3. 您在心理健康教育方面有哪些獨(dú)特的見解和觀點？
- 4. 如何應(yīng)對學(xué)生在心理健康方面的問題和挑戰(zhàn)？
- 5. 請分享一次您成功幫助學(xué)生解決心理健康問題的經(jīng)歷。
- 6. 您對心理健康教育中的課程開發(fā)有何想法？
- 7. 您在解決團(tuán)隊合作中的沖突方面有何經(jīng)驗？
- 8. 您對心理健康教育未來的發(fā)展有何預(yù)期？
如何回答面試題目
在回答心理健康教師面試題目時，我們應(yīng)該展現(xiàn)出自己的專業(yè)知識、經(jīng)驗和才能。下面是一些建議，幫助我們回答這些面試題目：
- 1. 請介紹一下您的個人背景和學(xué)術(shù)經(jīng)歷。
我們可以從自己的教育背景、工作經(jīng)驗和參與的項目中介紹自己。特別強(qiáng)調(diào)與心理健康教育相關(guān)的經(jīng)歷，例如參與學(xué)生心理咨詢、組織心理健康教育講座等。
- 2. 您是如何理解心理健康教育的？
我們可以強(qiáng)調(diào)心理健康教育的定義，即通過教育手段提升學(xué)生的心理健康水平。同時，我們還可以分享我們對于心理健康教育的重要性和影響的理解。
- 3. 您在心理健康教育方面有哪些獨(dú)特的見解和觀點？
我們可以分享自己對于心理健康教育的研究成果、實踐經(jīng)驗或者專業(yè)觀點。重點突出自己的創(chuàng)新性和對于心理健康教育的深入思考。
- 4. 如何應(yīng)對學(xué)生在心理健康方面的問題和挑戰(zhàn)？
我們可以強(qiáng)調(diào)個案思考和系統(tǒng)化方法，例如與學(xué)生進(jìn)行個別心理咨詢、組織心理健康工作坊等。同時，我們還可以提到與家長、教師和學(xué)校合作的重要性。
- 5. 請分享一次您成功幫助學(xué)生解決心理健康問題的經(jīng)歷。
我們可以具體描述一次成功的案例，并強(qiáng)調(diào)我們在這個過程中的角色和貢獻(xiàn)。著重表達(dá)自己的洞察力、專業(yè)知識和與學(xué)生之間的良好溝通。
- 6. 您對心理健康教育中的課程開發(fā)有何想法？
我們可以提到個人對于課程開發(fā)的經(jīng)驗和理解。重點強(qiáng)調(diào)學(xué)生的參與性、案例教學(xué)和實踐性的要求。
- 7. 您在解決團(tuán)隊合作中的沖突方面有何經(jīng)驗？
我們可以分享自己在團(tuán)隊合作中處理沖突的經(jīng)驗。重點強(qiáng)調(diào)積極溝通、傾聽他人觀點、尋求共識的重要性。
- 8. 您對心理健康教育未來的發(fā)展有何預(yù)期？
我們可以提到心理健康教育在未來的重要性和發(fā)展趨勢。重點關(guān)注社會需求的變化、科技的應(yīng)用和教育政策的支持。
總結(jié)
心理健康教師面試是一個展示我們專業(yè)能力和知識的機(jī)會。通過充分準(zhǔn)備，回答面試題目時可以突出自己的優(yōu)勢和獨(dú)特性。相信通過良好的準(zhǔn)備和自信的表現(xiàn)，我們一定能夠成功地通過心理健康教師面試，為學(xué)生的心理健康教育做出貢獻(xiàn)。
答：
1. 是的，衛(wèi)生健康綜合執(zhí)法大隊退休屬企業(yè)待遇。
2. 原因是衛(wèi)生健康綜合執(zhí)法大隊是屬于國家機(jī)關(guān)的一種特殊編制，其工作性質(zhì)與企業(yè)不同，但是在退休待遇上，衛(wèi)生健康綜合執(zhí)法大隊的退休人員享有與企業(yè)退休人員相同的待遇。
這是因為國家對于退休人員的待遇是有一定的規(guī)定和保障的，無論是企業(yè)還是國家機(jī)關(guān)，都應(yīng)該按照規(guī)定給予退休人員應(yīng)有的待遇。
3. 如果您是衛(wèi)生健康綜合執(zhí)法大隊的退休人員，想要了解自己的退休待遇，可以按照以下步驟進(jìn)行操作：
- 首先，查看自己的退休證明或者相關(guān)的工作證明，確認(rèn)自己的退休身份和待遇；
- 其次，可以咨詢所在單位的人事部門或者退休管理部門，了解自己的具體待遇標(biāo)準(zhǔn)和發(fā)放方式；
- 最后，如果有任何疑問或者不滿意的地方，可以向相關(guān)部門提出申訴或者投訴，維護(hù)自己的合法權(quán)益。
作為執(zhí)法人員。應(yīng)該積極的認(rèn)真的學(xué)習(xí)國家的法律法規(guī)。并且積極的做到文明執(zhí)法。堅決不越權(quán)執(zhí)法或者是暴力執(zhí)法的違法執(zhí)法行為。并且在執(zhí)法的時候要依法依規(guī)的按照國家的法律法規(guī)。絕對要做到公平公正的執(zhí)法，絕對不能選擇性的執(zhí)法。并且執(zhí)法的時候一定要向被執(zhí)法人出示執(zhí)法證。并且說明自己所在的執(zhí)法單位和此次前來執(zhí)行的法律任務(wù)。
之前看了Mahout官方示例 20news 的調(diào)用實現(xiàn)；于是想根據(jù)示例的流程實現(xiàn)其他例子。網(wǎng)上看到了一個關(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
檢測數(shù)據(jù)：
sunny，hot，high，weak
結(jié)果：
Yes=》 0.007039
No=》 0.027418
于是使用Java代碼調(diào)用Mahout的工具類實現(xiàn)分類。
基本思想：
1. 構(gòu)造分類數(shù)據(jù)。
2. 使用Mahout工具類進(jìn)行訓(xùn)練，得到訓(xùn)練模型。
3。將要檢測數(shù)據(jù)轉(zhuǎn)換成vector數(shù)據(jù)。
4. 分類器對vector數(shù)據(jù)進(jìn)行分類。
接下來貼下我的代碼實現(xiàn)=》
1. 構(gòu)造分類數(shù)據(jù)：
在hdfs主要創(chuàng)建一個文件夾路徑 /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。將要檢測數(shù)據(jù)轉(zhuǎn)換成vector數(shù)據(jù)。
4. 分類器對vector數(shù)據(jù)進(jìn)行分類。
這三步，代碼我就一次全貼出來；主要是兩個類 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";
/*
* 測試代碼
*/
public static void main(String[] args) {
//將訓(xùn)練數(shù)據(jù)轉(zhuǎn)換成 vector數(shù)據(jù)
makeTrainVector();
//產(chǎn)生訓(xùn)練模型
makeModel(false);
//測試檢測數(shù)據(jù)
BayesCheckData.printResult();
}
public static void makeCheckVector(){
//將測試數(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(){
//將測試數(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("檢測數(shù)據(jù)構(gòu)造成vectors初始化時報錯。。。。");
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);
TFIDF tfidf = new TFIDF();
//sunny，hot，high，weak
Multiset<String> words = ConcurrentHashMultiset.create();
words.add("sunny",1);
words.add("hot",1);
words.add("high",1);
words.add("weak",1);
int documentCount = documentFrequency.get(-1).intValue(); // key=-1時表示總文檔數(shù)
for (Multiset.Entry<String> entry : words.entrySet()) {
String word = entry.getElement();
int count = entry.getCount();
Integer wordId = dictionary.get(word); // 需要從dictionary.file-0文件（tf-vector）下得到wordID，
if (StringUtils.isEmpty(wordId.toString())){
continue;
}
if (documentFrequency.get(wordId) == null){
continue;
}
Long freq = documentFrequency.get(wordId);
double tfIdfValue = tfidf.calculate(count, freq.intValue(), 1, documentCount);
vector.setQuick(wordId, tfIdfValue);
}
// 利用貝葉斯算法開始分類,并提取得分最好的分類label
Vector resultVector = classifier.classifyFull(vector);
double bestScore = -Double.MAX_VALUE;
int bestCategoryId = -1;
for(Element element: resultVector.all()) {
int categoryId = element.index();
double score = element.get();
System.out.println("categoryId:"+categoryId+" score:"+score);
if (score > bestScore) {
bestScore = score;
bestCategoryId = categoryId;
}
}
classify = labelIndex.get(bestCategoryId)+"(categoryId="+bestCategoryId+")";
return classify;
}
public static void printResult(){
System.out.println("檢測所屬類別是："+getCheckResult());
}
}
