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 PythonFunctionFactory |
PythonFunctionFactory.createPythonFunctionFactory(ReadableConfig config) |
static PythonFunction |
PythonFunctionFactory.getPythonFunction(String fullyQualifiedName,
ReadableConfig config,
ClassLoader classLoader)
Returns PythonFunction according to the fully qualified name of the Python UDF i.e
${moduleName}.${functionName} or ${moduleName}.${className}.
|
static PythonFunctionFactory.CacheKey |
PythonFunctionFactory.CacheKey.of(ReadableConfig config,
ClassLoader classLoader) |
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 | Method and Description |
---|---|
static HBaseLookupOptions |
HBaseOptions.getHBaseLookupOptions(ReadableConfig tableOptions) |
static HBaseWriteOptions |
HBaseOptions.getHBaseWriteOptions(ReadableConfig tableOptions) |
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,
Integer configuredParallelism) |
HiveTableSource(org.apache.hadoop.mapred.JobConf jobConf,
ReadableConfig flinkConf,
ObjectPath tablePath,
CatalogTable catalogTable) |
Modifier and Type | Method and Description |
---|---|
DefaultConfigurableOptionsFactory |
DefaultConfigurableOptionsFactory.configure(ReadableConfig configuration)
Creates a
DefaultConfigurableOptionsFactory instance from a ReadableConfig . |
RocksDBOptionsFactory |
ConfigurableRocksDBOptionsFactory.configure(ReadableConfig configuration)
Creates a variant of the options factory that applies additional configuration parameters.
|
RocksDBStateBackend |
RocksDBStateBackend.configure(ReadableConfig config,
ClassLoader classLoader)
Deprecated.
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.
|
EmbeddedRocksDBStateBackend |
EmbeddedRocksDBStateBackend.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) |
EmbeddedRocksDBStateBackend |
EmbeddedRocksDBStateBackendFactory.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 |
---|---|
CheckpointStorage |
ConfigurableCheckpointStorage.configure(ReadableConfig config,
ClassLoader classLoader)
Creates a variant of the checkpoint storage that applies additional configuration parameters.
|
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.
|
T |
CheckpointStorageFactory.createFromConfig(ReadableConfig config,
ClassLoader classLoader)
Creates the checkpoint storage, optionally using the given configuration.
|
static Optional<CheckpointStorage> |
CheckpointStorageLoader.fromConfig(ReadableConfig config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the checkpoint storage from the configuration, from the parameter
'state.checkpoint-storage', as defined in
CheckpointingOptions.CHECKPOINT_STORAGE . |
static StateBackend |
StateBackendLoader.loadStateBackendFromConfig(ReadableConfig config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the state backend from the configuration.
|
Modifier and Type | Method and Description |
---|---|
FsStateBackend |
FsStateBackend.configure(ReadableConfig config,
ClassLoader classLoader)
Deprecated.
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)
Deprecated.
Creates a new backend using the given checkpoint-/savepoint directories, or the values
defined in the given configuration.
|
Modifier and Type | Method and Description |
---|---|
HashMapStateBackend |
HashMapStateBackend.configure(ReadableConfig config,
ClassLoader classLoader) |
HashMapStateBackend |
HashMapStateBackendFactory.createFromConfig(ReadableConfig config,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
MemoryStateBackend |
MemoryStateBackend.configure(ReadableConfig config,
ClassLoader classLoader)
Deprecated.
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 |
---|---|
LatencyTrackingStateConfig.Builder |
LatencyTrackingStateConfig.Builder.configure(ReadableConfig config) |
Modifier and Type | Method and Description |
---|---|
FileSystemCheckpointStorage |
FileSystemCheckpointStorage.configure(ReadableConfig config,
ClassLoader classLoader) |
JobManagerCheckpointStorage |
JobManagerCheckpointStorage.configure(ReadableConfig config,
ClassLoader classLoader)
Creates a copy of this checkpoint storage that uses the values defined in the configuration
for fields where that were not specified in this checkpoint storage.
|
static FileSystemCheckpointStorage |
FileSystemCheckpointStorage.createFromConfig(ReadableConfig config,
ClassLoader classLoader)
Creates a new
FileSystemCheckpointStorage using the given configuration. |
static JobManagerCheckpointStorage |
JobManagerCheckpointStorage.createFromConfig(ReadableConfig config,
ClassLoader classLoader)
Creates a new
JobManagerCheckpointStorage using the given configuration. |
Modifier and Type | Method and Description |
---|---|
StateBackend |
ChangelogStateBackend.configure(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,
RowType physicalType,
List<String> partitionKeys,
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) |
Constructor and Description |
---|
FunctionCatalog(ReadableConfig config,
CatalogManager catalogManager,
ModuleManager moduleManager) |
Modifier and Type | Method and Description |
---|---|
static java.time.ZoneId |
CliUtils.getSessionTimeZone(ReadableConfig sessionConfig)
Get time zone from the the given session config.
|
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
Executor.getSessionConfig(String sessionId)
Returns a
ReadableConfig of all session configurations that are defined by the
executor and the session. |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
SessionContext.getReadableConfig() |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
LocalExecutor.getSessionConfig(String sessionId) |
Modifier and Type | Method and Description |
---|---|
DynamicResult |
ResultStore.createResult(ReadableConfig config,
TableResult tableResult)
Creates a result.
|
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 |
CatalogFactory.Context.getConfiguration()
Gives read-only access to the configuration of the current session.
|
ReadableConfig |
TableSourceFactory.Context.getConfiguration() |
ReadableConfig |
DynamicTableFactory.Context.getConfiguration()
Gives read-only access to the configuration of the current session.
|
ReadableConfig |
TableSinkFactoryContextImpl.getConfiguration() |
ReadableConfig |
TableSourceFactoryContextImpl.getConfiguration() |
ReadableConfig |
TableSinkFactory.Context.getConfiguration() |
ReadableConfig |
FactoryUtil.DefaultDynamicTableContext.getConfiguration() |
ReadableConfig |
FactoryUtil.DefaultCatalogContext.getConfiguration() |
ReadableConfig |
FileSystemFormatFactory.ReaderContext.getFormatOptions()
Options of this format.
|
ReadableConfig |
FactoryUtil.CatalogFactoryHelper.getOptions()
Returns all options of the catalog.
|
ReadableConfig |
FactoryUtil.TableFactoryHelper.getOptions()
Returns all options of the table.
|
Modifier and Type | Method and Description |
---|---|
static Catalog |
FactoryUtil.createCatalog(String catalogName,
Map<String,String> options,
ReadableConfig configuration,
ClassLoader classLoader)
Attempts to discover an appropriate catalog factory and creates an instance of the catalog.
|
BulkDecodingFormat<RowData> |
BulkReaderFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a
BulkDecodingFormat from the given context and format options. |
DecodingFormat<I> |
DecodingFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format 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,
ResolvedCatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
static DynamicTableSource |
FactoryUtil.createTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable 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 |
---|
DefaultCatalogContext(String name,
Map<String,String> options,
ReadableConfig configuration,
ClassLoader classLoader) |
DefaultDynamicTableContext(ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary) |
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 |
---|---|
ReadableConfig |
SpecializedFunction.SpecializedContext.getConfiguration()
Gives read-only access to the configuration of the current session.
|
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.createSpecializedFunction(String functionName,
FunctionDefinition definition,
CallContext callContext,
ClassLoader builtInClassLoader,
ReadableConfig configuration)
Creates the runtime implementation of a
FunctionDefinition as an instance of UserDefinedFunction . |
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,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSourceUtils.convertDataStreamToRel(boolean isStreamingMode,
ReadableConfig config,
org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
ObjectIdentifier identifier,
ResolvedSchema schema,
DataStream<?> dataStream,
DataType physicalDataType,
boolean isTopLevelRecord,
ChangelogMode changelogMode)
Converts a given
DataStream to a RelNode . |
static org.apache.calcite.rel.RelNode |
DynamicSourceUtils.convertSourceToRel(boolean isStreamingMode,
ReadableConfig config,
org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
ObjectIdentifier identifier,
ResolvedCatalogTable catalogTable,
org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic,
List<org.apache.calcite.rel.hint.RelHint> hints,
DynamicTableSource tableSource)
Converts a given
DynamicTableSource to a RelNode . |
static void |
DynamicSourceUtils.prepareDynamicSource(ObjectIdentifier sourceIdentifier,
ResolvedCatalogTable table,
DynamicTableSource source,
boolean isStreamingMode,
ReadableConfig config)
Prepares the given
DynamicTableSource . |
Modifier and Type | Field and Description |
---|---|
protected ReadableConfig |
CatalogTableSpecBase.configuration |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
CatalogTableSpecBase.getReadableConfig() |
Modifier and Type | Method and Description |
---|---|
void |
CatalogTableSpecBase.setReadableConfig(ReadableConfig config) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.