Package org.apache.beam.sdk.io.fileschematransform

Class FileWriteSchemaTransformProvider

java.lang.Object

org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<FileWriteSchemaTransformConfiguration>

org.apache.beam.sdk.io.fileschematransform.FileWriteSchemaTransformProvider

All Implemented Interfaces:

SchemaTransformProvider

@AutoService(SchemaTransformProvider.class)
public class FileWriteSchemaTransformProvider
extends TypedSchemaTransformProvider<FileWriteSchemaTransformConfiguration>

A TypedSchemaTransformProvider implementation for writing a Row PCollection to file systems, driven by a FileWriteSchemaTransformConfiguration.

Field Summary

Fields

Modifier and Type	Field	Description
static final Schema	ERROR_SCHEMA
static final Schema.Field	FILE_NAME_FIELD
static final Schema	OUTPUT_SCHEMA

Constructor Summary

Constructors

Constructor	Description
FileWriteSchemaTransformProvider()

Method Summary

Modifier and Type	Method	Description
protected Class<FileWriteSchemaTransformConfiguration>	configurationClass()	Provides the required TypedSchemaTransformProvider.configurationClass().
protected SchemaTransform	from(FileWriteSchemaTransformConfiguration configuration)	Builds a SchemaTransform from a FileWriteSchemaTransformConfiguration.
String	identifier()	Returns the SchemaTransformProvider.identifier() required for registration.
List<String>	inputCollectionNames()	The expected PCollectionRowTuple input tags.
List<String>	outputCollectionNames()	The expected PCollectionRowTuple output tags.

Methods inherited from class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider

configurationSchema, dependencies, from

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

description

Field Details

FILE_NAME_FIELD

public static final Schema.Field FILE_NAME_FIELD

OUTPUT_SCHEMA

public static final Schema OUTPUT_SCHEMA

ERROR_SCHEMA

public static final Schema ERROR_SCHEMA

Constructor Details

FileWriteSchemaTransformProvider

public FileWriteSchemaTransformProvider()

Method Details

configurationClass

protected Class<FileWriteSchemaTransformConfiguration> configurationClass()

Provides the required TypedSchemaTransformProvider.configurationClass().

Overrides:

configurationClass in class TypedSchemaTransformProvider<FileWriteSchemaTransformConfiguration>

from

protected SchemaTransform from(FileWriteSchemaTransformConfiguration configuration)

Builds a SchemaTransform from a FileWriteSchemaTransformConfiguration.

Specified by:

from in class TypedSchemaTransformProvider<FileWriteSchemaTransformConfiguration>

identifier

public String identifier()

Returns the SchemaTransformProvider.identifier() required for registration.

inputCollectionNames

public List<String> inputCollectionNames()

The expected PCollectionRowTuple input tags.

outputCollectionNames

public List<String> outputCollectionNames()

The expected PCollectionRowTuple output tags.