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 false
public Boolean getEnableValidation()
true
if enabled, otherwise false
public String getWriterVersion()
null
public <T extends Enum<T>> T getWriterVersion(Class<T> type)
T
- the typetype
- the typenull
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.