मोंगोडीबीऑब्जेक्ट को आरआरडी फ़ोरैच लूप के अंदर नहीं जोड़ा जा रहा है

एक अन्य विकल्प (जिसे मैं पसंद करूंगा) आरडीडी की धारा को वांछित डेटा प्रारूप में बदलना और foreachRDD का उपयोग करना है। द्वितीयक भंडारण में इसे बनाए रखने की विधि। यह समस्या से संपर्क करने का एक अधिक कार्यात्मक तरीका होगा। यह मोटे तौर पर इस तरह दिखेगा:

  val filteredStream = twitterStream.filter(entry => filters.exists(term => entry.getText.getStatus.contains(term)))
  val filteredStreamWithTs = filteredStream.map(x => ((DateTime.now.toString(), x)))
  filteredStreamWithTs.foreachRdd(rdd => // write to Mongo)