1、調用EsSpark.esRDD 返回RDD[Tuple2[String, scala.collection.Map[String, AnyRef]]] ,其中String為es的id
2、調用EsSparkSQL.esDF返回DataFrame
1、調用EsSpark.esRDD 返回RDD[Tuple2[String, scala.collection.Map[String, AnyRef]]] ,其中String為es的id
2、調用EsSparkSQL.esDF返回DataFrame
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。