structured-streaming 第11页

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

MemorySinkV2 MemorySinkV2 is…​FIXME

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

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

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

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

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

FileStreamSink — Streaming Sink for Parquet Format

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

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

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

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

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

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

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

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

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

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

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

ConsumerStrategy Contract for KafkaConsumer Providers