org.apache.beam.sdk.io.fileschematransform

Class CsvWriteSchemaTransformFormatProvider

java.lang.Object

org.apache.beam.sdk.io.fileschematransform.CsvWriteSchemaTransformFormatProvider

All Implemented Interfaces:

FileWriteSchemaTransformFormatProvider, Providers.Identifyable

@AutoService(value=FileWriteSchemaTransformFormatProvider.class)
public class CsvWriteSchemaTransformFormatProvider
extends java.lang.Object
implements FileWriteSchemaTransformFormatProvider

A FileWriteSchemaTransformFormatProvider for CSV format.

Constructor Summary

Constructors

Constructor and Description
CsvWriteSchemaTransformFormatProvider()

Method Summary

Modifier and Type	Method and Description
PTransform<PCollection<Row>,PCollectionTuple>	buildTransform(FileWriteSchemaTransformConfiguration configuration, Schema schema) Builds a PTransform that writes a Row PCollection and outputs the resulting PCollectionTuple with two tags, one for the file names, and another errored-out rows.
java.lang.String	identifier() Returns an id that uniquely represents this among others implementing its derived interface.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CsvWriteSchemaTransformFormatProvider

public CsvWriteSchemaTransformFormatProvider()

Method Detail

identifier

public java.lang.String identifier()

Description copied from interface: Providers.Identifyable

Returns an id that uniquely represents this among others implementing its derived interface.

Specified by:

identifier in interface Providers.Identifyable

buildTransform

public PTransform<PCollection<Row>,PCollectionTuple> buildTransform(FileWriteSchemaTransformConfiguration configuration,
                                                                    Schema schema)

Description copied from interface: FileWriteSchemaTransformFormatProvider

Builds a PTransform that writes a Row PCollection and outputs the resulting PCollectionTuple with two tags, one for the file names, and another errored-out rows.

Specified by:

buildTransform in interface FileWriteSchemaTransformFormatProvider