通过算子的构造方法传递变量失效
hi all: 我定义了1个flatMap,通过构造方法传递了1个int类型的变量, 我在最外层定义了2条流,流定义的时候.flatMap(int)传入了这个变量, 目前有2个不同的flatmap,构造方法传入的这个int变量为2个不同的值, 当有数据流过这2个算子的时候,发现该int变量并没有发生变化,请如何给算子传递变量。 freeza1...@outlook.com
Re:通过算子的构造方法传递变量失效
hi,可以把部分代码贴出来看一下吗? 在 2020-10-28 17:29:58,"freeza1...@outlook.com" 写道: >hi all: >我定义了1个flatMap,通过构造方法传递了1个int类型的变量, 我在最外层定义了2条流,流定义的时候.flatMap(int)传入了这个变量, > 目前有2个不同的flatmap,构造方法传入的这个int变量为2个不同的值, >当有数据流过这2个算子的时候,发现该int变量并没有发生变化,请如何给算子传递变量。 > > > >freeza1...@outlook.com