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, verify
public 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()
AttributeDriver
public void process(DmdlSemantics environment, ModelDeclaration declaration, AstAttribute attribute)
ModelAttributeDriver
process
in class ModelAttributeDriver
environment
- the processing environmentdeclaration
- the model declaration with the attribute
attribute
- the attribute with the target name
AttributeDriver.getTargetName()
public void verify(DmdlSemantics environment, ModelDeclaration declaration, AstAttribute attribute)
ModelAttributeDriver
processed
.verify
in class ModelAttributeDriver
environment
- the processing environmentdeclaration
- the model declaration with the attribute
attribute
- the attribute with the target name
AttributeDriver.getTargetName()
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.