草庐IT

CopyingChainingOutput

全部标签

一文搞懂 Flink OperatorChain 对象重用

OperatorChain的对象重用,可以提高效率,但什么情况下可以重用,什么情况下不可以重用,我们一起来看你一下代码:首先,在OperatorChain类的createChainedOperator方法privateWatermarkGaugeExposingOutput>createChainedOperator(StreamTaskcontainingTask,StreamConfigoperatorConfig,MapchainedConfigs,ClassLoaderuserCodeClassloader,Map>streamOutputs,List>allOperators,Out

一文搞懂 Flink OperatorChain 对象重用

OperatorChain的对象重用,可以提高效率,但什么情况下可以重用,什么情况下不可以重用,我们一起来看你一下代码:首先,在OperatorChain类的createChainedOperator方法privateWatermarkGaugeExposingOutput>createChainedOperator(StreamTaskcontainingTask,StreamConfigoperatorConfig,MapchainedConfigs,ClassLoaderuserCodeClassloader,Map>streamOutputs,List>allOperators,Out