hadoop - How to pass to UDF entire relation? -


इस स्क्रिप्ट पर विचार करें:

  रजिस्टर udf-1.0.0-BETA.jar A = लोड '1.txt' का प्रयोग PigStorage ('\ t') के रूप में (key1: chararray, val1: chararray); बी = लोड '2.txt' का प्रयोग PigStorage ('\ t') के रूप में (key2: chararray, val2: chararray); में शामिल हो गए = कुंजी 1 द्वारा, कुंजी 2 द्वारा बी; बाहर = FOREACH आम में शामिल हो com.example.UDF (); कूड़ा फेंके;   

इसी तरह मेरे यूडीएफ को केवल चाबियाँ मिलें। यदि मैं यह कोशिश करता हूं:

  बाहर = FOREACH आम में शामिल हो com.example.UDF (जुड़ा हुआ);   

मुझे एक अपवाद मिला एक कॉलम को उसके लिए एक संबंध से अनुमानित किया जाना चाहिए

मैं संपूर्ण इस तरह के संबंध

  बाहर = FOREACH जून में शामिल हो com.example.UDF (ए :: कुंजी 1, ए :: वेल 1, बी :: कुंजी 2, बी :: वैल 2);   

लेकिन यह वर्बोज़ के लिए है क्या कोई आसान तरीका है?

हां, निम्न प्रयास करें:

  आउट = FOREACH आम में शामिल हो com.example.UDF (*);    

Comments

Popular posts from this blog

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

java - JPA TypedQuery: Parameter value element did not match expected type -

c++ - static template member variable has internal linkage but is not defined -