structured-streaming 第11页

2015-08-23admin阅读(1108)赞(0)

MemorySinkV2 MemorySinkV2 is…​FIXME

2015-08-22admin阅读(1304)赞(0)

RateStreamSource RateStreamSource is a streaming source that generates consecutive numbers with timestamp that can ...

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

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

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

FileStreamSink — Streaming Sink for Parquet Format

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

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

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

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

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

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

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

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

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

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

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

ConsumerStrategy Contract for KafkaConsumer Providers