spark技术分享

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

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

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

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

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

ForeachWriterProvider ForeachWriterProvider is…​FIXME

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

ConsoleSink for Showing DataFrames to Console

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

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

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

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

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

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

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

MemorySinkV2 MemorySinkV2 is…​FIXME

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

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

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

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