标签：structured-streaming

2015-08-31admin阅读(2879)赞(0)

ForeachBatchSink ForeachBatchSink is a streaming sink that is used for the foreachBatch source. ForeachBatchSink ...

2015-08-30admin阅读(1466)赞(0)

ForeachSink ForeachSink is a typed streaming sink that passes rows (of the type T) to ForeachWriter (one record at ...

2015-08-29admin阅读(4437)赞(0)

ForeachWriter ForeachWriter is the contract for a foreach writer that is a streaming format that controls streamin ...

2015-08-28admin阅读(1322)赞(0)

ForeachWriterProvider ForeachWriterProvider is…​FIXME

2015-08-27admin阅读(1382)赞(0)

ConsoleSink for Showing DataFrames to Console

2015-08-26admin阅读(1444)赞(0)

ConsoleSinkProvider ConsoleSinkProvider is a DataSourceV2 with StreamWriteSupport for [spark-sql-streaming-Console ...

2015-08-25admin阅读(1453)赞(0)

MemoryStream MemoryStream is a streaming Source that produces values to memory. MemoryStream uses the internal ...

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

MemorySink MemorySink is a streaming Sink that stores records in memory. It is particularly useful for testing. ...

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 ...