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
Post a Comment