赞
踩
创建累加器
private IntCounter numLines = new IntCounter();
在open()方法中注册累加器,然后后定义累加器的名称
getRuntimeContext().addAccumulator("myCounter",this.numLines);
使用累加器
this.numLines.add(1);
获取累加器的结果
将结果存储在JobExecutionResult对象中,该对象是从执行环境的execute()方法返回的(仅在作业执行完成时起作用)
myJobExecutionResult.getAccumulatorResult("myCounter");
Flink会在内部合并所有具有相同名称的累加器
自定义累加器可以通过继承Accumulator或SimpleAccumulator来实现
赞
踩
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。