标签：structured-streaming

2015-08-21admin阅读(1748)赞(0)

RateSourceProvider RateSourceProvider is a StreamSourceProvider for RateStreamSource (that acts as the source for ...

2015-08-20admin阅读(1730)赞(0)

FileStreamSink — Streaming Sink for Parquet Format

2015-08-19admin阅读(1539)赞(0)

FileStreamSource FileStreamSource is a Source that reads text files from path directory as they appear. It uses Lo ...

2015-08-18admin阅读(1616)赞(0)

TextSocketSource TextSocketSource is a streaming source that reads lines from a socket at the host and port (defin ...

2015-08-17admin阅读(2082)赞(0)

TextSocketSourceProvider TextSocketSourceProvider is a StreamSourceProvider for TextSocketSource that read records ...

2015-08-16admin阅读(1830)赞(0)

KafkaSink KafkaSink is a streaming sink that KafkaSourceProvider registers as the kafka format. [crayon-69a87058e ...

2015-08-15admin阅读(1494)赞(0)

KafkaSourceOffset KafkaSourceOffset is a OffsetV2 that…​FIXME KafkaSourceOffset takes a collection o ...

2015-08-14admin阅读(1651)赞(0)

ConsumerStrategy Contract for KafkaConsumer Providers

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

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

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

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