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

Post a Comment

Popular posts from this blog

How can I add a seperate action listener to all 14 of my buttons at once that can determine player turn?(java) -

I have a big code, for a game I'm calling Tommy's Kumamak. I know that this is not beautiful, but I am very naive and for some reasons I know from using arrays, anyway, my problem is that I can not add a variable outside the listener and within the action listener I can modify the variable (pTurn ++) from How can I go about adding a count to that variable from inside the action listener? 1 error was found: file: c: \ user \ public \ togiz_kumalak.java [line: 130] error: local variables pTurn is accessed from within internal class; Need to be declared final int pTurn = 0; Button1.addActionListener {new zero-action action (action event e) {pTurn ++; if (pTurn% 2 == 0) {display.append ("\ n Player 2 cup 1");} If ( PTurn% 2! = 0) {display.append ("\ nPlayer 1Cup 1")}}); In that case, move the contents of the functionalities into orbit and then call the action For example, display the method from: Private Zero Button Press {pTurn ++; If (pTurn% 2...
Read more

php - Sorting an multidimension array using usort fails -

I tried to use custom-made YouTube fun cats when I ran 5 cell arrays in 30 seconds and then a Throwing a serious error. I tried to know that I have been made an infinite loop, but he did not install it. iPhone 5S 32GB [Price] => 0 [Description] => A new apple product [Image_URL] = & Gt; [Business_ID] = & gt; 6 [keyword] = & gt; ["iPhone", "iPhone 5s", "Apple", "32 GB"]) [1] = & gt; array ([name] = & Gt; iPhone 4S 32g [Price] => 300 [Description] => Apple iPhone 4S = [Image_URL] => [Business_ID] => 6 [Keyword] = & gt; [ "IPhone 4S", "" iPhone "," Apple "," 32 GB "])) search: $ searchTerm =" iphone 5s "; Code: if (! SearchTerm below!) {$ SearchTermWords = Explosion (" ", $ searchTerm); $$ $$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$ ['Keyword']; $ bKeywords = $...
Read more

Simple file compression in C -

I am new to programming with C, and I need elsewhere that I can read on file compression in C I am I only need a simple accredited method, for example it will help but mostly I can read it to understand. Probably a good starting point RLE is very simple but it is not so insignificant to apply see it :
Read more