OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
ApexParDoOperator<InputT,OutputT> operator=new ApexParDoOperator<>(context.getPipelineOptions(),doFn,transform.getMainOutputTag(),transform.getAdditionalOutputTags().getAll(),input.getWindowingStrategy(),sideInputs,input.getCoder(),outputCoders,DoFnSchemaInformation.create(),context.getStateBackend());ApexParDoOperator<InputT,OutputT> operator=new ApexParDoOperator<>(context.getPipelineOptions(),doFn,transform.getMainOutputTag(),transform.getAdditionalOutputTags().getAll(),input.getWindowingStrategy(),sideInputs,input.getCoder(),outputCoders,DoFnSchemaInformation.create(),Collections.emptyMap(),context.getStateBackend());new ApexParDoOperator<>(context.getPipelineOptions(),doFn,transform.getMainOutputTag(),transform.getAdditionalOutputTags().getAll(),input.getWindowingStrategy(),sideInputs,input.getCoder(),outputCoders,DoFnSchemaInformation.create(),context.getStateBackend())new ApexParDoOperator<>(context.getPipelineOptions(),doFn,transform.getMainOutputTag(),transform.getAdditionalOutputTags().getAll(),input.getWindowingStrategy(),sideInputs,input.getCoder(),outputCoders,DoFnSchemaInformation.create(),Collections.emptyMap(),context.getStateBackend())beam64262a61402fad67d9ad8a66eaf6322593d3b5dcorg.apache.beam.runners.apex.translation.ParDoTranslator.SplittableProcessElementsTranslator
_1142
_2148
_1sideInputs
_2sideInputs
v6transform.getMainOutputTag()
v7transform.getAdditionalOutputTags().getAll()
v8context.getPipelineOptions()
v9doFn
v10
TCIVarsideInputs
v0DoFnSchemaInformation.create()
v1context.getStateBackend()
v2input.getCoder()
v3outputCoders
v4input.getWindowingStrategy()
  • org.apache.beam.runners.apex.translation.operators.ApexParDoOperator
v6transform.getMainOutputTag()
v7transform.getAdditionalOutputTags().getAll()
v8context.getPipelineOptions()
v9doFn
v10
TCIVarsideInputs
v0DoFnSchemaInformation.create()
v1context.getStateBackend()
v2input.getCoder()
v3outputCoders
v4input.getWindowingStrategy()
UsesTrue