Package org.apache.beam.sdk.io.fileschematransform

Class FileWriteSchemaTransformConfiguration.ParquetConfiguration

java.lang.Object

org.apache.beam.sdk.io.fileschematransform.FileWriteSchemaTransformConfiguration.ParquetConfiguration

Enclosing class:

FileWriteSchemaTransformConfiguration

@DefaultSchema(AutoValueSchema.class)
public abstract static class FileWriteSchemaTransformConfiguration.ParquetConfiguration
extends Object

Configures extra details related to writing Parquet formatted files.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FileWriteSchemaTransformConfiguration.ParquetConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
ParquetConfiguration()

Method Summary

Modifier and Type	Method	Description
abstract String	getCompressionCodecName()
abstract Integer	getRowGroupSize()

Methods inherited from class java.lang.Object

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

Constructor Details

ParquetConfiguration

public ParquetConfiguration()

Method Details

getCompressionCodecName

@SchemaFieldDescription("Specifies compression codec. Valid values are: \"GZIP\", \"LZO\", \"SNAPPY\", \"UNCOMPRESSED\"")
public abstract String getCompressionCodecName()

getRowGroupSize

@SchemaFieldDescription("Specify row-group size; if not set or zero, a default is used by the underlying writer.")
@Nullable
public abstract Integer getRowGroupSize()