एक Combiner मैपर के बाद और प्रसारण से पहले चलाता में क्लास, यह। सभी डेटा किसी दिए गए नोड पर मैपर उदाहरणों द्वारा उत्सर्जित इनपुट के रूप में प्राप्त होगा तो कम करने के लिए उत्पादन का उत्सर्जन करता है।
मैं एडब्ल्यूएस (एक स्ट्रीमिंग नौकरी) के माध्यम से एक नक्शा केवल नौकरी बनाने की कोशिश कर रहा हूँ। रेड्यूसर फ़ील्ड आवश्यक है, इसलिए मैं एक डमी निष्पादन योग्य दे रहा हूं, और अतिरिक्त Args बॉक्स में -jobc
मैं नए Clojure 1.5 reducers पुस्तकालय के लिए निम्न उदाहरण कन्वर्ट करने के लिए कोशिश कर रहा हूँ के साथ तह: (reduce max (map inc (range 10)))
;=> 10
जब मैं है- बदल मैं निम्नलिखित त्रुटि मिलती है: (r/
के साथ एकाधिक आउटपुट का परीक्षण करना MRUnit के साथ कक्षा को कम करने का कोई तरीका है जो एकाधिक आउटपुट फ़ाइलों को लिखने के लिए MultipleOutputFormat का उपयोग करता है?