structured-streaming 第2页

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

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

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

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

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

Demo: Using StreamingQueryManager for Query Termination Management

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

Demo: current_timestamp Function For Processing Time in Streaming Queries

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

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

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

Demo: groupBy Streaming Aggregation with Append Output Mode

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

Demo: StateStoreSaveExec with Update Output Mode

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

Demo: StateStoreSaveExec with Complete Output Mode

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

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

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

Streaming Sink — Adding Batches of Data to Storage