public class ParquetFileDriver extends ModelAttributeDriver
@directio.hive.parquet attributes.
table_name=[string-literal] as explicit table name (default: data model name) format_version=[string-literal] as parquet format version (default: system default) compression=[string-literal] as compression kind name (default: "snappy") block_size=integer as block size (default: system default) block_size=integer as block size (default: system default) data_page_size=integer as data page size(default: system default) dictionary_page_size=integer as dictionary page size (default: system default) enable_dictionary=boolean as dictionary on/off (default: system default) enable_validation=boolean as validation on/off (default: system default) field_mappping=[string-literal] (default: "position") missing_source=[string-literal] (default: "logging") missing_target=[string-literal] (default: "logging") incompatible_type=[string-literal] (default: "fail") AttributeDriver.Context| Modifier and Type | Field and Description |
|---|---|
static String |
ELEMENT_BLOCK_SIZE
The element name of block size.
|
static String |
ELEMENT_COMPRESSION
The element name of compression codec name.
|
static String |
ELEMENT_DATA_PAGE_SIZE
The element name of data page size.
|
static String |
ELEMENT_DICTIONARY_PAGE_SIZE
The element name of dictionary page size.
|
static String |
ELEMENT_ENABLE_DICTIONARY
The element name of dictionary enabled.
|
static String |
ELEMENT_ENABLE_VALIDATION
The element name of validation enabled.
|
static String |
ELEMENT_FIELD_MAPPING
The element name of field mapping strategy.
|
static String |
ELEMENT_FORMAT_VERSION
The element name of parquet format version.
|
static String |
ELEMENT_INCOMPATIBLE_TYPE
The element name of missing incompatible type handling strategy.
|
static String |
ELEMENT_MISSING_SOURCE
The element name of missing source handling strategy.
|
static String |
ELEMENT_MISSING_TARGET
The element name of missing target handling strategy.
|
static String |
ELEMENT_TABLE_NAME
The element name of explicit table name.
|
static String |
TARGET_NAME
The attribute name.
|
| Constructor and Description |
|---|
ParquetFileDriver() |
| Modifier and Type | Method and Description |
|---|---|
String |
getTargetName()
Returns the qualified name of the target attribute.
|
void |
process(DmdlSemantics environment,
ModelDeclaration declaration,
AstAttribute attribute)
Processes and modifies the attributed data model declaration.
|
void |
verify(DmdlSemantics environment,
ModelDeclaration declaration,
AstAttribute attribute)
Verifies the attributed declaration.
|
process, verifypublic static final String TARGET_NAME
public static final String ELEMENT_TABLE_NAME
public static final String ELEMENT_FORMAT_VERSION
public static final String ELEMENT_COMPRESSION
public static final String ELEMENT_BLOCK_SIZE
public static final String ELEMENT_DATA_PAGE_SIZE
public static final String ELEMENT_DICTIONARY_PAGE_SIZE
public static final String ELEMENT_ENABLE_DICTIONARY
public static final String ELEMENT_ENABLE_VALIDATION
public static final String ELEMENT_FIELD_MAPPING
public static final String ELEMENT_MISSING_SOURCE
public static final String ELEMENT_MISSING_TARGET
public static final String ELEMENT_INCOMPATIBLE_TYPE
public String getTargetName()
AttributeDriverpublic void process(DmdlSemantics environment, ModelDeclaration declaration, AstAttribute attribute)
ModelAttributeDriverprocess in class ModelAttributeDriverenvironment - the processing environmentdeclaration - the model declaration with the attributeattribute - the attribute with the target nameAttributeDriver.getTargetName()public void verify(DmdlSemantics environment, ModelDeclaration declaration, AstAttribute attribute)
ModelAttributeDriverprocessed.verify in class ModelAttributeDriverenvironment - the processing environmentdeclaration - the model declaration with the attributeattribute - the attribute with the target nameAttributeDriver.getTargetName()Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.