OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
ApexParDoOperator<InputT,OutputT> operator=new ApexParDoOperator<>(context.getPipelineOptions(),doFn,transform.getMainOutputTag(),transform.getAdditionalOutputTags().getAll(),input.getWindowingStrategy(),sideInputs,input.getCoder(),outputCoders,doFnSchemaInformation,context.getStateBackend());ApexParDoOperator<InputT,OutputT> operator=new ApexParDoOperator<>(context.getPipelineOptions(),doFn,transform.getMainOutputTag(),transform.getAdditionalOutputTags().getAll(),input.getWindowingStrategy(),sideInputs,input.getCoder(),outputCoders,doFnSchemaInformation,sideInputMapping,context.getStateBackend());new ApexParDoOperator<>(context.getPipelineOptions(),doFn,transform.getMainOutputTag(),transform.getAdditionalOutputTags().getAll(),input.getWindowingStrategy(),sideInputs,input.getCoder(),outputCoders,doFnSchemaInformation,context.getStateBackend())new ApexParDoOperator<>(context.getPipelineOptions(),doFn,transform.getMainOutputTag(),transform.getAdditionalOutputTags().getAll(),input.getWindowingStrategy(),sideInputs,input.getCoder(),outputCoders,doFnSchemaInformation,sideInputMapping,context.getStateBackend())beam64262a61402fad67d9ad8a66eaf6322593d3b5dcorg.apache.beam.runners.apex.translation.ParDoTranslator
_179
_281
_1sideInputs
_2sideInputs
v6transform.getMainOutputTag()
v7transform.getAdditionalOutputTags().getAll()
v8context.getPipelineOptions()
v9doFn
v10
TCIVarsideInputs
v0doFnSchemaInformation
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
v1context.getStateBackend()
v2input.getCoder()
v3outputCoders
v4input.getWindowingStrategy()
UsesFalse