public class InputFormatConfig
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
InputFormatConfig.ConfigBuilder |
static class |
InputFormatConfig.InMemoryDataModel |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
AS_OF_TIMESTAMP |
static java.lang.String |
CASE_SENSITIVE |
static boolean |
CASE_SENSITIVE_DEFAULT |
static java.lang.String |
CATALOG_CONFIG_PREFIX |
static java.lang.String |
CATALOG_NAME |
static java.lang.String |
COMMIT_FILE_THREAD_POOL_SIZE |
static int |
COMMIT_FILE_THREAD_POOL_SIZE_DEFAULT |
static java.lang.String |
COMMIT_TABLE_THREAD_POOL_SIZE |
static int |
COMMIT_TABLE_THREAD_POOL_SIZE_DEFAULT |
static java.lang.String |
CONFIG_SERIALIZATION_DISABLED |
static boolean |
CONFIG_SERIALIZATION_DISABLED_DEFAULT |
static java.lang.String |
EXTERNAL_TABLE_PURGE |
static java.lang.String |
FILTER_EXPRESSION |
static java.lang.String |
HADOOP_CATALOG |
static java.lang.String |
HADOOP_TABLES |
static java.lang.String |
HIVE_CATALOG |
static java.lang.String |
ICEBERG_SNAPSHOTS_TABLE_SUFFIX |
static java.lang.String |
IN_MEMORY_DATA_MODEL |
static java.lang.String |
LOCALITY |
static java.lang.String |
OUTPUT_TABLES |
static java.lang.String |
PARTITION_SPEC |
static java.lang.String |
READ_SCHEMA |
static java.lang.String |
REUSE_CONTAINERS |
static java.lang.String |
SCHEMA_AUTO_CONVERSION |
static java.lang.String |
SELECTED_COLUMNS |
static java.lang.String |
SERIALIZED_TABLE_PREFIX |
static java.lang.String |
SKIP_RESIDUAL_FILTERING |
static java.lang.String |
SNAPSHOT_ID |
static java.lang.String |
SNAPSHOT_TABLE |
static java.lang.String |
SNAPSHOT_TABLE_SUFFIX |
static java.lang.String |
SPLIT_SIZE |
static java.lang.String |
TABLE_CATALOG_PREFIX |
static java.lang.String |
TABLE_IDENTIFIER |
static java.lang.String |
TABLE_LOCATION |
static java.lang.String |
TABLE_SCHEMA |
static java.lang.String |
WRITE_TARGET_FILE_SIZE |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
catalogPropertyConfigKey(java.lang.String catalogName,
java.lang.String catalogProperty)
Get Hadoop config key of a catalog property based on catalog name
|
static Schema |
readSchema(org.apache.hadoop.conf.Configuration conf) |
static java.lang.String[] |
selectedColumns(org.apache.hadoop.conf.Configuration conf) |
static Schema |
tableSchema(org.apache.hadoop.conf.Configuration conf) |
public static final java.lang.String REUSE_CONTAINERS
public static final java.lang.String SKIP_RESIDUAL_FILTERING
public static final java.lang.String AS_OF_TIMESTAMP
public static final java.lang.String FILTER_EXPRESSION
public static final java.lang.String IN_MEMORY_DATA_MODEL
public static final java.lang.String READ_SCHEMA
public static final java.lang.String SNAPSHOT_ID
public static final java.lang.String SPLIT_SIZE
public static final java.lang.String SCHEMA_AUTO_CONVERSION
public static final java.lang.String TABLE_IDENTIFIER
public static final java.lang.String TABLE_LOCATION
public static final java.lang.String TABLE_SCHEMA
public static final java.lang.String PARTITION_SPEC
public static final java.lang.String SERIALIZED_TABLE_PREFIX
public static final java.lang.String TABLE_CATALOG_PREFIX
public static final java.lang.String LOCALITY
public static final java.lang.String SELECTED_COLUMNS
public static final java.lang.String EXTERNAL_TABLE_PURGE
public static final java.lang.String CONFIG_SERIALIZATION_DISABLED
public static final boolean CONFIG_SERIALIZATION_DISABLED_DEFAULT
public static final java.lang.String OUTPUT_TABLES
public static final java.lang.String COMMIT_TABLE_THREAD_POOL_SIZE
public static final int COMMIT_TABLE_THREAD_POOL_SIZE_DEFAULT
public static final java.lang.String COMMIT_FILE_THREAD_POOL_SIZE
public static final int COMMIT_FILE_THREAD_POOL_SIZE_DEFAULT
public static final java.lang.String WRITE_TARGET_FILE_SIZE
public static final java.lang.String CASE_SENSITIVE
public static final boolean CASE_SENSITIVE_DEFAULT
public static final java.lang.String CATALOG_NAME
public static final java.lang.String HADOOP_CATALOG
public static final java.lang.String HADOOP_TABLES
public static final java.lang.String HIVE_CATALOG
public static final java.lang.String ICEBERG_SNAPSHOTS_TABLE_SUFFIX
public static final java.lang.String SNAPSHOT_TABLE
public static final java.lang.String SNAPSHOT_TABLE_SUFFIX
public static final java.lang.String CATALOG_CONFIG_PREFIX
public static Schema tableSchema(org.apache.hadoop.conf.Configuration conf)
public static Schema readSchema(org.apache.hadoop.conf.Configuration conf)
public static java.lang.String[] selectedColumns(org.apache.hadoop.conf.Configuration conf)
public static java.lang.String catalogPropertyConfigKey(java.lang.String catalogName, java.lang.String catalogProperty)
catalogName
- catalog namecatalogProperty
- catalog property, can be any custom property, a commonly used list of
properties can be found at CatalogProperties