StreamingAggregationStateManagerBaseImpl — Base State Manager for Streaming Aggregation
StreamingAggregationStateManagerBaseImpl — Base State Manager for Streaming Aggregation
StreamingAggregationStateManagerBaseImpl — Base State Manager for Streaming Aggregation
StreamingAggregationStateManager Contract — State Managers for Streaming Aggregation
StateStoreCoordinatorRef — RPC Endpoint Reference to StateStoreCoordinator
StateStoreCoordinator — Tracking Locations of StateStores for StateStoreRDD
StateStoreRDD — RDD for Updating State (in StateStores Across Spark Cluster)
StateStoreCustomMetric Contract StateStoreCustomMetric is the abstraction of metrics that a state store may wish t ...
StateStoreMetrics StateStoreMetrics holds the metrics of a state store: Number of keys Memory used (in byt ...
HDFSBackedStateStoreProvider — Default StateStoreProvider
StateStoreProvider Contract StateStoreProvider is the abstraction of state store providers that manage StateStores ...
MemoryStateStore MemoryStateStore is…FIXME
一周热门排行