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

c# - The item with identity 'Id' already exists in the metadata collection. Parameter name: item -

-
मेरी सभी संस्थाओं का आधार वर्ग है: सार्वजनिक वर्ग इकाई & lt; TKey & gt; : आईएरिटीटी & lt; टीके & gt; {गतिशील आईईआरटीईटी.आईडी {प्राप्त करें} इस आईआईडी; } सेट {this.Id = मान; }} सार्वजनिक TKey Id {get; सेट; }} उदाहरण के लिए स्थिति इकाई: [मेटाडाटा टाइप (टाइपफ (स्टेटसमैटडेटा))] सार्वजनिक आंशिक श्रेणी की स्थिति: इकाई & lt; बाइट & gt; {सार्वजनिक स्ट्रिंग शीर्षक {प्राप्त करें; सेट; }} जब मैं डेटाबेस के विरुद्ध क्वेरी चलाऊँगा तो मुझे निम्न त्रुटि मिलती है: "पहचान 'आईडी वाला आइटम पहले से ही मेटाडेटा संग्रह में मौजूद है। पैरामीटर का नाम: आइटम" क्या यह तय करने का कोई तरीका है या यह किसी वारसा के कारण हुई समस्या है और मैं किसी भी वर्ग से अपनी संस्थाओं का वारिस नहीं कर सकता हूं? यह एक सामान्य त्रुटि है, कुछ जानकारी के लिए खोज करते हुए, मैंने देखा कि: दो तालिकाओं को एक प्राथमिक कुंजी के लिए एक ही नाम हो सकता है लाइटस्विच टेबल्स को देखो, उन सभी को एक प्राथमिक कुंजी है जिन्हें आईडी कहा जाता है। इसलिए, मैं सभी संस्थाओं की समीक्षा करता ह...
Read more

jquery - How to make a wrapper function in javascript? -

-
I have a very low click handler: $ (document) .on (' Click ',' .xxxbtn ', function (e) {....}) I want to save one of the cookies in some of them. I can write down like this: function default handler (e, callback) {callback (e); DoSomeJobs (); } $ (Document) .on ('click', '.xxxbtn', defaultHandler (e, function (e) {`different code in each BTN .... ....}) But I think it should be handled well ( just look better and clear ): $ (document) .on ( 'Click', ' update m Maybe my example is a bit unclear. I mean if i can create defaultHandler as function statement in javascript? Just function short answser : No, there is no way to say defaultHandler (e) {...} Long answer : It is possible to achieve something like this: order functions, functions which return the function ns. Yes In JS, such a thing is possible, and even clean, short codes are required to be written. First of all, start with a simple ex...
Read more

jsp - No mapping found for HTTP request with URI with annotation config Spring MVC and Jetty -

-
Image
I'm only using annotation configuration, the server starts, but when I use some pages error is displayed: Warning: no mapping found for HTTP request with URI [/WEB-INF/view/main.jsp] name 'org.springframework.web.servlet.DispatcherServlet -D7259e with DispatcherServlet in Controller mapping works fine, but no JSP page is full. I am using Jetty 9.2.0.M0 and Spring MVC 4.0.4 release. JetTyP Config: Private Static Last String CONTEXT_PATH = "/"; Private Static Last String MAPPING_URL = "/ *"; Private Zero Server (Int port) throws exceptions {server server = new server (port); Server.addLifeCycleListener (New LifeCycleListener ()); Server.setHandler (getServletContextHandler (getContext ())); Server.start (); Server.join (); } Private static ServletContextHandler getServletContextHandler (WebApplicationContext context) throws IOException {LOGGER.info ( "ServletContextHandler is ready"); CircleContaxHandler themeHandler = new circactont...
Read more