public class FileSystemOptions extends Object
Constructor and Description |
---|
FileSystemOptions() |
public static final ConfigOption<String> PATH
public static final ConfigOption<String> PARTITION_DEFAULT_NAME
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_CHECK_INTERVAL
public static final ConfigOption<Boolean> SINK_SHUFFLE_BY_PARTITION
public static final ConfigOption<Boolean> STREAMING_SOURCE_ENABLE
public static final ConfigOption<String> STREAMING_SOURCE_PARTITION_INCLUDE
public static final ConfigOption<java.time.Duration> STREAMING_SOURCE_MONITOR_INTERVAL
public static final ConfigOption<String> STREAMING_SOURCE_PARTITION_ORDER
public static final ConfigOption<String> STREAMING_SOURCE_CONSUME_START_OFFSET
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_PATTERN
public static final ConfigOption<java.time.Duration> LOOKUP_JOIN_CACHE_TTL
public static final ConfigOption<String> 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> SINK_PARALLELISM
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.