flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/BroadcastStateTransformationTranslator.java [46:59]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        draftTransformation.getUserFunction(),
                        draftTransformation.getBroadcastStateDescriptors());
        TwoInputTransformation<?, ?, ?> actualTransformation =
                new TwoInputTransformation(
                        context.getActualTransformation(
                                draftTransformation.getRegularInput().getId()),
                        context.getActualTransformation(
                                draftTransformation.getBroadcastInput().getId()),
                        draftTransformation.getName(),
                        new WrapperOperatorFactory(
                                SimpleOperatorFactory.of(operator), operatorWrapper),
                        operatorWrapper.getWrappedTypeInfo(
                                (TypeInformation) draftTransformation.getOutputType()),
                        draftTransformation.getParallelism());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/KeyedBroadcastStateTransformationTranslator.java [47:60]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        draftTransformation.getUserFunction(),
                        draftTransformation.getBroadcastStateDescriptors());
        TwoInputTransformation<?, ?, ?> actualTransformation =
                new TwoInputTransformation(
                        context.getActualTransformation(
                                draftTransformation.getRegularInput().getId()),
                        context.getActualTransformation(
                                draftTransformation.getBroadcastInput().getId()),
                        draftTransformation.getName(),
                        new WrapperOperatorFactory(
                                SimpleOperatorFactory.of(operator), operatorWrapper),
                        operatorWrapper.getWrappedTypeInfo(
                                (TypeInformation) draftTransformation.getOutputType()),
                        draftTransformation.getParallelism());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -