bigdata - How to query data stored into JavaRDD? -


मैंने व्यक्ति वस्तु बनाने के लिए Person.java नामक एक साधारण जावा वर्ग लिखा है।

उदाहरण:

  सार्वजनिक व्यक्ति () {} सार्वजनिक स्ट्रिंग getName () {वापसी का नाम; } सार्वजनिक शून्य सेटनाम (स्ट्रिंग नाम) {this.name = name; }   

मैंने तब अपाचे स्पार्क मुख्य चालक वर्ग में कोड को लागू किया।

  जावाआरडीडी & lt; व्यक्ति & gt; लोग = ctx.textFile (लॉगफ़ाइल) .मैप (नया फ़ंक्शन & lt; स्ट्रिंग, व्यक्ति & gt; () {सार्वजनिक व्यक्ति कॉल (स्ट्रिंग रेखा) अपवाद {स्ट्रिंग [] भागों = line.split ("\\ |"); व्यक्ति ट्रांस = नया व्यक्ति (); trans.setName (भाग [0]); वापसी पार;}});   

फ़ंक्शंस संकलित और ठीक चलाना है लेकिन समस्या यह है कि मैं लोगों के डेटासेट को कैसे पूछूं?

जब मैंने कोशिश की: लोग। पहले ();

आउटपुट था: Person @ 3f03a49

जो मुझे कास्टिंग के साथ समस्या मानते हैं? मैं इसे मानव पठनीय में कैसे रूपांतरित कर सकता हूं?

मैं कोशिश कर रहा था स्पार्क जैसी एक जटिल पुस्तकालय के साथ काम करते हैं व्यक्ति @ 3f03a49 कास्टिंग के साथ कोई समस्या नहीं है, इस तरह से कक्षा <कोड> व्यक्ति का एक ऑब्जेक्ट डिफ़ॉल्ट रूप से स्ट्रिंग में परिवर्तित हो जाता है आपको केवल परिभाषित करने की आवश्यकता है

  @ ओवरराइड सार्वजनिक स्ट्रिंग टूस्ट्रिंग () {वापसी "व्यक्ति (" + + + + ")"; }   

अंदर व्यक्ति वर्ग।

मैं संग्रहीत डेटा कैसे प्राप्त करूं? < P> किसी भी साथ: पहले , संग्रह , आदि। लेकिन ध्यान दें कि डिफ़ॉल्ट रूप से स्पार्क स्टोर डेटा नहीं करता है, यह मक्खी पर गणना की जाती है।

Comments

Popular posts from this blog

Java - Error: no suitable method found for add(int, java.lang.String) -

c# - passing input text from view to contoller with FacebookContext using Facebook app -

Calling a C++ function from C# by passing a string with variable size to it -