structured-streaming 第5页

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

StatefulOperator Contract — Physical Operators That Read or Write to StateStore

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

StreamingAggregationStateManagerImplV2 — Default State Manager for Streaming Aggregation

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

StreamingAggregationStateManagerImplV1 — Legacy State Manager for Streaming Aggregation

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

StreamingAggregationStateManagerBaseImpl — Base State Manager for Streaming Aggregation

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

StreamingAggregationStateManager Contract — State Managers for Streaming Aggregation

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

StateStoreCoordinatorRef — RPC Endpoint Reference to StateStoreCoordinator

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

StateStoreCoordinator — Tracking Locations of StateStores for StateStoreRDD

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

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

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

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

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

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