structured-streaming 第5页

2015-10-22admin阅读(1443)赞(0)

StatefulOperator Contract — Physical Operators That Read or Write to StateStore

2015-10-21admin阅读(1631)赞(0)

StreamingAggregationStateManagerImplV2 — Default State Manager for Streaming Aggregation

2015-10-20admin阅读(1663)赞(0)

StreamingAggregationStateManagerImplV1 — Legacy State Manager for Streaming Aggregation

2015-10-19admin阅读(1589)赞(0)

StreamingAggregationStateManagerBaseImpl — Base State Manager for Streaming Aggregation

2015-10-18admin阅读(1607)赞(0)

StreamingAggregationStateManager Contract — State Managers for Streaming Aggregation

2015-10-17admin阅读(1672)赞(0)

StateStoreCoordinatorRef — RPC Endpoint Reference to StateStoreCoordinator

2015-10-16admin阅读(1671)赞(0)

StateStoreCoordinator — Tracking Locations of StateStores for StateStoreRDD

2015-10-15admin阅读(1565)赞(0)

StateStoreRDD — RDD for Updating State (in StateStores Across Spark Cluster)

2015-10-14admin阅读(1609)赞(0)

StateStoreCustomMetric Contract StateStoreCustomMetric is the abstraction of metrics that a state store may wish t ...

2015-10-13admin阅读(1625)赞(0)

StateStoreMetrics StateStoreMetrics holds the metrics of a state store: Number of keys Memory used (in byt ...