ExpansionServiceSchemaTransformProvider (Apache Beam 2.68.0)

java.lang.Object

org.apache.beam.sdk.expansion.service.ExpansionServiceSchemaTransformProvider

All Implemented Interfaces:: TransformProvider<PCollectionRowTuple,PCollectionRowTuple>

public class ExpansionServiceSchemaTransformProvider extends Object implements TransformProvider<PCollectionRowTuple,PCollectionRowTuple>

Method Summary

Modifier and Type

Method

Description

PCollectionRowTuple

createInput(Pipeline p, Map<String,PCollection<?>> inputs)

Map<String,PCollection<?>>

extractOutputs(PCollectionRowTuple output)

PTransform

getTransform(org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec spec, PipelineOptions options)

static ExpansionServiceSchemaTransformProvider

of()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.sdk.expansion.service.TransformProvider
apply, getDependencies, getTransformUniqueID

Method Details
- of
  
  public static ExpansionServiceSchemaTransformProvider of()
- createInput
  
  public PCollectionRowTuple createInput(Pipeline p, Map<String,PCollection<?>> inputs)
  
  Specified by:
  
  createInput in interface TransformProvider<PCollectionRowTuple,PCollectionRowTuple>
- extractOutputs
  
  public Map<String,PCollection<?>> extractOutputs(PCollectionRowTuple output)
  
  Specified by:
  
  extractOutputs in interface TransformProvider<PCollectionRowTuple,PCollectionRowTuple>
- getTransform
  
  public PTransform getTransform(org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec spec, PipelineOptions options)
  
  Specified by:
  
  getTransform in interface TransformProvider<PCollectionRowTuple,PCollectionRowTuple>