org.apache.beam.sdk.extensions.sql.expansion

Class SqlTransformSchemaTransformProvider

java.lang.Object

org.apache.beam.sdk.extensions.sql.expansion.SqlTransformSchemaTransformProvider

All Implemented Interfaces:

SchemaTransformProvider

@Experimental
 @AutoService(value=SchemaTransformProvider.class)
public class SqlTransformSchemaTransformProvider
extends java.lang.Object
implements SchemaTransformProvider

Constructor Summary

Constructors

Constructor and Description
SqlTransformSchemaTransformProvider()

Method Summary

Modifier and Type	Method and Description
Schema	configurationSchema() Returns the expected schema of the configuration object.
SchemaTransform	from(Row configuration) Produce a SchemaTransform some transform-specific configuration object.
java.lang.String	identifier() Returns an id that uniquely represents this transform.
java.util.List<java.lang.String>	inputCollectionNames() Returns the input collection names of this transform.
java.util.List<java.lang.String>	outputCollectionNames() Returns the output collection names of this transform.

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.schemas.transforms.SchemaTransformProvider

dependencies

Constructor Detail

SqlTransformSchemaTransformProvider

public SqlTransformSchemaTransformProvider()

Method Detail

identifier

public java.lang.String identifier()

Description copied from interface: SchemaTransformProvider

Returns an id that uniquely represents this transform.

Specified by:

identifier in interface SchemaTransformProvider

configurationSchema

public Schema configurationSchema()

Description copied from interface: SchemaTransformProvider

Returns the expected schema of the configuration object. Note this is distinct from the schema of the transform itself.

Specified by:

configurationSchema in interface SchemaTransformProvider

from

public SchemaTransform from(Row configuration)

Description copied from interface: SchemaTransformProvider

Produce a SchemaTransform some transform-specific configuration object. Can throw a InvalidConfigurationException or a InvalidSchemaException.

Specified by:

from in interface SchemaTransformProvider

inputCollectionNames

public java.util.List<java.lang.String> inputCollectionNames()

Description copied from interface: SchemaTransformProvider

Returns the input collection names of this transform.

Specified by:

inputCollectionNames in interface SchemaTransformProvider

outputCollectionNames

public java.util.List<java.lang.String> outputCollectionNames()

Description copied from interface: SchemaTransformProvider

Returns the output collection names of this transform.

Specified by:

outputCollectionNames in interface SchemaTransformProvider