Modifier and Type | Method and Description |
---|---|
void |
ExecutionConfig.configure(ReadableConfig configuration,
ClassLoader classLoader)
Sets all relevant options contained in the
ReadableConfig such as e.g. |
Modifier and Type | Method and Description |
---|---|
static Optional<RestartStrategies.RestartStrategyConfiguration> |
RestartStrategies.fromConfiguration(ReadableConfig configuration)
Reads a
RestartStrategies.RestartStrategyConfiguration from a given ReadableConfig . |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionEnvironment.configure(ReadableConfig configuration,
ClassLoader classLoader)
Sets all relevant options contained in the
ReadableConfig such as e.g. |
Modifier and Type | Method and Description |
---|---|
static PythonFunction |
PythonFunctionFactory.getPythonFunction(String fullyQualifiedName,
ReadableConfig config)
Returns PythonFunction according to the fully qualified name of the Python UDF i.e
${moduleName}.${functionName} or ${moduleName}.${className}.
|
static PythonFunctionFactory |
PythonFunctionFactory.getPythonFunctionFactory(ReadableConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
Configuration
Lightweight configuration object which stores key/value pairs.
|
class |
DelegatingConfiguration
A configuration that manages a subset of keys with a common prefix from a given configuration.
|
class |
UnmodifiableConfiguration
Unmodifiable version of the Configuration class.
|
Modifier and Type | Method and Description |
---|---|
static <IN,OUT,E extends Throwable> |
ConfigUtils.decodeListFromConfig(ReadableConfig configuration,
ConfigOption<List<IN>> key,
FunctionWithException<IN,OUT,E> mapper)
Gets a
List of values of type IN from a ReadableConfig and transforms
it to a List of type OUT based on the provided mapper function. |
Modifier and Type | Field and Description |
---|---|
protected ReadableConfig |
HiveTableSource.flinkConf |
Constructor and Description |
---|
HiveLookupTableSource(org.apache.hadoop.mapred.JobConf jobConf,
ReadableConfig flinkConf,
ObjectPath tablePath,
CatalogTable catalogTable) |
HiveTableSink(ReadableConfig flinkConf,
org.apache.hadoop.mapred.JobConf jobConf,
ObjectIdentifier identifier,
CatalogTable table) |
HiveTableSource(org.apache.hadoop.mapred.JobConf jobConf,
ReadableConfig flinkConf,
ObjectPath tablePath,
CatalogTable catalogTable) |
Modifier and Type | Method and Description |
---|---|
RocksDBOptionsFactory |
ConfigurableRocksDBOptionsFactory.configure(ReadableConfig configuration)
Creates a variant of the options factory that applies additional configuration parameters.
|
DefaultConfigurableOptionsFactory |
DefaultConfigurableOptionsFactory.configure(ReadableConfig configuration)
Creates a
DefaultConfigurableOptionsFactory instance from a ReadableConfig . |
RocksDBStateBackend |
RocksDBStateBackend.configure(ReadableConfig config,
ClassLoader classLoader)
Creates a copy of this state backend that uses the values defined in the configuration for
fields where that were not yet specified in this state backend.
|
RocksDBStateBackend |
RocksDBStateBackendFactory.createFromConfig(ReadableConfig config,
ClassLoader classLoader) |
static RocksDBNativeMetricOptions |
RocksDBNativeMetricOptions.fromConfig(ReadableConfig config)
Creates a
RocksDBNativeMetricOptions based on an external configuration. |
static RocksDBMemoryConfiguration |
RocksDBMemoryConfiguration.fromOtherAndConfiguration(RocksDBMemoryConfiguration other,
ReadableConfig config)
Derives a RocksDBMemoryConfiguration from another object and a configuration.
|
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
AvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
AvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<BulkWriter.Factory<RowData>> |
AvroFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
static Map<String,String> |
RegistryAvroFormatFactory.buildOptionalPropertiesMap(ReadableConfig formatOptions) |
DecodingFormat<DeserializationSchema<RowData>> |
RegistryAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
RegistryAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
DebeziumAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
DebeziumAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
CsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
CsvFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
JsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
JsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
static JsonOptions.MapNullKeyMode |
JsonOptions.getMapNullKeyMode(ReadableConfig config)
Creates handling mode for null key map data.
|
static TimestampFormat |
JsonOptions.getTimestampFormat(ReadableConfig config) |
static void |
JsonOptions.validateDecodingFormatOptions(ReadableConfig tableOptions)
Validator for json decoding format.
|
static void |
JsonOptions.validateEncodingFormatOptions(ReadableConfig tableOptions)
Validator for json encoding format.
|
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
CanalJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
CanalJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
static void |
CanalJsonOptions.validateDecodingFormatOptions(ReadableConfig tableOptions)
Validator for canal decoding format.
|
static void |
CanalJsonOptions.validateEncodingFormatOptions(ReadableConfig tableOptions)
Validator for canal encoding format.
|
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
DebeziumJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
DebeziumJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
static void |
DebeziumJsonOptions.validateDecodingFormatOptions(ReadableConfig tableOptions)
Validator for debezium decoding format.
|
static void |
DebeziumJsonOptions.validateEncodingFormatOptions(ReadableConfig tableOptions)
Validator for debezium encoding format.
|
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
MaxwellJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
MaxwellJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
static void |
MaxwellJsonOptions.validateDecodingFormatOptions(ReadableConfig tableOptions)
Validator for maxwell decoding format.
|
static void |
MaxwellJsonOptions.validateEncodingFormatOptions(ReadableConfig tableOptions)
Validator for maxwell encoding format.
|
Modifier and Type | Method and Description |
---|---|
BulkDecodingFormat<RowData> |
ParquetFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<BulkWriter.Factory<RowData>> |
ParquetFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
BulkDecodingFormat<RowData> |
OrcFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<BulkWriter.Factory<RowData>> |
OrcFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
static SavepointRestoreSettings |
SavepointRestoreSettings.fromConfiguration(ReadableConfig configuration) |
Modifier and Type | Method and Description |
---|---|
StateBackend |
ConfigurableStateBackend.configure(ReadableConfig config,
ClassLoader classLoader)
Creates a variant of the state backend that applies additional configuration parameters.
|
T |
StateBackendFactory.createFromConfig(ReadableConfig config,
ClassLoader classLoader)
Creates the state backend, optionally using the given configuration.
|
static StateBackend |
StateBackendLoader.loadStateBackendFromConfig(ReadableConfig config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the state backend from the configuration, from the parameter 'state.backend', as
defined in
CheckpointingOptions.STATE_BACKEND . |
Modifier and Type | Method and Description |
---|---|
FsStateBackend |
FsStateBackend.configure(ReadableConfig config,
ClassLoader classLoader)
Creates a copy of this state backend that uses the values defined in the configuration for
fields where that were not specified in this state backend.
|
FsStateBackend |
FsStateBackendFactory.createFromConfig(ReadableConfig config,
ClassLoader classLoader) |
Constructor and Description |
---|
AbstractFileStateBackend(Path baseCheckpointPath,
Path baseSavepointPath,
ReadableConfig configuration)
Creates a new backend using the given checkpoint-/savepoint directories, or the values
defined in the given configuration.
|
Modifier and Type | Method and Description |
---|---|
MemoryStateBackend |
MemoryStateBackend.configure(ReadableConfig config,
ClassLoader classLoader)
Creates a copy of this state backend that uses the values defined in the configuration for
fields where that were not specified in this state backend.
|
MemoryStateBackend |
MemoryStateBackendFactory.createFromConfig(ReadableConfig config,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointConfig.configure(ReadableConfig configuration)
Sets all relevant options contained in the
ReadableConfig such as e.g. |
void |
StreamExecutionEnvironment.configure(ReadableConfig configuration,
ClassLoader classLoader)
Sets all relevant options contained in the
ReadableConfig such as e.g. |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
TransformationTranslator.Context.getGraphGeneratorConfig()
Retrieves additional configuration for the graph generation process.
|
Constructor and Description |
---|
StreamGraphGenerator(List<Transformation<?>> transformations,
ExecutionConfig executionConfig,
CheckpointConfig checkpointConfig,
ReadableConfig configuration) |
Modifier and Type | Method and Description |
---|---|
static int[] |
KafkaOptions.createKeyFormatProjection(ReadableConfig options,
DataType physicalDataType)
Creates an array of indices that determine which physical fields of the table schema to
include in the key format and the order that those fields have in the key format.
|
static int[] |
KafkaOptions.createValueFormatProjection(ReadableConfig options,
DataType physicalDataType)
Creates an array of indices that determine which physical fields of the table schema to
include in the value format.
|
static Optional<FlinkKafkaPartitioner<RowData>> |
KafkaOptions.getFlinkKafkaPartitioner(ReadableConfig tableOptions,
ClassLoader classLoader)
The partitioner can be either "fixed", "round-robin" or a customized partitioner full class
name.
|
static KafkaSinkSemantic |
KafkaOptions.getSinkSemantic(ReadableConfig tableOptions) |
static Pattern |
KafkaOptions.getSourceTopicPattern(ReadableConfig tableOptions) |
static List<String> |
KafkaOptions.getSourceTopics(ReadableConfig tableOptions) |
static KafkaOptions.StartupOptions |
KafkaOptions.getStartupOptions(ReadableConfig tableOptions) |
static void |
KafkaOptions.validateSinkTopic(ReadableConfig tableOptions) |
static void |
KafkaOptions.validateSourceTopic(ReadableConfig tableOptions) |
static void |
KafkaOptions.validateTableSinkOptions(ReadableConfig tableOptions) |
static void |
KafkaOptions.validateTableSourceOptions(ReadableConfig tableOptions) |
Modifier and Type | Method and Description |
---|---|
static KinesisPartitioner<RowData> |
KinesisOptions.getKinesisPartitioner(ReadableConfig tableOptions,
CatalogTable targetTable,
ClassLoader classLoader)
Constructs the kinesis partitioner for a
targetTable based on the currently set
tableOptions . |
static void |
KinesisDynamicTableFactory.validateKinesisPartitioner(ReadableConfig tableOptions,
CatalogTable targetTable) |
Modifier and Type | Method and Description |
---|---|
CatalogManager.Builder |
CatalogManager.Builder.config(ReadableConfig config) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
ChangelogCsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
ResolverRule.ResolutionContext.configuration()
Access to configuration.
|
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
TableSinkFactoryContextImpl.getConfiguration() |
ReadableConfig |
TableSinkFactory.Context.getConfiguration() |
ReadableConfig |
TableSourceFactoryContextImpl.getConfiguration() |
ReadableConfig |
DynamicTableFactory.Context.getConfiguration()
Gives read-only access to the configuration of the current session.
|
ReadableConfig |
TableSourceFactory.Context.getConfiguration() |
ReadableConfig |
FileSystemFormatFactory.ReaderContext.getFormatOptions()
Options of this format.
|
ReadableConfig |
FactoryUtil.TableFactoryHelper.getOptions()
Returns all options of the table.
|
Modifier and Type | Method and Description |
---|---|
DecodingFormat<I> |
DecodingFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
BulkDecodingFormat<RowData> |
BulkReaderFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a
BulkDecodingFormat from the given context and format options. |
EncodingFormat<I> |
EncodingFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
static DynamicTableSink |
FactoryUtil.createTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
static DynamicTableSource |
FactoryUtil.createTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSource from a CatalogTable . |
static <T> TableSink<T> |
TableFactoryUtil.findAndCreateTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
boolean isStreamingMode,
boolean isTemporary)
Creates a
TableSink from a CatalogTable . |
static <T> TableSource<T> |
TableFactoryUtil.findAndCreateTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
boolean isTemporary)
Creates a
TableSource from a CatalogTable . |
static void |
FactoryUtil.validateFactoryOptions(Factory factory,
ReadableConfig options)
Validates the required and optional
ConfigOption s of a factory. |
static void |
FactoryUtil.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions,
Set<ConfigOption<?>> optionalOptions,
ReadableConfig options)
Validates the required options and optional options.
|
Constructor and Description |
---|
TableSinkFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isBounded,
boolean isTemporary) |
TableSourceFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isTemporary) |
Modifier and Type | Field and Description |
---|---|
protected ReadableConfig |
DataGenVisitorBase.config |
Constructor and Description |
---|
DataGenVisitorBase(String name,
ReadableConfig config) |
RandomGeneratorVisitor(String name,
ReadableConfig config) |
SequenceGeneratorVisitor(String name,
ReadableConfig config) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
RawFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
RawFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
static UserDefinedFunction |
FunctionService.createFunction(FunctionDescriptor descriptor,
ClassLoader classLoader,
boolean performValidation,
ReadableConfig config)
Creates a user-defined function with the given properties.
|
static UserDefinedFunction |
UserDefinedFunctionHelper.instantiateFunction(ClassLoader classLoader,
ReadableConfig config,
String name,
CatalogFunction catalogFunction)
Instantiates a
UserDefinedFunction from a CatalogFunction . |
static void |
UserDefinedFunctionHelper.prepareInstance(ReadableConfig config,
UserDefinedFunction function)
Prepares a
UserDefinedFunction instance for usage in the API. |
Modifier and Type | Method and Description |
---|---|
static PythonFunction |
PythonFunctionUtils.getPythonFunction(String fullyQualifiedName,
ReadableConfig config) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.