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()) | beam | 64262a61402fad67d9ad8a66eaf6322593d3b5dc | org.apache.beam.runners.apex.translation.ParDoTranslator.SplittableProcessElementsTranslator | | | v6 | transform.getMainOutputTag() |
---|
v7 | transform.getAdditionalOutputTags().getAll() |
---|
v8 | context.getPipelineOptions() |
---|
v9 | doFn |
---|
v10 | |
---|
TCIVar | sideInputs |
---|
v0 | DoFnSchemaInformation.create() |
---|
v1 | context.getStateBackend() |
---|
v2 | input.getCoder() |
---|
v3 | outputCoders |
---|
v4 | input.getWindowingStrategy() |
---|
| - org.apache.beam.runners.apex.translation.operators.ApexParDoOperator
| v6 | transform.getMainOutputTag() |
---|
v7 | transform.getAdditionalOutputTags().getAll() |
---|
v8 | context.getPipelineOptions() |
---|
v9 | doFn |
---|
v10 | |
---|
TCIVar | sideInputs |
---|
v0 | DoFnSchemaInformation.create() |
---|
v1 | context.getStateBackend() |
---|
v2 | input.getCoder() |
---|
v3 | outputCoders |
---|
v4 | input.getWindowingStrategy() |
---|
| Uses | True |