How to execute a flume configuration file using java program? -

-

मेरे पास फ्लू कॉन्फ़िगरेशन फ़ाइल है filename.conf , जब मैं इस फाइल को टर्मिनल में निष्पादित करता हूँ तो यह काम करता है कुंआ। लेकिन मैं रनटाइम.गेटरीटाइम ()। Exec फ़ंक्शन का उपयोग करके जावा प्रोग्राम में एक ही फ़ाइल को उत्तेजित करने की कोशिश कर रहा हूं। यह

यह मेरा flume निष्पादन कमांड: 

  / home / path / flume / bin / flume-ng एजेंट --conf फाइल /होम / पाथ / फ्लूमेम / फ़िलेनाम.कॉम --name एजेंट- Dflume.root .logger = INFO, कंसोल   
 यह मेरा जावा कोड है:  
  प्रक्रिया p; P = Runtime.getRuntime ()। Exec ("/ home / path / flume / bin / flume-ng एजेंट --conf फाइल /होम / पाथ / फ्लूमेम / फ़िलेनाम। कॉन्फ़ - नाम चहचहानाअगेंट- Dflume.root.logger = जानकारी, कंसोल "); p.waitFor (); BufferedReader रीडर = नया BufferedReader (नया InputStreamReader (p.getInputStream ())); स्ट्रिंग रेखा = ""; जबकि ((रेखा = रीडर। रीडलाइन ()) = नल) {System.out.println (रेखा); }   
 मुझे कोई त्रुटि नहीं मिल रही है।   
 
 
 जावा प्रोग्राम का प्रयोग करके कॉन्फ़ फाइल को चलाने के लिए एक एपलीकेशन क्लास। कृपया नीचे कार्यक्रम खोजें।  <पूर्व>  आयात करें org.apache.flume.node.Application; आयात करें org.apache.log4j.BasicConfigurator; सार्वजनिक कक्षा फ्लोम {सार्वजनिक स्थिर शून्य मुख्य (स्ट्रिंग [] आर्ग्स) {स्ट्रिंग [] args1 = नया स्ट्रिंग [] {"एजेंट", "- nTwitterAgent", "- fflume.conf"}; BasicConfigurator.configure (); Application.main (args1); System.setProperty ("hadoop.home.dir", "/"); }}   
 अनुप्रयोग वर्ग में आपको अपने एजेंट, एजेंटनाम और flume.conf फ़ाइल पथ की आवश्यकता है। यहाँ मेरे मामले में flume.conf फ़ाइल मेरी प्रोजेक्ट कक्षापथ में है, इसलिए मैंने सिर्फ-fflume.conf के रूप में निर्दिष्ट किया है यदि यह एक अलग निर्देशिका में है, तो आपको वहां पूर्ण पथ निर्दिष्ट करना होगा। इसके बाद आप इसे सामान्य जावा प्रोग्राम के रूप में चला सकते हैं।

Comments

Post a Comment

Popular posts from this blog

Selenium IDE Conditional Statements -

-
I want to ask if there is another way to see the error label, which has been shown whether we There is no need to fill up with the necessary to use the verifyText command. Here's an example: id: [required] PW: [required] Email: [expected] Dropdown box: [required] If you make test cases, then there is an easy way to make a test case first, and then three error labels will show whether the other fields will not be filled with that. The PW or email from the dropdown box will be shown even if the error is filled with the error label. Before saving that field, I'm just using the verified text, but if there are many conditional requirements like this there is no easy and easy way to create this testcase? Thx If I understand you correctly, If you ignore the required text fields, you are searching for a way to verify that error message. Since I know the Waitfortext command and expect the error message to appear, this command will wait until it expects the err...
Read more

sql - Select count and aggregate, but only unique -

-
Image
मेरे पास टेबल के साथ एक डाटाबेस (MSSQL) है: बनाएँ तालिका [ डीपीए] [साइप्रर्स] ([टाइम] [डेटाइम] NULL, [होस्टनाम] [वरारार] (50) नल, [क्लाइंटआईपी] [वरारार] (50) नल, [यूजरएजेंट] [वरारार] (550) नल, [साइफर नेम ] [दोहराव] (200) नल, [साइफरवर्सन] [वरचर] (100) नल, [साइफरबिट्स] [वरारार] (50) नल) पर [प्राथमिक] कुछ पंक्तियाँ इस तरह दिख सकते हैं: अब का चयन करें CipherName, CipherVersion, CipherBits, मैं प्रत्येक शीर्ष स्तर डोमेन के लिए CipherName, CipherVersion और CipherBits के संयोजन की घटनाओं की संख्या की गणना करना चाहते हैं। , सीआईपीआरएन नाम, साइफरविर्सियन, साइफरबिट्स द्वारा समूह '% domain.com' समूह की तरह सीपर्स से "हिट्स" के रूप में, "हिट्स", क्रैक्स यह है कि मैं केवल विशिष्ट उदाहरणों की गिनती करना चाहता हूं प्रत्येक ग्राहक आईपी यही है, अगर कोई ग्राहक sub.domain.com और test.domain.com पर गया है तो मैं इसे दो के रूप में नहीं मानना ​​चाहता, बस एक। यह देखते हुए कि आप HostName द्वारा समूह नहीं कर रहे हैं, ऐसा लगता है कि आपकी ज़रूरत है: SE...
Read more

ruby on rails - How to avoid ActionController::InvalidCrossOriginRequest exception? -

-
मैंने Rails 4.1 को अपने रेल ऐप को अपडेट किया है और ActionController :: InvalidCrossOriginRequest अपवाद प्राप्त करना शुरू कर दिया है। मुझे पाया गया कि बिंग बॉट्स सक्रिय रूप से मेरी गतिशील रूप से जेनरेट की गई जावास्क्रिप्ट फाइल को क्रॉल करते हैं। मुझे लगता है कि यह सही है कि रेलवे इस अपवाद को उठाती है क्योंकि जावास्क्रिप्ट को सीधे कहा जाता है, लेकिन मेरा लॉग इस अपवाद के साथ भरा हुआ है। > सीएसआरएफ संरक्षण को बंद किए बिना इस अपवाद को बढ़ाने से बॉट्स से बचने का कोई तरीका क्या है? मेरा नियंत्रक ऐसा दिखता है। वर्ग सूचियाँ नियंत्रक & lt; ApplicationController before_filter: authenticate_user! Def add @list = List.find (params [: आईडी]) response_to do | format | Format.js {render 'add'} format.html {redirect_to list_path (@list)} एंड एंड एंड जेएच के उत्तर में जोड़ने के लिए और मानते हुए कि आपको कुछ सहायता चाहिए, आपको पता होना चाहिए कि हर मेजबान यह निर्धारित करने के लिए उपयोग करता है कि उनके सर्वर का कौन (और नहीं) पहुंच सकता है सीधे आपकी त्रुटि मूल रूप से है क...
Read more