| 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 |