Flink MapState有两个方法，clear()和remove(key)。我已经为映射描述符设置了可查询状态，当在一些ProcessFunction中调用remove(key)时，我仍然可以查询一个键，即键还没有从我的映射状态中删除，检查点大小也在不断增加。我需要调用clear()吗，有人能解释一下这两个方法到底是做什么的吗？
浏览 120提问于2021-11-18得票数 0
1回答
Flink广播状态行为
、、、
我试着用一个简单的例子来处理flink的溴化状态。谢谢!).clear() ctx.getBroadcastState(State.m
浏览 0提问于2018-06-25得票数 1
回答已采纳
这一次我的问题是:使用MapState，使用mapstate.put(key, value)将键的当前值修改到mapState中是安全的，或者我需要执行mapState.remove(key)，然后再次执行mapstate.put(key, value)，或者无论如何都要更新此值？从Flink的状态抽象开始，抽象不是为并发访问而设计的，也不应该在多个线程之间共享。那么，重新表述我的问题:我可以根据键将值更新到mapState中，而不需要删除键然后再放入
浏览 43提问于2020-04-16得票数 1
背景Flink是否提供了一个API来限制状态中元素的数量？
使用MapState和StateTtlConfig生成的TTL/过期机制。
浏览 4提问于2022-04-07得票数 1
回答已采纳
我还尝试创建一个最低限度的工作示例来调查这一点：import org.apache.flink.api.common.state.MapStateDescriptor对于使用如下定义的EventTimeTumblingWindows的processWindowFunction，是否有其他原因不能在整个MapState中保留状态：
private MapState<UserDefinedEnumac
浏览 3提问于2020-06-18得票数 0
我同时使用了Clear-Item variable:和Remove-Variable，但是使用后者与使用前者清空内存内容相比，从内存中删除内容的速度有多快？
浏览 0提问于2012-12-09得票数 8
回答已采纳
我使用BroadcastState在Flink中执行流计算。我为我的工作定义了一个扩展KeyedBroadcastProcessFunction的类。我知道我可以在这个类中在processBroadcastElement或processElement中注册一个计时器，这样当超时时，我可以通过调用state.clear()来删除特定密钥组的关联状态。
浏览 0提问于2019-01-08得票数 1
因此，在这种情况下，我们没有使用Flink提供的窗口。我们使用keyed state来存储以前的信息。在ProcessFunction中使用timers来触发旧数据的清理作业。
浏览 4提问于2018-03-15得票数 4
假设Kafka消息包含flink窗口大小配置。问题陈述：
我们能使用BroadcastStream来处理上述场景吗？
浏览 0提问于2020-01-20得票数 1
我有一个flink应用程序(flink版本是1.9.2)，它启用了检查点功能。当我在apache平台上运行时。connection; private String getCusipListQuery; private MapState<String, List&l
浏览 3提问于2020-07-03得票数 3
回答已采纳
1回答
(dog) dogs.remove(dog)
dogs_list = list(cats_vs_dogs[dog])(cat) <e
浏览 0提问于2013-01-09得票数 1
回答已采纳
{ListState, ListStateDescriptor}import org.apache.flink.runtime.state.filesystem.FsStateBackendimport org.apache.flink.runtime.state.org.apache.flink.streaming.api.functions.source.SourceFunction
import org.apache.flink</em
浏览 20提问于2019-09-26得票数 0
回答已采纳
我使用MapState来保存前一个会话，但不知何故，mapstate从未包含任何以前的键，所以每个会话都是新的。StateTtlConfig ttlConfig = StateTtlConfig
previous_user_ses
浏览 17提问于2020-04-15得票数 1
schemas.microsoft.com/fakes/2011/"> <StubGeneration> <Remove FullName="System.Diagnostics.Tracing!"/>
<Remove</e
浏览 0提问于2017-02-08得票数 0
1回答
根据列单元格值清除特定行
、、、
以下是我目前在网站上的代码： var depositid = SpreadsheetApp.getActiveSpreadsheet();var DELETE_VAL = "Yes"; // Keyword to remove the row
var COL_TO_SEARCH = 11; // Column L = 11
浏览 2提问于2020-06-13得票数 0
回答已采纳
我已经尝试使用vue路由器链路，并使用用于路由器链路的class-active属性手动设置类 <vs-sidebar-item to="/dashboard" index="1" icon="menu"> </vs-sidebar-item>
<vs-sidebar-item to="/orders" index=
浏览 17提问于2019-02-15得票数 0
NDC.clear() NDC.remove()
谢谢你的帮助。
浏览 0提问于2019-01-29得票数 2
回答已采纳
这个例子一开始非常有用，它说明了keyedProcessFunction是如何在Flink工作的它来自Fraud检测器v2: State + Time部件，对于实际的应用需求部分，在这里设置一个定时器是合理的KeyedProcessFunction[Long, Transaction, Alert]#OnTimerContext, // removeflag after 1 minute flagS
浏览 3提问于2020-05-26得票数 0
我在flink中有一个应用程序，它可以消除多个流的重复。它对一个字符串字段执行键操作，并使用值状态对其进行还原。state.backend.incremental: true
我们使用的是Flink
浏览 5提问于2022-05-16得票数 0
supports element removal, which removes the corresponding * <tt>Collection.remove</tt>, <tt>removeAll</tt>,
* <tt>retainAll</tt> and <tt>clear<
浏览 1提问于2012-09-28得票数 0
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号