spark OffsetRange 源码

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

spark LocationStrategy 源码

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

spark KafkaUtils 源码

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

spark KafkaRDDPartition 源码

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

spark KafkaRDD 源码

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

spark KafkaDataConsumer 源码

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

spark ConsumerStrategy 源码

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

spark SparkConnectService 源码

spark SparkConnectService 代码 文件路径:/connector/connect/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala
阅读全文