关注 spark技术分享，
撸spark源码 玩spark最佳实践
当前位置：spark技术分享 > structured-streaming > 正文

StreamingAggregationStateManagerImplV1 — Legacy State Manager for Streaming Aggregation

2015-10-20 分类：structured-streaming 阅读(1245) 评论(0)

StreamingAggregationStateManagerImplV1 — Legacy State Manager for Streaming Aggregation

StreamingAggregationStateManagerImplV1 is the legacy state manager for streaming aggregations.

Note
 The version of a state manager is controlled using spark.sql.streaming.aggregation.stateFormatVersion internal configuration property.

StreamingAggregationStateManagerImplV1 is created exclusively when StreamingAggregationStateManager is requested for a new StreamingAggregationStateManager.

Storing Row in State Store — put Method

Note
 put is part of the StreamingAggregationStateManager Contract to store a row in a state store.

put…​FIXME

Creating StreamingAggregationStateManagerImplV1 Instance

StreamingAggregationStateManagerImplV1 takes the following when created:

  • Attribute expressions for keys (Seq[Attribute])

  • Attribute expressions of input rows (Seq[Attribute])

赞(0) 打赏
未经允许不得转载：spark技术分享 » StreamingAggregationStateManagerImplV1 — Legacy State Manager for Streaming Aggregation
分享到： 更多 (0)
标签：

相关推荐

吐血推荐

欢迎关注：spark技术分享

热门标签

spark-sql (562)spark-core (421)structured-streaming (152)原理剖析 (28)spark-streaming (11)kafka (6)最佳实践 (6)Delta (6)hbase (5)入门教程 (5)面试 (3)源码剖析 (3)flink (3)spark优化 (2)优化 (2)spark-checkpoint (2)shuffle过程 (2)DStream (2)HFile (2)基本概念 (2)技术选型 (2)AQE (2)机器学习 (1)elasticsearch (1)catalyst框架 (1)优化策略 (1)干货 (1)大会资料 (1)spark应用实践 (1)机器学习原理 (1)

近期文章

分类目录

关注公众号：spark技术分享

联系我们联系我们

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏