@PublicEvolving public class FileSystemConnectorOptions extends Object
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 . |
public static final ConfigOption<String> PATH
public static final ConfigOption<String> PARTITION_DEFAULT_NAME
public static final ConfigOption<java.time.Duration> SOURCE_MONITOR_INTERVAL
public static final ConfigOption<FileSystemConnectorOptions.FileStatisticsType> SOURCE_REPORT_STATISTICS
public static final ConfigOption<MemorySize> SINK_ROLLING_POLICY_FILE_SIZE
public static final ConfigOption<java.time.Duration> SINK_ROLLING_POLICY_ROLLOVER_INTERVAL
public static final ConfigOption<java.time.Duration> SINK_ROLLING_POLICY_INACTIVITY_INTERVAL
public static final ConfigOption<java.time.Duration> SINK_ROLLING_POLICY_CHECK_INTERVAL
public static final ConfigOption<Boolean> SINK_SHUFFLE_BY_PARTITION
public static final ConfigOption<String> PARTITION_TIME_EXTRACTOR_KIND
public static final ConfigOption<String> PARTITION_TIME_EXTRACTOR_CLASS
public static final ConfigOption<String> PARTITION_TIME_EXTRACTOR_TIMESTAMP_FORMATTER
public static final ConfigOption<String> PARTITION_TIME_EXTRACTOR_TIMESTAMP_PATTERN
public static final ConfigOption<FileSystemConnectorOptions.PartitionCommitTriggerType> SINK_PARTITION_COMMIT_TRIGGER
public static final ConfigOption<java.time.Duration> SINK_PARTITION_COMMIT_DELAY
public static final ConfigOption<String> SINK_PARTITION_COMMIT_WATERMARK_TIME_ZONE
public static final ConfigOption<String> SINK_PARTITION_COMMIT_POLICY_KIND
public static final ConfigOption<String> SINK_PARTITION_COMMIT_POLICY_CLASS
public static final ConfigOption<String> SINK_PARTITION_COMMIT_SUCCESS_FILE_NAME
public static final ConfigOption<Boolean> AUTO_COMPACTION
public static final ConfigOption<MemorySize> COMPACTION_FILE_SIZE
public static final ConfigOption<Integer> COMPACTION_PARALLELISM
public static final ConfigOption<Integer> SINK_PARALLELISM
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.