
StreamingAggregationStateManagerBaseImpl — Base State Manager for Streaming Aggregation
StreamingAggregationStateManagerBaseImpl — Base State Manager for Streaming Aggregation
spark技术分享
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
一周热门排行