public class CoreOptions extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
CoreOptions.ChangelogProducer
Specifies the changelog producer for table.
|
static interface |
CoreOptions.Immutable
Annotation used on
ConfigOption fields to exclude it from schema change. |
static class |
CoreOptions.LogChangelogMode
Specifies the log changelog mode for table.
|
static class |
CoreOptions.LogConsistency
Specifies the log consistency mode for table.
|
static class |
CoreOptions.MergeEngine
Specifies the merge engine for table with primary key.
|
static class |
CoreOptions.StartupMode
Specifies the startup mode for log consumer.
|
Modifier and Type | Field and Description |
---|---|
static org.apache.flink.configuration.ConfigOption<Boolean> |
AUTO_CREATE |
static org.apache.flink.configuration.ConfigOption<Integer> |
BUCKET |
static org.apache.flink.configuration.ConfigOption<String> |
BUCKET_KEY |
static org.apache.flink.configuration.ConfigOption<CoreOptions.ChangelogProducer> |
CHANGELOG_PRODUCER |
static org.apache.flink.configuration.ConfigOption<java.time.Duration> |
CHANGELOG_PRODUCER_FULL_COMPACTION_TRIGGER_INTERVAL |
static org.apache.flink.configuration.ConfigOption<Boolean> |
COMMIT_FORCE_COMPACT |
static org.apache.flink.configuration.ConfigOption<Integer> |
COMPACTION_MAX_FILE_NUM |
static org.apache.flink.configuration.ConfigOption<Integer> |
COMPACTION_MAX_SIZE_AMPLIFICATION_PERCENT |
static org.apache.flink.configuration.ConfigOption<Integer> |
COMPACTION_MAX_SORTED_RUN_NUM |
static org.apache.flink.configuration.ConfigOption<Integer> |
COMPACTION_MIN_FILE_NUM |
static org.apache.flink.configuration.ConfigOption<Integer> |
COMPACTION_SIZE_RATIO |
static org.apache.flink.configuration.ConfigOption<java.time.Duration> |
CONTINUOUS_DISCOVERY_INTERVAL |
static org.apache.flink.configuration.ConfigOption<String> |
FILE_FORMAT |
static org.apache.flink.configuration.ConfigOption<Integer> |
LOCAL_SORT_MAX_NUM_FILE_HANDLES |
static org.apache.flink.configuration.ConfigOption<CoreOptions.LogChangelogMode> |
LOG_CHANGELOG_MODE |
static org.apache.flink.configuration.ConfigOption<CoreOptions.LogConsistency> |
LOG_CONSISTENCY |
static org.apache.flink.configuration.ConfigOption<String> |
LOG_FORMAT |
static org.apache.flink.configuration.ConfigOption<String> |
LOG_KEY_FORMAT |
static org.apache.flink.configuration.ConfigOption<java.time.Duration> |
LOG_RETENTION |
static org.apache.flink.configuration.ConfigOption<Boolean> |
LOG_SCAN_REMOVE_NORMALIZE |
static org.apache.flink.configuration.ConfigOption<String> |
MANIFEST_FORMAT |
static org.apache.flink.configuration.ConfigOption<Integer> |
MANIFEST_MERGE_MIN_COUNT |
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> |
MANIFEST_TARGET_FILE_SIZE |
static org.apache.flink.configuration.ConfigOption<CoreOptions.MergeEngine> |
MERGE_ENGINE |
static org.apache.flink.configuration.ConfigOption<Integer> |
NUM_LEVELS |
static org.apache.flink.configuration.ConfigOption<Integer> |
NUM_SORTED_RUNS_COMPACTION_TRIGGER |
static org.apache.flink.configuration.ConfigOption<Integer> |
NUM_SORTED_RUNS_STOP_TRIGGER |
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> |
PAGE_SIZE |
static org.apache.flink.configuration.ConfigOption<Boolean> |
PARTIAL_UPDATE_IGNORE_DELETE |
static org.apache.flink.configuration.ConfigOption<String> |
PARTITION_DEFAULT_NAME |
static org.apache.flink.configuration.ConfigOption<java.time.Duration> |
PARTITION_EXPIRATION_CHECK_INTERVAL |
static org.apache.flink.configuration.ConfigOption<java.time.Duration> |
PARTITION_EXPIRATION_TIME |
static org.apache.flink.configuration.ConfigOption<String> |
PARTITION_TIMESTAMP_FORMATTER |
static org.apache.flink.configuration.ConfigOption<String> |
PARTITION_TIMESTAMP_PATTERN |
static org.apache.flink.configuration.ConfigOption<String> |
PATH |
static org.apache.flink.configuration.ConfigOption<CoreOptions.StartupMode> |
SCAN_MODE |
static org.apache.flink.configuration.ConfigOption<Boolean> |
SCAN_PLAN_SORT_PARTITION |
static org.apache.flink.configuration.ConfigOption<Long> |
SCAN_SNAPSHOT_ID |
static org.apache.flink.configuration.ConfigOption<Long> |
SCAN_TIMESTAMP_MILLIS |
static org.apache.flink.configuration.ConfigOption<String> |
SEQUENCE_FIELD |
static org.apache.flink.configuration.ConfigOption<Integer> |
SNAPSHOT_NUM_RETAINED_MAX |
static org.apache.flink.configuration.ConfigOption<Integer> |
SNAPSHOT_NUM_RETAINED_MIN |
static org.apache.flink.configuration.ConfigOption<java.time.Duration> |
SNAPSHOT_TIME_RETAINED |
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> |
SOURCE_SPLIT_OPEN_FILE_COST |
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> |
SOURCE_SPLIT_TARGET_SIZE |
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> |
TARGET_FILE_SIZE |
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> |
WRITE_BUFFER_SIZE |
static org.apache.flink.configuration.ConfigOption<Boolean> |
WRITE_BUFFER_SPILLABLE |
static org.apache.flink.configuration.ConfigOption<WriteMode> |
WRITE_MODE |
static org.apache.flink.configuration.ConfigOption<Boolean> |
WRITE_ONLY |
Constructor and Description |
---|
CoreOptions(org.apache.flink.configuration.Configuration options) |
CoreOptions(Map<String,String> options) |
public static final org.apache.flink.configuration.ConfigOption<Integer> BUCKET
public static final org.apache.flink.configuration.ConfigOption<String> BUCKET_KEY
@Internal public static final org.apache.flink.configuration.ConfigOption<String> PATH
public static final org.apache.flink.configuration.ConfigOption<String> FILE_FORMAT
public static final org.apache.flink.configuration.ConfigOption<String> MANIFEST_FORMAT
public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> MANIFEST_TARGET_FILE_SIZE
public static final org.apache.flink.configuration.ConfigOption<Integer> MANIFEST_MERGE_MIN_COUNT
public static final org.apache.flink.configuration.ConfigOption<String> PARTITION_DEFAULT_NAME
public static final org.apache.flink.configuration.ConfigOption<Integer> SNAPSHOT_NUM_RETAINED_MIN
public static final org.apache.flink.configuration.ConfigOption<Integer> SNAPSHOT_NUM_RETAINED_MAX
public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> SNAPSHOT_TIME_RETAINED
public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> CONTINUOUS_DISCOVERY_INTERVAL
public static final org.apache.flink.configuration.ConfigOption<CoreOptions.MergeEngine> MERGE_ENGINE
public static final org.apache.flink.configuration.ConfigOption<Boolean> PARTIAL_UPDATE_IGNORE_DELETE
public static final org.apache.flink.configuration.ConfigOption<WriteMode> WRITE_MODE
public static final org.apache.flink.configuration.ConfigOption<Boolean> WRITE_ONLY
public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> SOURCE_SPLIT_TARGET_SIZE
public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> SOURCE_SPLIT_OPEN_FILE_COST
public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> WRITE_BUFFER_SIZE
public static final org.apache.flink.configuration.ConfigOption<Boolean> WRITE_BUFFER_SPILLABLE
public static final org.apache.flink.configuration.ConfigOption<Integer> LOCAL_SORT_MAX_NUM_FILE_HANDLES
public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> PAGE_SIZE
public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> TARGET_FILE_SIZE
public static final org.apache.flink.configuration.ConfigOption<Integer> NUM_SORTED_RUNS_COMPACTION_TRIGGER
public static final org.apache.flink.configuration.ConfigOption<Integer> NUM_SORTED_RUNS_STOP_TRIGGER
public static final org.apache.flink.configuration.ConfigOption<Integer> NUM_LEVELS
public static final org.apache.flink.configuration.ConfigOption<Boolean> COMMIT_FORCE_COMPACT
public static final org.apache.flink.configuration.ConfigOption<Integer> COMPACTION_MAX_SIZE_AMPLIFICATION_PERCENT
public static final org.apache.flink.configuration.ConfigOption<Integer> COMPACTION_SIZE_RATIO
public static final org.apache.flink.configuration.ConfigOption<Integer> COMPACTION_MIN_FILE_NUM
public static final org.apache.flink.configuration.ConfigOption<Integer> COMPACTION_MAX_FILE_NUM
public static final org.apache.flink.configuration.ConfigOption<Integer> COMPACTION_MAX_SORTED_RUN_NUM
public static final org.apache.flink.configuration.ConfigOption<CoreOptions.ChangelogProducer> CHANGELOG_PRODUCER
public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> CHANGELOG_PRODUCER_FULL_COMPACTION_TRIGGER_INTERVAL
public static final org.apache.flink.configuration.ConfigOption<String> SEQUENCE_FIELD
public static final org.apache.flink.configuration.ConfigOption<CoreOptions.StartupMode> SCAN_MODE
public static final org.apache.flink.configuration.ConfigOption<Long> SCAN_TIMESTAMP_MILLIS
public static final org.apache.flink.configuration.ConfigOption<Long> SCAN_SNAPSHOT_ID
public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> LOG_RETENTION
public static final org.apache.flink.configuration.ConfigOption<CoreOptions.LogConsistency> LOG_CONSISTENCY
public static final org.apache.flink.configuration.ConfigOption<CoreOptions.LogChangelogMode> LOG_CHANGELOG_MODE
public static final org.apache.flink.configuration.ConfigOption<Boolean> LOG_SCAN_REMOVE_NORMALIZE
public static final org.apache.flink.configuration.ConfigOption<String> LOG_KEY_FORMAT
public static final org.apache.flink.configuration.ConfigOption<String> LOG_FORMAT
public static final org.apache.flink.configuration.ConfigOption<Boolean> AUTO_CREATE
public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> PARTITION_EXPIRATION_TIME
public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> PARTITION_EXPIRATION_CHECK_INTERVAL
public static final org.apache.flink.configuration.ConfigOption<String> PARTITION_TIMESTAMP_FORMATTER
public static final org.apache.flink.configuration.ConfigOption<String> PARTITION_TIMESTAMP_PATTERN
public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_PLAN_SORT_PARTITION
public CoreOptions(org.apache.flink.configuration.Configuration options)
public int bucket()
public org.apache.flink.core.fs.Path path()
public static org.apache.flink.core.fs.Path path(org.apache.flink.configuration.Configuration options)
public FileFormat fileFormat()
public FileFormat manifestFormat()
public org.apache.flink.configuration.MemorySize manifestTargetSize()
public String partitionDefaultName()
public int snapshotNumRetainMin()
public int snapshotNumRetainMax()
public java.time.Duration snapshotTimeRetain()
public int manifestMergeMinCount()
public CoreOptions.MergeEngine mergeEngine()
public long splitTargetSize()
public long splitOpenFileCost()
public long writeBufferSize()
public boolean writeBufferSpillable(boolean usingObjectStore)
public java.time.Duration continuousDiscoveryInterval()
public int localSortMaxNumFileHandles()
public int pageSize()
public long targetFileSize()
public int numSortedRunCompactionTrigger()
public int numSortedRunStopTrigger()
public int numLevels()
public boolean commitForceCompact()
public int maxSizeAmplificationPercent()
public int sortedRunSizeRatio()
public int compactionMinFileNum()
public int compactionMaxFileNum()
public int maxSortedRunNum()
public CoreOptions.ChangelogProducer changelogProducer()
public boolean scanPlanSortPartition()
public CoreOptions.StartupMode startupMode()
public static CoreOptions.StartupMode startupMode(org.apache.flink.configuration.ReadableConfig options)
public Long scanTimestampMills()
public Long scanSnapshotId()
public java.time.Duration changelogProducerFullCompactionTriggerInterval()
public WriteMode writeMode()
public boolean writeOnly()
public java.time.Duration partitionExpireTime()
public java.time.Duration partitionExpireCheckInterval()
public String partitionTimestampFormatter()
public String partitionTimestampPattern()
public static void setDefaultValues(org.apache.flink.configuration.Configuration options)
CoreOptions
via the given Configuration
.options
- the options to set default valuespublic static void validateTableSchema(TableSchema schema)
TableSchema
and CoreOptions
.
TODO validate all items in schema and all keys in options.
schema
- the schema to be validated@Internal public static List<org.apache.flink.configuration.ConfigOption<?>> getOptions()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.