@PublicEvolving public class JdbcConnectorOptions extends Object
public static final ConfigOption<String> URL
public static final ConfigOption<String> TABLE_NAME
public static final ConfigOption<String> USERNAME
public static final ConfigOption<String> PASSWORD
public static final ConfigOption<String> DRIVER
public static final ConfigOption<java.time.Duration> MAX_RETRY_TIMEOUT
public static final ConfigOption<Integer> SINK_PARALLELISM
public static final ConfigOption<String> SCAN_PARTITION_COLUMN
public static final ConfigOption<Integer> SCAN_PARTITION_NUM
public static final ConfigOption<Long> SCAN_PARTITION_LOWER_BOUND
public static final ConfigOption<Long> SCAN_PARTITION_UPPER_BOUND
public static final ConfigOption<Integer> SCAN_FETCH_SIZE
public static final ConfigOption<Boolean> SCAN_AUTO_COMMIT
public static final ConfigOption<Long> LOOKUP_CACHE_MAX_ROWS
public static final ConfigOption<java.time.Duration> LOOKUP_CACHE_TTL
public static final ConfigOption<Integer> LOOKUP_MAX_RETRIES
public static final ConfigOption<Boolean> LOOKUP_CACHE_MISSING_KEY
public static final ConfigOption<Integer> SINK_BUFFER_FLUSH_MAX_ROWS
public static final ConfigOption<java.time.Duration> SINK_BUFFER_FLUSH_INTERVAL
public static final ConfigOption<Integer> SINK_MAX_RETRIES
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.