structured-streaming 第2页

2015-11-21admin阅读(1619)赞(0)

EventTimeStatsAccum Accumulator EventTimeStatsAccum is a Spark accumulator of EventTimeStats from Longs (i.e. Accu ...

2015-11-20admin阅读(1918)赞(0)

UnsupportedOperationChecker UnsupportedOperationChecker checks whether the logical plan of a streaming query uses ...

2015-11-19admin阅读(1088)赞(0)

Demo: Using StreamingQueryManager for Query Termination Management

2015-11-18admin阅读(1122)赞(0)

Demo: current_timestamp Function For Processing Time in Streaming Queries

2015-11-17admin阅读(2087)赞(0)

Demo: Developing Custom Streaming Sink (and Monitoring SQL Queries in web UI)

2015-11-16admin阅读(4238)赞(0)

Demo: groupBy Streaming Aggregation with Append Output Mode

2015-11-15admin阅读(1474)赞(0)

Demo: StateStoreSaveExec with Update Output Mode

2015-11-14admin阅读(1258)赞(0)

Demo: StateStoreSaveExec with Complete Output Mode

2015-11-13admin阅读(4037)赞(0)

StreamSinkProvider StreamSinkProvider is the contract for creating streaming sinks for a specific format or system ...

2015-11-12admin阅读(1442)赞(0)

Streaming Sink — Adding Batches of Data to Storage