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 RetryPolicy |
RetryPolicy.fromConfig(ReadableConfig config) |
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 | 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 |
---|---|
static HBaseLookupOptions |
HBaseConnectorOptionsUtil.getHBaseLookupOptions(ReadableConfig tableOptions) |
static HBaseWriteOptions |
HBaseConnectorOptionsUtil.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) |
HiveSourceBuilder(org.apache.hadoop.mapred.JobConf jobConf,
ReadableConfig flinkConf,
ObjectPath tablePath,
String hiveVersion,
CatalogTable catalogTable)
Creates a builder to read a hive table.
|
HiveSourceBuilder(org.apache.hadoop.mapred.JobConf jobConf,
ReadableConfig flinkConf,
String hiveVersion,
String dbName,
String tableName,
Map<String,String> tableOptions)
Creates a builder to read a hive table.
|
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.
|
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 |
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.
|
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<BulkWriter.Factory<RowData>> |
AvroFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
AvroFormatFactory.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 JsonFormatOptions.MapNullKeyMode |
JsonFormatOptionsUtil.getMapNullKeyMode(ReadableConfig config)
Creates handling mode for null key map data.
|
static TimestampFormat |
JsonFormatOptionsUtil.getTimestampFormat(ReadableConfig config) |
static void |
JsonFormatOptionsUtil.validateDecodingFormatOptions(ReadableConfig tableOptions)
Validator for json decoding format.
|
static void |
JsonFormatOptionsUtil.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) |
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) |
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) |
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 |
---|---|
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 |
---|---|
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.
|
CheckpointStorage |
ConfigurableCheckpointStorage.configure(ReadableConfig config,
ClassLoader classLoader)
Creates a variant of the checkpoint storage that applies additional configuration parameters.
|
T |
CheckpointStorageFactory.createFromConfig(ReadableConfig config,
ClassLoader classLoader)
Creates the checkpoint storage, optionally using the given configuration.
|
T |
StateBackendFactory.createFromConfig(ReadableConfig config,
ClassLoader classLoader)
Creates the state backend, 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 unwrapped state backend from the configuration, from the parameter 'state.backend',
as defined in
StateBackendOptions.STATE_BACKEND . |
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 |
---|---|
ReadableConfig |
StreamExecutionEnvironment.getConfiguration()
Gives read-only access to the underlying configuration of this environment.
|
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)
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 void |
KinesisDynamicTableFactory.validateKinesisPartitioner(ReadableConfig tableOptions,
CatalogTable targetTable) |
Modifier and Type | Method and Description |
---|---|
static EnvironmentSettings |
EnvironmentSettings.fromConfiguration(ReadableConfig configuration)
Creates an instance of
EnvironmentSettings from configuration. |
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. |
Constructor and Description |
---|
ResultDescriptor(String resultId,
ResolvedSchema resultSchema,
boolean isMaterialized,
ReadableConfig config) |
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 |
---|---|
ReadableConfig |
Executor.getConfiguration()
Gives read-only access to the configuration of the executor.
|
Modifier and Type | Method and Description |
---|---|
Pipeline |
Executor.createPipeline(List<Transformation<?>> transformations,
ReadableConfig tableConfiguration,
String defaultJobName)
Translates the given transformations to a
Pipeline . |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
ChangelogCsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
ChainingOptimizingExecutor.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
Pipeline |
ChainingOptimizingExecutor.createPipeline(List<Transformation<?>> transformations,
ReadableConfig configuration,
String defaultJobName) |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
ResolverRule.ResolutionContext.configuration()
Access to configuration.
|
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
TableSourceFactoryContextImpl.getConfiguration() |
ReadableConfig |
CatalogFactory.Context.getConfiguration()
Gives read-only access to the configuration of the current session.
|
ReadableConfig |
TableSourceFactory.Context.getConfiguration() |
ReadableConfig |
TableSinkFactory.Context.getConfiguration() |
ReadableConfig |
DynamicTableFactory.Context.getConfiguration()
Gives read-only access to the configuration of the current session.
|
ReadableConfig |
ModuleFactory.Context.getConfiguration()
Gives read-only access to the configuration of the current session.
|
ReadableConfig |
FactoryUtil.DefaultDynamicTableContext.getConfiguration() |
ReadableConfig |
FactoryUtil.DefaultCatalogContext.getConfiguration() |
ReadableConfig |
FactoryUtil.DefaultModuleContext.getConfiguration() |
ReadableConfig |
TableSinkFactoryContextImpl.getConfiguration() |
ReadableConfig |
FileSystemFormatFactory.ReaderContext.getFormatOptions()
Options of this format.
|
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 Module |
FactoryUtil.createModule(String moduleName,
Map<String,String> options,
ReadableConfig configuration,
ClassLoader classLoader)
Discovers a matching module factory and creates an instance of it.
|
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) |
DefaultModuleContext(Map<String,String> options,
ReadableConfig configuration,
ClassLoader classLoader) |
TableSinkFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isBounded,
boolean isTemporary) |
TableSourceFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isTemporary) |
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 |
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 isBatchMode,
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 isBatchMode,
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 isBatchMode,
ReadableConfig config)
Prepares the given
DynamicTableSource . |
Modifier and Type | Class and Description |
---|---|
class |
PlannerConfiguration
Configuration view that combines the API specific table configuration and the executor
configuration.
|
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
DefaultExecutor.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
Pipeline |
DefaultExecutor.createPipeline(List<Transformation<?>> transformations,
ReadableConfig tableConfiguration,
String defaultJobName) |
Constructor and Description |
---|
InputPriorityConflictResolver(List<ExecNode<?>> roots,
InputProperty.DamBehavior safeDamBehavior,
StreamExchangeMode exchangeMode,
ReadableConfig configuration)
Create a
InputPriorityConflictResolver for the given ExecNode graph. |
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) |
Modifier and Type | Method and Description |
---|---|
static ReadableConfig |
ShortcutUtils.unwrapConfig(org.apache.calcite.rel.RelNode relNode) |
Modifier and Type | Method and Description |
---|---|
static StreamExchangeMode |
StreamExchangeModeUtils.getBatchStreamExchangeMode(ReadableConfig config,
StreamExchangeMode requiredExchangeMode) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.