apache pig - Maintaining Order of data in Pig Script -


मान लें कि मेरे पास निम्न पीआईजी स्क्रिप्ट है 

  record = LOAD 'input' का प्रयोग PigStorage ('\ T') के रूप में (आईडी, नाम, आयु); आदेश दिया गया रेकार्ड = आयु आयु एएससी द्वारा रिकॉर्ड; FinalRecord = FOREACH का आदेश दिया गया रिकार्ड आईडी, नाम; संग्रहित रिकॉर्ड्स = LIMIT अंतिम रेकार्ड 1000; स्टोर में संग्रहित रिकॉर्ड्स में 'आउटपुट';

मुझे पता है कि आदेश दिया गया आदेश उम्र के आधार पर सॉर्ट किया जाएगा, लेकिन जब मैंने आदेश दिया रेकार्ड से आयु निकाल दी है, तब भी डेटा क्रमबद्ध क्रम में है मैं सिर्फ 1000 डेटा बिंदुओं को सिर्फ आईडी और उम्र के आधार पर सॉर्ट करना चाहता हूं।

नहीं, यह मेरी समझ के अनुसार सॉर्ट किया जा सकता है लेकिन इसकी गारंटी नहीं है।

जैसा कि आप जानते हैं कि आप इस डेटा को आगे बढ़ाने की प्रक्रिया करते हैं, तो आप ऑर्डर खो देंगे। इसलिए यह गारंटी नहीं है कि आपका डेटा क्रमबद्ध रहेगा लेकिन इसके शेष आदेशों की संभावना अभी भी मौजूद है।


Comments

Post a Comment

Popular posts from this blog

scala - Play Framework - how to bind form to a session field -

Is there any way, I can get some parameters from the header, cookies (log in userId in my case) , And then apply it in a form which I know who will deposit the ticket? SupportForm supportForm: form [supportTicket] = form (mapping ("question" -> text, "priority" -> text) (apply support ticket. (HelpText.update) What are the good practices here? What is the call to apply the request, when I can use it (and also a good practice?) Edit An issue, absolutely deceiving anyone if I were to create a hidden area with this value. It could Ript, but the issue may be re-used in any way to verify and return the form, it can not be sure how it ....
Read more

Django Celery - running scheduled tasks -

After several hours on this without the result, I really need help I'm able to run Django-Celery with my Django app and I scheduled tasks on it: dragon manage.py celeryd -E -B -l INFO Now it is time to produce and here it is that my pain begins. I have configured the cellarid as the daemon, it works, but scheduled tasks will not work. So I added -b to CELERYD_OPTS . My tasks are now run as scheduled, but these are the boring lines on my logs: [2014-02-17 22: 37: 30,738: debuts / main process] Beat: 5.00 Waking in seconds I just want to delete that line from my logs! I did not even understand what it meant. So I had configured the Selerbeat daemon, thinking it would be a cleaner and suggest a solution to the production environment. Unfortunately, when I stop the celerybeat daemon, it creates a log and a PID file but scheduled tasks do not work. Info / main process] green: ... [2014-02-17 19: 15: 41,921: information / main process] write entries. .. [...
Read more

perl - 'Unquoted string ".." may clash with future reserved word' but only when package is used -

I ran into this problem while trying to reactor one of my modules in the object-oriented code. I compressed it down to the bottom. Here is the list of 3 files I am using: _mypkg.pm: Usage _debug; Use _debug dprint; Package mypkg; Sub New {my ($ class,% args) = @_; My $ self = blessing {}, $ square; DPPrint "PKG \ n"; Return $ self; } 1; _debug.pm: # package mydebug; # Getting this line gets an error 500 $ my bprint = ""; Sub print_now {print "print:". $ Bprint; $ Bprint = "";} Subprint {$ bprint. = "@_"; } Subdeprint {bprint @_; } 1; testfile.cgi: #! / Usr / bin / perl is required '_mypkg.pm'; #require '_debug.pm'; #use_debug; Use _debug dprint; Print "content-type: text / html \ n \ n"; DePrint "First & lt; br & gt; \ n"; & Amp; Print_now; My $ somepkg = mypkg- & gt; new (); DePrint "Second & lt; br & gt; \ n"; & Amp; Print_now; As they a...
Read more