public class FlinkConnectorOptions extends Object
Modifier and Type | Field and Description |
---|---|
static org.apache.flink.configuration.ConfigOption<String> |
LOG_SYSTEM |
static String |
NONE |
static org.apache.flink.configuration.ConfigOption<String> |
ROOT_PATH |
static org.apache.flink.configuration.ConfigOption<Integer> |
SCAN_PARALLELISM |
static org.apache.flink.configuration.ConfigOption<Integer> |
SINK_PARALLELISM |
static String |
TABLE_STORE_PREFIX |
Constructor and Description |
---|
FlinkConnectorOptions() |
Modifier and Type | Method and Description |
---|---|
static List<org.apache.flink.configuration.ConfigOption<?>> |
getOptions() |
static String |
relativeTablePath(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier) |
public static final String TABLE_STORE_PREFIX
public static final String NONE
@Internal public static final org.apache.flink.configuration.ConfigOption<String> ROOT_PATH
public static final org.apache.flink.configuration.ConfigOption<String> LOG_SYSTEM
public static final org.apache.flink.configuration.ConfigOption<Integer> SINK_PARALLELISM
public static final org.apache.flink.configuration.ConfigOption<Integer> SCAN_PARALLELISM
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.