डेटाफ़्रेम से RDD [(स्ट्रिंग, स्ट्रिंग)] रूपांतरण

यदि आप किसी पंक्ति को किसी भिन्न RDD तत्व में मैप करना चाहते हैं, तो डेटाफ़्रेम को RDD में बदलने के लिए आप df.map(row => ...) का उपयोग कर सकते हैं।

उदाहरण के लिए:

val df = Seq(("table1",432),
      ("table2",567),
      ("table3",987),
      ("table1",789)).
      toDF("tablename", "Code").toDF()

    df.show()

    +---------+----+
|tablename|Code|
+---------+----+
|   table1| 432|
|   table2| 567|
|   table3| 987|
|   table1| 789|
+---------+----+

    val rddDf = df.map(r => (r(0), r(1))).rdd // Type:RDD[(Any,Any)]

    OR

    val rdd = df.map(r => (r(0).toString, r(1).toString)).rdd  //Type: RDD[(String,String)]

कृपया देखें https://community.hortonworks.com/questions/106500/error-in-spark-streaming-kafka-integration-structu.html के बारे में AnalysisException:स्ट्रीमिंग स्रोतों वाली क्वेरी को राइटस्ट्रीम.स्टार्ट() के साथ निष्पादित किया जाना चाहिए

आपको क्वेरी का उपयोग करके क्वेरी के समाप्त होने की प्रतीक्षा करनी होगी।वेट टर्मिनेशन () क्वेरी सक्रिय होने पर प्रक्रिया को बाहर निकलने से रोकने के लिए।