spark KinesisWordCountASL 源码

spark KinesisWordCountASL 代码 文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala
阅读全文

spark KinesisExampleUtils 源码

spark KinesisExampleUtils 代码 文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisExampleUtils.scala
阅读全文

spark KafkaTokenUtil 源码

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

spark KafkaTokenSparkConf 源码

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

spark KafkaRedactionUtil 源码

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

spark KafkaConfigUpdater 源码

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

spark CachedKafkaProducer 源码

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

spark package 源码

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