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()
abstract java.lang.Integer	getRowGroupSize()

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

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

getRowGroupSize

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