org.apache.beam.sdk.io.fileschematransform

Class FileWriteSchemaTransformFormatProviders

java.lang.Object

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

@Internal
public final class FileWriteSchemaTransformFormatProviders
extends java.lang.Object

FileWriteSchemaTransformFormatProviders contains FileWriteSchemaTransformFormatProvider implementations.

The design goals of this class are to enable clean FileWriteSchemaTransformConfiguration.getFormat() lookups that map to the appropriate FileIO.Write that encodes the file data into the configured format.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FileWriteSchemaTransformFormatProviders.Avro A FileWriteSchemaTransformFormatProvider for avro format.
static class	FileWriteSchemaTransformFormatProviders.Csv A FileWriteSchemaTransformFormatProvider for CSV format.
static class	FileWriteSchemaTransformFormatProviders.Json A FileWriteSchemaTransformFormatProvider for JSON format.
static class	FileWriteSchemaTransformFormatProviders.Parquet A FileWriteSchemaTransformFormatProvider for Parquet format.
static class	FileWriteSchemaTransformFormatProviders.Xml A FileWriteSchemaTransformFormatProvider for XML format.

Constructor Summary

Constructors

Constructor and Description
FileWriteSchemaTransformFormatProviders()

Method Summary

Modifier and Type	Method and Description
static java.util.Map<java.lang.String,FileWriteSchemaTransformFormatProvider>	loadProviders() Load all FileWriteSchemaTransformFormatProvider implementations.

Methods inherited from class java.lang.Object

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

Constructor Detail

FileWriteSchemaTransformFormatProviders

public FileWriteSchemaTransformFormatProviders()

Method Detail

loadProviders

public static java.util.Map<java.lang.String,FileWriteSchemaTransformFormatProvider> loadProviders()

Load all FileWriteSchemaTransformFormatProvider implementations.