org.apache.flink.connector.file.table

Class FileSystemConnectorOptions

java.lang.Object

org.apache.flink.connector.file.table.FileSystemConnectorOptions

@PublicEvolving
public class FileSystemConnectorOptions
extends Object

Options for the filesystem connector.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FileSystemConnectorOptions.FileStatisticsType Statistics types for file system, see SOURCE_REPORT_STATISTICS.
static class	FileSystemConnectorOptions.PartitionCommitTriggerType Trigger types for partition commit, see SINK_PARTITION_COMMIT_TRIGGER.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Boolean>	AUTO_COMPACTION
static ConfigOption<MemorySize>	COMPACTION_FILE_SIZE
static ConfigOption<Integer>	COMPACTION_PARALLELISM
static ConfigOption<String>	PARTITION_DEFAULT_NAME
static ConfigOption<String>	PARTITION_TIME_EXTRACTOR_CLASS
static ConfigOption<String>	PARTITION_TIME_EXTRACTOR_KIND
static ConfigOption<String>	PARTITION_TIME_EXTRACTOR_TIMESTAMP_FORMATTER
static ConfigOption<String>	PARTITION_TIME_EXTRACTOR_TIMESTAMP_PATTERN
static ConfigOption<String>	PATH
static ConfigOption<Integer>	SINK_PARALLELISM
static ConfigOption<Duration>	SINK_PARTITION_COMMIT_DELAY
static ConfigOption<String>	SINK_PARTITION_COMMIT_POLICY_CLASS
static ConfigOption<List<String>>	SINK_PARTITION_COMMIT_POLICY_CLASS_PARAMETERS
static ConfigOption<String>	SINK_PARTITION_COMMIT_POLICY_KIND
static ConfigOption<String>	SINK_PARTITION_COMMIT_SUCCESS_FILE_NAME
static ConfigOption<FileSystemConnectorOptions.PartitionCommitTriggerType>	SINK_PARTITION_COMMIT_TRIGGER
static ConfigOption<String>	SINK_PARTITION_COMMIT_WATERMARK_TIME_ZONE
static ConfigOption<Duration>	SINK_ROLLING_POLICY_CHECK_INTERVAL
static ConfigOption<MemorySize>	SINK_ROLLING_POLICY_FILE_SIZE
static ConfigOption<Duration>	SINK_ROLLING_POLICY_INACTIVITY_INTERVAL
static ConfigOption<Duration>	SINK_ROLLING_POLICY_ROLLOVER_INTERVAL
static ConfigOption<Boolean>	SINK_SHUFFLE_BY_PARTITION
static ConfigOption<Duration>	SOURCE_MONITOR_INTERVAL
static ConfigOption<String>	SOURCE_PATH_REGEX_PATTERN
static ConfigOption<FileSystemConnectorOptions.FileStatisticsType>	SOURCE_REPORT_STATISTICS

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PATH

public static final ConfigOption<String> PATH

PARTITION_DEFAULT_NAME

public static final ConfigOption<String> PARTITION_DEFAULT_NAME

SOURCE_MONITOR_INTERVAL

public static final ConfigOption<Duration> SOURCE_MONITOR_INTERVAL

SOURCE_REPORT_STATISTICS

public static final ConfigOption<FileSystemConnectorOptions.FileStatisticsType> SOURCE_REPORT_STATISTICS

SOURCE_PATH_REGEX_PATTERN

public static final ConfigOption<String> SOURCE_PATH_REGEX_PATTERN

SINK_ROLLING_POLICY_FILE_SIZE

public static final ConfigOption<MemorySize> SINK_ROLLING_POLICY_FILE_SIZE

SINK_ROLLING_POLICY_ROLLOVER_INTERVAL

public static final ConfigOption<Duration> SINK_ROLLING_POLICY_ROLLOVER_INTERVAL

SINK_ROLLING_POLICY_INACTIVITY_INTERVAL

public static final ConfigOption<Duration> SINK_ROLLING_POLICY_INACTIVITY_INTERVAL

SINK_ROLLING_POLICY_CHECK_INTERVAL

public static final ConfigOption<Duration> SINK_ROLLING_POLICY_CHECK_INTERVAL

SINK_SHUFFLE_BY_PARTITION

public static final ConfigOption<Boolean> SINK_SHUFFLE_BY_PARTITION

PARTITION_TIME_EXTRACTOR_KIND

public static final ConfigOption<String> PARTITION_TIME_EXTRACTOR_KIND

PARTITION_TIME_EXTRACTOR_CLASS

public static final ConfigOption<String> PARTITION_TIME_EXTRACTOR_CLASS

PARTITION_TIME_EXTRACTOR_TIMESTAMP_FORMATTER

public static final ConfigOption<String> PARTITION_TIME_EXTRACTOR_TIMESTAMP_FORMATTER

PARTITION_TIME_EXTRACTOR_TIMESTAMP_PATTERN

public static final ConfigOption<String> PARTITION_TIME_EXTRACTOR_TIMESTAMP_PATTERN

SINK_PARTITION_COMMIT_TRIGGER

public static final ConfigOption<FileSystemConnectorOptions.PartitionCommitTriggerType> SINK_PARTITION_COMMIT_TRIGGER

SINK_PARTITION_COMMIT_DELAY

public static final ConfigOption<Duration> SINK_PARTITION_COMMIT_DELAY

SINK_PARTITION_COMMIT_WATERMARK_TIME_ZONE

public static final ConfigOption<String> SINK_PARTITION_COMMIT_WATERMARK_TIME_ZONE

SINK_PARTITION_COMMIT_POLICY_KIND

public static final ConfigOption<String> SINK_PARTITION_COMMIT_POLICY_KIND

SINK_PARTITION_COMMIT_POLICY_CLASS

public static final ConfigOption<String> SINK_PARTITION_COMMIT_POLICY_CLASS

SINK_PARTITION_COMMIT_POLICY_CLASS_PARAMETERS

public static final ConfigOption<List<String>> SINK_PARTITION_COMMIT_POLICY_CLASS_PARAMETERS

SINK_PARTITION_COMMIT_SUCCESS_FILE_NAME

public static final ConfigOption<String> SINK_PARTITION_COMMIT_SUCCESS_FILE_NAME

AUTO_COMPACTION

public static final ConfigOption<Boolean> AUTO_COMPACTION

COMPACTION_FILE_SIZE

public static final ConfigOption<MemorySize> COMPACTION_FILE_SIZE

COMPACTION_PARALLELISM

public static final ConfigOption<Integer> COMPACTION_PARALLELISM

SINK_PARALLELISM

public static final ConfigOption<Integer> SINK_PARALLELISM