StatefulOperator Contract — Physical Operators That Read or Write to StateStore
StatefulOperator Contract — Physical Operators That Read or Write to StateStore
StatefulOperator Contract — Physical Operators That Read or Write to StateStore
StreamingAggregationStateManagerImplV2 — Default State Manager for Streaming Aggregation
StreamingAggregationStateManagerImplV1 — Legacy 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 ...