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