保存中间变量可以用状态存 李继 <liji12...@gmail.com> 于2021年1月7日周四 下午5:42写道:
> HI , 请问当一个算子会被多次使用时,怎么把他缓存住,类似于spark的cache操作 > > val env = getBatchEnv > val ds = env.fromElements("a","b","c") > > val ds2 = ds.map(x=>{ > println("map op") > x.charAt(0).toInt+1 > }) > > //此操作会打印三遍map op > ds2.print() > > //此操作又会打印三遍map op > ds2.filter(_>100).print() >