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).
|
String |
getCompressionCodecName()
Returns the compression codec name.
|
<T extends Enum<T>> |
getCompressionCodecName(Class<T> type)
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.
|
String |
getWriterVersion()
Returns the writer version.
|
<T extends Enum<T>> |
getWriterVersion(Class<T> type)
Returns the writer version.
|
String |
toString() |
ParquetFormatConfiguration |
withBlockSize(Integer value)
Sets the block size (in bytes).
|
ParquetFormatConfiguration |
withCompressionCodecName(String 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(String 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(String 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(String value)
value - the valuepublic DataModelMapping.FieldMappingStrategy getFieldMappingStrategy()
public DataModelMapping.ExceptionHandlingStrategy getOnMissingSource()
public DataModelMapping.ExceptionHandlingStrategy getOnMissingTarget()
public DataModelMapping.ExceptionHandlingStrategy getOnIncompatibleType()
public String getCompressionCodecName()
public <T extends Enum<T>> T getCompressionCodecName(Class<T> type)
T - the typetype - the typepublic Integer getBlockSize()
public Integer getDataPageSize()
public Integer getDictionaryPageSize()
public Boolean getEnableDictionary()
true if enabled, otherwise falsepublic Boolean getEnableValidation()
true if enabled, otherwise falsepublic String getWriterVersion()
nullpublic <T extends Enum<T>> T getWriterVersion(Class<T> type)
T - the typetype - the typenullCopyright © 2011–2019 Asakusa Framework Team. All rights reserved.