जैसे स्पार्क आरडीडी का इलाज करें मेरे पास JSON को बदलने के लिए एक सीएलआई एप्लिकेशन है। इसका अधिकांश कोड map
पिंग, flatMap
पिंग और for
JValues की सूची के साथ ट्रैवर्सिंग है। अब मैं इस एप्लिकेशन को स्पार्क पर पोर्ट करना चाहता हूं, लेकिन मुझे लगता है कि मुझे सभी कार्यों को 1: 1 को फिर से लिखना होगा, लेकिन के बजाय RDD[JValue]
लिखें।सार्क सेक
क्या लिस्ट और आरडीडी दोनों को स्वीकार करने के लिए फ़ंक्शन के लिए कोई तरीका (जैसे प्रकार वर्ग) है।
सूची और आरडीडी पर मानचित्र का विधि हस्ताक्षर समान नहीं है, इसलिए यह दर्द होगा। आप एक टाइपक्लास दृष्टिकोण के साथ जा सकते हैं और अपने मानचित्र के लिए अपना स्वयं का रैपर परिभाषित कर सकते हैं, दोनों के लिए एक उदाहरण प्रदान कर सकते हैं। यदि आप आरडीडी के लिए स्कालाज़ मोनैड और ट्रैवर्स इंस्टेंस को परिभाषित कर सकते हैं तो आप इसका उपयोग कर सकते हैं। – Daenyth
मुझे लगता है कि मज़ेदार के साथ समस्या नहीं होनी चाहिए। लेकिन पहली नज़र में आरडीडी मोनाद कानून नहीं रखता है। – chuwy
यदि आरडीडी मोनैड कानूनों का पालन नहीं करता है तो आप स्कालज़ टाइपक्लास के साथ फ्लैटमैप नहीं कर पाएंगे। उस ने कहा कि आप ऐसे संस्करण को लागू करने में सक्षम हो सकते हैं जो कानूनों का पालन नहीं करता है और यह आपकी विशिष्ट आवश्यकताओं के लिए * काम * कर सकता है। ValidationFlatMap – Daenyth