public class ParquetFormatConfiguration extends Object
Constructor and Description |
---|
ParquetFormatConfiguration() |
Modifier and Type | Method and Description |
---|---|
ParquetFormatConfiguration |
clear()
Clears all properties.
|
Integer |
getBlockSize()
Returns the block size (in bytes).
|
parquet.hadoop.metadata.CompressionCodecName |
getCompressionCodecName()
Returns the compression codec name.
|
Integer |
getDataPageSize()
Returns the data page size (in bytes).
|
Integer |
getDictionaryPageSize()
Returns the dictionary page size (in bytes).
|
Boolean |
getEnableDictionary()
Returns whether the dictionary is enabled or not.
|
Boolean |
getEnableValidation()
Returns whether the schema validation is enabled or not.
|
DataModelMapping.FieldMappingStrategy |
getFieldMappingStrategy()
Returns the field mapping strategy.
|
DataModelMapping.ExceptionHandlingStrategy |
getOnIncompatibleType()
Returns the exception handling strategy for incompatible field type.
|
DataModelMapping.ExceptionHandlingStrategy |
getOnMissingSource()
Returns the exception handling strategy for missing source fields.
|
DataModelMapping.ExceptionHandlingStrategy |
getOnMissingTarget()
Returns the exception handling strategy for missing target fields.
|
parquet.column.ParquetProperties.WriterVersion |
getWriterVersion()
Returns the writer version.
|
String |
toString() |
ParquetFormatConfiguration |
withBlockSize(Integer value)
Sets the block size (in bytes).
|
ParquetFormatConfiguration |
withCompressionCodecName(parquet.hadoop.metadata.CompressionCodecName value)
Sets the compression codec name.
|
ParquetFormatConfiguration |
withDataPageSize(Integer value)
Sets the data page size (in bytes).
|
ParquetFormatConfiguration |
withDictionaryPageSize(Integer value)
Sets the dictionary page size (in bytes).
|
ParquetFormatConfiguration |
withEnableDictionary(Boolean value)
Sets whether the dictionary is enabled or not.
|
ParquetFormatConfiguration |
withEnableValidation(Boolean value)
Sets whether the schema validation is enabled or not.
|
ParquetFormatConfiguration |
withFieldMappingStrategy(DataModelMapping.FieldMappingStrategy value)
Sets the field mapping strategy.
|
ParquetFormatConfiguration |
withOnIncompatibleType(DataModelMapping.ExceptionHandlingStrategy value)
Sets the exception handling strategy for incompatible field type.
|
ParquetFormatConfiguration |
withOnMissingSource(DataModelMapping.ExceptionHandlingStrategy value)
Sets the exception handling strategy for missing source fields.
|
ParquetFormatConfiguration |
withOnMissingTarget(DataModelMapping.ExceptionHandlingStrategy value)
Sets the exception handling strategy for missing target fields.
|
ParquetFormatConfiguration |
withWriterVersion(parquet.column.ParquetProperties.WriterVersion value)
Sets the writer version.
|
public ParquetFormatConfiguration clear()
public ParquetFormatConfiguration withFieldMappingStrategy(DataModelMapping.FieldMappingStrategy value)
value
- the strategypublic ParquetFormatConfiguration withOnMissingSource(DataModelMapping.ExceptionHandlingStrategy value)
value
- the strategypublic ParquetFormatConfiguration withOnMissingTarget(DataModelMapping.ExceptionHandlingStrategy value)
value
- the strategypublic ParquetFormatConfiguration withOnIncompatibleType(DataModelMapping.ExceptionHandlingStrategy value)
value
- the strategypublic ParquetFormatConfiguration withCompressionCodecName(parquet.hadoop.metadata.CompressionCodecName value)
value
- the valuepublic ParquetFormatConfiguration withBlockSize(Integer value)
value
- the valuepublic ParquetFormatConfiguration withDataPageSize(Integer value)
value
- the valuepublic ParquetFormatConfiguration withDictionaryPageSize(Integer value)
value
- the valuepublic ParquetFormatConfiguration withEnableDictionary(Boolean value)
value
- the valuepublic ParquetFormatConfiguration withEnableValidation(Boolean value)
value
- the valuepublic ParquetFormatConfiguration withWriterVersion(parquet.column.ParquetProperties.WriterVersion value)
value
- the valuepublic DataModelMapping.FieldMappingStrategy getFieldMappingStrategy()
public DataModelMapping.ExceptionHandlingStrategy getOnMissingSource()
public DataModelMapping.ExceptionHandlingStrategy getOnMissingTarget()
public DataModelMapping.ExceptionHandlingStrategy getOnIncompatibleType()
public parquet.hadoop.metadata.CompressionCodecName getCompressionCodecName()
public Integer getBlockSize()
public Integer getDataPageSize()
public Integer getDictionaryPageSize()
public Boolean getEnableDictionary()
true
if enabled, otherwise false
public Boolean getEnableValidation()
true
if enabled, otherwise false
public parquet.column.ParquetProperties.WriterVersion getWriterVersion()
null
Copyright © 2011–2018 Asakusa Framework Team. All rights reserved.