@AutoService(value=FileWriteSchemaTransformFormatProvider.class) public class CsvWriteSchemaTransformFormatProvider extends java.lang.Object implements FileWriteSchemaTransformFormatProvider
FileWriteSchemaTransformFormatProvider
for CSV format.Constructor and Description |
---|
CsvWriteSchemaTransformFormatProvider() |
Modifier and Type | Method and Description |
---|---|
PTransform<PCollection<Row>,PCollection<java.lang.String>> |
buildTransform(FileWriteSchemaTransformConfiguration configuration,
Schema schema)
Builds a
PTransform that writes a Row PCollection and outputs the
resulting PCollection of the file names. |
java.lang.String |
identifier()
Returns an id that uniquely represents this among others implementing its derived interface.
|
public CsvWriteSchemaTransformFormatProvider()
public java.lang.String identifier()
Providers.Identifyable
identifier
in interface Providers.Identifyable
public PTransform<PCollection<Row>,PCollection<java.lang.String>> buildTransform(FileWriteSchemaTransformConfiguration configuration, Schema schema)
FileWriteSchemaTransformFormatProvider
PTransform
that writes a Row
PCollection
and outputs the
resulting PCollection
of the file names.buildTransform
in interface FileWriteSchemaTransformFormatProvider