org.apache.beam.sdk.io.fileschematransform

Class FileWriteSchemaTransformConfiguration.ParquetConfiguration

java.lang.Object

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

Enclosing class:

FileWriteSchemaTransformConfiguration

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class FileWriteSchemaTransformConfiguration.ParquetConfiguration
extends java.lang.Object

Configures extra details related to writing Parquet formatted files.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
ParquetConfiguration()

Method Summary

Modifier and Type	Method and Description
abstract java.lang.String	getCompressionCodecName() Specifies compression codec.
abstract java.lang.Integer	getRowGroupSize() Specify row-group size; if not set or zero, a default is used by the underlying writer.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetConfiguration

public ParquetConfiguration()

Method Detail

getCompressionCodecName

public abstract java.lang.String getCompressionCodecName()

Specifies compression codec. See org.apache.parquet.hadoop.metadata.CompressionCodecName for allowed names.

getRowGroupSize

@Nullable
public abstract java.lang.Integer getRowGroupSize()

Specify row-group size; if not set or zero, a default is used by the underlying writer.