structured-streaming 第12页

2015-08-13admin阅读(1230)赞(0)

KafkaOffsetReader KafkaOffsetReader is created when: KafkaRelation builds an RDD with rows that are records fr ...

2015-08-12admin阅读(1210)赞(0)

CachedKafkaConsumer Caution FIXME poll Internal Method Caution FIXME fetchData Internal Me ...

2015-08-11admin阅读(1080)赞(0)

KafkaSourceRDD KafkaSourceRDD is an RDD of Kafka’s ConsumerRecords (with keys and values being collections o ...

2015-08-10admin阅读(1227)赞(0)

KafkaRelation KafkaRelation is…​FIXME KafkaRelation is created when…​FIXME Creating K ...

2015-08-09admin阅读(5392)赞(0)

KafkaSource KafkaSource is a streaming source that generates DataFrames of records from one or more topics in Apac ...

2015-08-08admin阅读(5360)赞(0)

KafkaSourceProvider — Data Source Provider for Apache Kafka

2015-08-07admin阅读(1781)赞(0)

Configuration Properties The following list are the properties that you can use to fine-tune Spark Structured Stre ...

2015-08-06admin阅读(1368)赞(0)

SQLConf — Internal Configuration Store

2015-08-05admin阅读(2053)赞(0)

StreamingQueryManager — Streaming Query Management

2015-08-04admin阅读(1410)赞(0)

GroupStateTimeout GroupStateTimeout represents the possible timeouts that you can use for the state-aware Dataset ...