spark KafkaSource 源码

spark KafkaSource 代码 文件路径:/connector/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala
阅读全文

spark KafkaSink 源码

spark KafkaSink 代码 文件路径:/connector/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSink.scala
阅读全文

spark KafkaRelation 源码

spark KafkaRelation 代码 文件路径:/connector/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala
阅读全文

spark KafkaOffsetReader 源码

spark KafkaOffsetReader 代码 文件路径:/connector/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaOffsetReader.scala
阅读全文