spark CatalystDataToProtobuf 代码
文件路径:/connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/CatalystDataToProtobuf.scala
阅读全文
spark SparkAWSCredentials 源码
spark SparkAWSCredentials 代码
文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/SparkAWSCredentials.scala
阅读全文
spark KinesisUtilsPythonHelper 源码
spark KinesisUtilsPythonHelper 代码
文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisUtilsPythonHelper.scala
阅读全文
spark KinesisTestUtils 源码
spark KinesisTestUtils 代码
文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisTestUtils.scala
阅读全文
spark KinesisRecordProcessor 源码
spark KinesisRecordProcessor 代码
文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisRecordProcessor.scala
阅读全文
spark KinesisReceiver 源码
spark KinesisReceiver 代码
文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala
阅读全文
spark KinesisReadConfigurations 源码
spark KinesisReadConfigurations 代码
文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReadConfigurations.scala
阅读全文
spark KinesisInputDStream 源码
spark KinesisInputDStream 代码
文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisInputDStream.scala
阅读全文
spark KinesisCheckpointer 源码
spark KinesisCheckpointer 代码
文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisCheckpointer.scala
阅读全文
spark KinesisBackedBlockRDD 源码
spark KinesisBackedBlockRDD 代码
文件路径:/connector/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDD.scala
阅读全文