@AutoService(value=FileWriteSchemaTransformFormatProvider.class) public class ParquetWriteSchemaTransformFormatProvider extends java.lang.Object implements FileWriteSchemaTransformFormatProvider
FileWriteSchemaTransformFormatProvider
for Parquet format.Constructor and Description |
---|
ParquetWriteSchemaTransformFormatProvider() |
Modifier and Type | Method and Description |
---|---|
PTransform<PCollection<Row>,PCollection<java.lang.String>> |
buildTransform(FileWriteSchemaTransformConfiguration configuration,
Schema schema)
Builds a
PTransform that transforms a Row PCollection into result
PCollection file names written using ParquetIO.Sink and FileIO.Write . |
java.lang.String |
identifier()
Returns an id that uniquely represents this among others implementing its derived interface.
|
public ParquetWriteSchemaTransformFormatProvider()
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)
PTransform
that transforms a Row
PCollection
into result
PCollection
file names written using ParquetIO.Sink
and FileIO.Write
.buildTransform
in interface FileWriteSchemaTransformFormatProvider