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

Class SqlTransformSchemaTransformProvider

java.lang.Object

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

All Implemented Interfaces:

SchemaTransformProvider

@AutoService(SchemaTransformProvider.class)
public class SqlTransformSchemaTransformProvider
extends Object
implements SchemaTransformProvider

Constructor Summary

Constructors

Constructor	Description
SqlTransformSchemaTransformProvider()

Method Summary

Modifier and Type	Method	Description
Schema	configurationSchema()	Returns the expected schema of the configuration object.
String	description()	Returns a description regarding the SchemaTransform represented by the SchemaTransformProvider.
SchemaTransform	from(Row configuration)	Produce a SchemaTransform from some transform-specific configuration object.
String	identifier()	Returns an id that uniquely represents this transform.
List<String>	inputCollectionNames()	Returns the input collection names of this transform.
List<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 Details

SqlTransformSchemaTransformProvider

public SqlTransformSchemaTransformProvider()

Method Details

identifier

public String identifier()

Description copied from interface: SchemaTransformProvider

Returns an id that uniquely represents this transform.

Specified by:

identifier in interface SchemaTransformProvider

description

public String description()

Description copied from interface: SchemaTransformProvider

Returns a description regarding the SchemaTransform represented by the SchemaTransformProvider. Please keep the language generic (i.e. not specific to any programming language). The description may be markdown formatted.

Specified by:

description 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 from some transform-specific configuration object. Can throw a

invalid reference

InvalidConfigurationException

or a

invalid reference

InvalidSchemaException

.

Specified by:

from in interface SchemaTransformProvider

inputCollectionNames

public List<String> inputCollectionNames()

Description copied from interface: SchemaTransformProvider

Returns the input collection names of this transform.

Specified by:

inputCollectionNames in interface SchemaTransformProvider

outputCollectionNames

public List<String> outputCollectionNames()

Description copied from interface: SchemaTransformProvider

Returns the output collection names of this transform.

Specified by:

outputCollectionNames in interface SchemaTransformProvider