org.apache.beam.sdk.io.fileschematransform

Class FileWriteSchemaTransformFormatProviders.Parquet

java.lang.Object

org.apache.beam.sdk.io.fileschematransform.FileWriteSchemaTransformFormatProviders.Parquet

All Implemented Interfaces:

FileWriteSchemaTransformFormatProvider, Providers.Identifyable

Enclosing class:

FileWriteSchemaTransformFormatProviders

@AutoService(value=FileWriteSchemaTransformFormatProvider.class)
public static class FileWriteSchemaTransformFormatProviders.Parquet
extends java.lang.Object
implements FileWriteSchemaTransformFormatProvider

A FileWriteSchemaTransformFormatProvider for Parquet format.

Constructor Summary

Constructors

Constructor and Description
Parquet()

Method Summary

Modifier and Type	Method and Description
PTransform<PCollection<?>,PDone>	buildTransform() Builds a PTransform that consumes PCollection.
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

Parquet

public Parquet()

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<?>,PDone> buildTransform()

Description copied from interface: FileWriteSchemaTransformFormatProvider

Builds a PTransform that consumes PCollection.

Specified by:

buildTransform in interface FileWriteSchemaTransformFormatProvider