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 SharedBufferCacheConfig |
SharedBufferCacheConfig.of(ReadableConfig readableConfig) |
Modifier and Type | Method and Description |
---|---|
static StateChangeUploadScheduler |
StateChangeUploadScheduler.fromConfig(JobID jobID,
ReadableConfig config,
ChangelogStorageMetricGroup metricGroup,
TaskChangelogRegistry changelogRegistry,
LocalRecoveryConfig localRecoveryConfig) |
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. |
static String[] |
CoreOptions.getParentFirstLoaderPatterns(ReadableConfig config) |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
AsyncDynamicTableSinkFactory.AsyncDynamicSinkContext.getTableOptions() |
Modifier and Type | Field and Description |
---|---|
protected ReadableConfig |
AsyncSinkConfigurationValidator.tableOptions |
Constructor and Description |
---|
AsyncSinkConfigurationValidator(ReadableConfig tableOptions) |
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) |
Constructor and Description |
---|
FileSystemTableSource(ObjectIdentifier tableIdentifier,
DataType physicalRowDataType,
List<String> partitionKeys,
ReadableConfig tableOptions,
DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat,
DecodingFormat<DeserializationSchema<RowData>> deserializationFormat) |
Modifier and Type | Method and Description |
---|---|
BulkDecodingFormat<RowData> |
BulkReaderFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a
BulkDecodingFormat from the given context and format options. |
Constructor and Description |
---|
KinesisFirehoseConnectorOptionUtils(Map<String,String> resolvedOptions,
ReadableConfig tableOptions) |
Modifier and Type | Method and Description |
---|---|
static Configuration |
HBaseConnectorOptionsUtil.getHBaseConfiguration(ReadableConfig tableOptions)
config HBase Configuration.
|
static HBaseWriteOptions |
HBaseConnectorOptionsUtil.getHBaseWriteOptions(ReadableConfig tableOptions) |
Modifier and Type | Method and Description |
---|---|
static PartitionKeyGenerator<RowData> |
KinesisPartitionKeyGeneratorFactory.getKinesisPartitioner(ReadableConfig tableOptions,
RowType physicalType,
List<String> partitionKeys,
ClassLoader classLoader)
Constructs the kinesis partitioner for a
targetTable based on the currently set
tableOptions . |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
KinesisStreamsConnectorOptionsUtils.KinesisProducerOptionsMapper.mapDeprecatedTableOptions() |
Constructor and Description |
---|
KinesisProducerOptionsMapper(ReadableConfig tableOptions,
Map<String,String> resolvedOptions) |
KinesisStreamsConnectorOptionsUtils(Map<String,String> options,
ReadableConfig tableOptions,
RowType physicalType,
List<String> partitionKeys,
ClassLoader classLoader) |
Modifier and Type | Class and Description |
---|---|
class |
PulsarConfiguration
An unmodifiable
Configuration for Pulsar. |
Modifier and Type | Class and Description |
---|---|
class |
SinkConfiguration
The configured class for pulsar sink.
|
Modifier and Type | Class and Description |
---|---|
class |
SourceConfiguration
The configuration class for pulsar source.
|
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)
Deprecated.
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.
|
EmbeddedRocksDBStateBackend |
EmbeddedRocksDBStateBackendFactory.createFromConfig(ReadableConfig config,
ClassLoader classLoader) |
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.
|
Constructor and Description |
---|
RocksDBResourceContainer(ReadableConfig configuration,
PredefinedOptions predefinedOptions,
RocksDBOptionsFactory optionsFactory,
OpaqueMemoryResource<org.apache.flink.contrib.streaming.state.RocksDBSharedResources> sharedResources,
boolean enableStatistics) |
Modifier and Type | Method and Description |
---|---|
BulkDecodingFormat<RowData> |
AvroFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
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 |
---|---|
BulkDecodingFormat<RowData> |
CsvFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
DecodingFormat<DeserializationSchema<RowData>> |
CsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<BulkWriter.Factory<RowData>> |
CsvFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
CsvFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Constructor and Description |
---|
CsvBulkDecodingFormat(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 |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
OggJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
OggJsonFormatFactory.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) |
Constructor and Description |
---|
ParquetBulkDecodingFormat(ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
PbFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
PbFormatFactory.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) |
Constructor and Description |
---|
OrcBulkDecodingFormat(ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
PythonConfig
Configurations for the Python job which are used at run time.
|
Modifier and Type | Method and Description |
---|---|
void |
PythonFunctionRunner.open(ReadableConfig config)
Prepares the Python function runner, such as preparing the Python execution environment, etc.
|
Constructor and Description |
---|
PythonConfig(ReadableConfig configuration,
ReadableConfig pythonDependencyConfiguration) |
Modifier and Type | Method and Description |
---|---|
static PythonDependencyInfo |
PythonDependencyInfo.create(ReadableConfig config,
DistributedCache distributedCache)
Creates PythonDependencyInfo from GlobalJobParameters and DistributedCache.
|
Modifier and Type | Method and Description |
---|---|
static Configuration |
PythonDependencyUtils.configurePythonDependencies(List<Tuple2<String,DistributedCache.DistributedCacheEntry>> cachedFiles,
ReadableConfig config)
Adds python dependencies to registered cache file list according to given configuration and
returns a new configuration which contains the metadata of the registered python
dependencies.
|
static Configuration |
PythonConfigUtil.extractPythonConfiguration(List<Tuple2<String,DistributedCache.DistributedCacheEntry>> cachedFiles,
ReadableConfig config)
Extract the configurations which is used in the Python operators.
|
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 |
---|---|
static BufferDebloatConfiguration |
BufferDebloatConfiguration.fromConfiguration(ReadableConfig config) |
Modifier and Type | Method and Description |
---|---|
static Configuration |
MutableConfig.of(ReadableConfig config)
Creates a new
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 |
---|---|
void |
BeamPythonFunctionRunner.open(ReadableConfig config) |
Modifier and Type | Method and Description |
---|---|
static BeamStateRequestHandler |
BeamStateRequestHandler.of(KeyedStateBackend<?> keyedStateBackend,
OperatorStateBackend operatorStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
ReadableConfig config)
Create a
BeamStateRequestHandler . |
Constructor and Description |
---|
BeamMapStateHandler(ReadableConfig config) |
Constructor and Description |
---|
KinesisConnectorOptionsUtil(Map<String,String> options,
ReadableConfig tableOptions) |
Modifier and Type | Class and Description |
---|---|
class |
TableConfig
Configuration for the current
TableEnvironment session to adjust Table & SQL API
programs. |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
TableConfig.getRootConfiguration()
Gives direct access to the underlying environment-specific key-value map for advanced
configuration.
|
Modifier and Type | Method and Description |
---|---|
static EnvironmentSettings |
EnvironmentSettings.fromConfiguration(ReadableConfig configuration)
Deprecated.
|
void |
TableConfig.setRootConfiguration(ReadableConfig rootConfiguration)
Sets the given configuration as
TableConfig.rootConfiguration , which contains any configuration
set in the execution context. |
Modifier and Type | Method and Description |
---|---|
CatalogManager.Builder |
CatalogManager.Builder.config(ReadableConfig config) |
Constructor and Description |
---|
FunctionCatalog(ReadableConfig config,
ResourceManager resourceManager,
CatalogManager catalogManager,
ModuleManager moduleManager) |
ManagedTableListener(ClassLoader classLoader,
ReadableConfig config) |
Modifier and Type | Method and Description |
---|---|
static java.time.ZoneId |
CliUtils.getSessionTimeZone(ReadableConfig sessionConfig)
Get time zone from 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,
RowDataToStringConverter rowDataToStringConverter) |
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,
TableResultInternal tableResult)
Creates a result.
|
Modifier and Type | Method and Description |
---|---|
static DefaultLookupCache |
DefaultLookupCache.fromConfig(ReadableConfig config) |
Modifier and Type | Method and Description |
---|---|
static TimedCacheReloadTrigger |
TimedCacheReloadTrigger.fromConfig(ReadableConfig config) |
static PeriodicCacheReloadTrigger |
PeriodicCacheReloadTrigger.fromConfig(ReadableConfig config) |
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 |
ModuleFactory.Context.getConfiguration()
Gives read-only access to the configuration of the current session.
|
ReadableConfig |
CatalogFactory.Context.getConfiguration()
Gives read-only access to the configuration of the current session.
|
ReadableConfig |
DynamicTableFactory.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 |
TableSourceFactoryContextImpl.getConfiguration()
Deprecated.
|
ReadableConfig |
TableSinkFactory.Context.getConfiguration() |
ReadableConfig |
TableSourceFactory.Context.getConfiguration() |
ReadableConfig |
TableSinkFactoryContextImpl.getConfiguration()
Deprecated.
|
ReadableConfig |
FactoryUtil.FactoryHelper.getOptions()
Returns all options currently being consumed by the factory.
|
ReadableConfig |
FactoryUtil.TableFactoryHelper.getOptions()
Returns all options currently being consumed by the factory.
|
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.
|
DecodingFormat<I> |
DecodingFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
static DynamicTableSink |
FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory preferredFactory,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
Map<String,String> enrichmentOptions,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
static DynamicTableSink |
FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory preferredFactory,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
|
static DynamicTableSource |
FactoryUtil.createDynamicTableSource(DynamicTableSourceFactory preferredFactory,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
Map<String,String> enrichmentOptions,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSource from a CatalogTable . |
static DynamicTableSource |
FactoryUtil.createDynamicTableSource(DynamicTableSourceFactory preferredFactory,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
|
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)
|
static DynamicTableSource |
FactoryUtil.createTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
|
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 boolean |
TableFactoryUtil.isLegacyConnectorOptions(Catalog catalog,
ReadableConfig configuration,
boolean isStreamingMode,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
boolean isTemporary)
Checks whether the
CatalogTable uses legacy connector sink options. |
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,
Map<String,String> enrichmentOptions,
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)
Deprecated.
|
TableSourceFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isTemporary)
Deprecated.
|
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,
SpecializedFunction.ExpressionEvaluatorFactory evaluatorFactory)
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 |
---|---|
ReadableConfig |
SqlGatewayEndpointFactoryUtils.DefaultEndpointFactoryContext.getFlinkConfiguration() |
ReadableConfig |
SqlGatewayEndpointFactory.Context.getFlinkConfiguration()
Gives read-only access to the configuration of the current session.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.convertCollectToRel(FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
CollectModifyOperation collectModifyOperation,
ReadableConfig configuration,
ClassLoader classLoader)
Converts an
TableResult.collect() sink to a RelNode . |
static org.apache.calcite.rel.RelNode |
DynamicSourceUtils.convertDataStreamToRel(boolean isBatchMode,
ReadableConfig config,
FlinkRelBuilder relBuilder,
ContextResolvedTable contextResolvedTable,
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,
FlinkRelBuilder relBuilder,
ContextResolvedTable contextResolvedTable,
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(String tableDebugName,
ResolvedCatalogTable table,
DynamicTableSource source,
boolean isBatchMode,
ReadableConfig config)
Prepares the given
DynamicTableSource . |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ExecNodeConfig
Configuration view which is used combine the
PlannerBase.getTableConfig() with the ExecNodeBase.getPersistedConfig() configuration. |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
ExecNodeBase.getPersistedConfig() |
static <T extends ExecNode<?>> |
ExecNodeContext.newPersistedConfig(Class<T> execNodeClass,
ReadableConfig tableConfig)
Create a configuration for the
ExecNode , ready to be persisted to a JSON plan. |
Modifier and Type | Method and Description |
---|---|
protected String |
ExecNodeBase.createFormattedTransformationDescription(String description,
ReadableConfig config) |
protected String |
ExecNodeBase.createFormattedTransformationName(String detailName,
String simplifiedName,
ReadableConfig config) |
protected String |
ExecNodeBase.createTransformationDescription(ReadableConfig config) |
protected String |
ExecNodeBase.createTransformationName(ReadableConfig config) |
static <T extends ExecNode<?>> |
ExecNodeContext.newPersistedConfig(Class<T> execNodeClass,
ReadableConfig tableConfig)
Create a configuration for the
ExecNode , ready to be persisted to a JSON plan. |
static ExecNodeConfig |
ExecNodeConfig.ofNodeConfig(ReadableConfig nodeConfig,
boolean isCompiled) |
Constructor and Description |
---|
ExecNodeBase(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
Constructor and Description |
---|
BatchExecBoundedStreamScan(ReadableConfig tableConfig,
DataStream<?> dataStream,
DataType sourceType,
int[] fieldIndexes,
List<String> qualifiedName,
RowType outputType,
String description) |
BatchExecCalc(ReadableConfig tableConfig,
List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecCorrelate(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecDynamicFilteringDataCollector(List<Integer> dynamicFilteringFieldIndices,
ReadableConfig tableConfig,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecExchange(ReadableConfig tableConfig,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecExpand(ReadableConfig tableConfig,
List<List<org.apache.calcite.rex.RexNode>> projects,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecHashAggregate(ReadableConfig tableConfig,
int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
RowType aggInputRowType,
boolean isMerge,
boolean isFinal,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecHashJoin(ReadableConfig tableConfig,
JoinSpec joinSpec,
int estimatedLeftAvgRowSize,
int estimatedRightAvgRowSize,
long estimatedLeftRowCount,
long estimatedRightRowCount,
boolean leftIsBuild,
boolean tryDistinctBuildRow,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
BatchExecHashWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
int inputTimeFieldIndex,
boolean inputTimeIsDate,
NamedWindowProperty[] namedWindowProperties,
RowType aggInputRowType,
boolean enableAssignPane,
boolean isMerge,
boolean isFinal,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecLegacySink(ReadableConfig tableConfig,
TableSink<T> tableSink,
String[] upsertKeys,
InputProperty inputProperty,
LogicalType outputType,
String description) |
BatchExecLegacyTableSourceScan(ReadableConfig tableConfig,
TableSource<?> tableSource,
List<String> qualifiedName,
RowType outputType,
String description) |
BatchExecLimit(ReadableConfig tableConfig,
long limitStart,
long limitEnd,
boolean isGlobal,
InputProperty inputProperty,
LogicalType outputType,
String description) |
BatchExecLookupJoin(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
LookupJoinUtil.AsyncLookupOptions asyncLookupOptions,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecMatch(ReadableConfig tableConfig,
MatchSpec matchSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecMultipleInput(ReadableConfig tableConfig,
List<InputProperty> inputProperties,
ExecNode<?> rootNode,
List<ExecEdge> originalEdges,
String description) |
BatchExecNestedLoopJoin(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode condition,
boolean leftIsBuild,
boolean singleRowJoin,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
BatchExecOverAggregate(ReadableConfig tableConfig,
OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecOverAggregateBase(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonCalc(ReadableConfig tableConfig,
List<org.apache.calcite.rex.RexNode> projection,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonCorrelate(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonGroupAggregate(ReadableConfig tableConfig,
int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonGroupWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
int inputTimeFieldIndex,
NamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecPythonOverAggregate(ReadableConfig tableConfig,
OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecRank(ReadableConfig tableConfig,
int[] partitionFields,
int[] sortFields,
long rankStart,
long rankEnd,
boolean outputRankNumber,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecScriptTransform(ReadableConfig tableConfig,
InputProperty inputProperty,
LogicalType inputType,
LogicalType outputType,
String description,
int[] inputIndexes,
String script,
ScriptTransformIOInfo scriptTransformIOInfo) |
BatchExecSink(ReadableConfig tableConfig,
DynamicTableSinkSpec tableSinkSpec,
InputProperty inputProperty,
LogicalType outputType,
String description) |
BatchExecSort(ReadableConfig tableConfig,
SortSpec sortSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecSortAggregate(ReadableConfig tableConfig,
int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
RowType aggInputRowType,
boolean isMerge,
boolean isFinal,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecSortLimit(ReadableConfig tableConfig,
SortSpec sortSpec,
long limitStart,
long limitEnd,
boolean isGlobal,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecSortMergeJoin(ReadableConfig tableConfig,
FlinkJoinType joinType,
int[] leftKeys,
int[] rightKeys,
boolean[] filterNulls,
org.apache.calcite.rex.RexNode nonEquiCondition,
boolean leftIsSmaller,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
BatchExecSortWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
int[] auxGrouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
int inputTimeFieldIndex,
boolean inputTimeIsDate,
NamedWindowProperty[] namedWindowProperties,
RowType aggInputRowType,
boolean enableAssignPane,
boolean isMerge,
boolean isFinal,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecTableSourceScan(ReadableConfig tableConfig,
DynamicTableSourceSpec tableSourceSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
BatchExecTableSourceScan(ReadableConfig tableConfig,
DynamicTableSourceSpec tableSourceSpec,
RowType outputType,
String description) |
BatchExecUnion(ReadableConfig tableConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
BatchExecValues(ReadableConfig tableConfig,
List<List<RexLiteral>> tuples,
RowType outputType,
String description) |
BatchExecWindowTableFunction(ReadableConfig tableConfig,
TimeAttributeWindowingStrategy windowingStrategy,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
static Tuple2<Pattern<RowData,RowData>,List<String>> |
CommonExecMatch.translatePattern(MatchSpec matchSpec,
ReadableConfig config,
ClassLoader classLoader,
org.apache.calcite.tools.RelBuilder relBuilder,
RowType inputRowType) |
Constructor and Description |
---|
CommonExecCalc(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
Class<?> operatorBaseClass,
boolean retainHeader,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
Class<?> operatorBaseClass,
boolean retainHeader,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecExchange(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecExpand(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<List<org.apache.calcite.rex.RexNode>> projects,
boolean retainHeader,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecLegacySink(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
boolean isStreaming,
InputProperty inputProperty,
LogicalType outputType,
String description) |
CommonExecLegacyTableSourceScan(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TableSource<?> tableSource,
List<String> qualifiedName,
RowType outputType,
String description) |
CommonExecLookupJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
LookupJoinUtil.AsyncLookupOptions asyncLookupOptions,
LookupJoinUtil.RetryLookupOptions retryOptions,
ChangelogMode inputChangelogMode,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecMatch(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
MatchSpec matchSpec,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
CommonExecPythonCalc(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<org.apache.calcite.rex.RexNode> projection,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecPythonCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecSink(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
boolean isBounded,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
CommonExecTableSourceScan(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSourceSpec tableSourceSpec,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
CommonExecUnion(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
CommonExecValues(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<List<RexLiteral>> tuples,
RowType outputType,
String description) |
CommonExecWindowTableFunction(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TimeAttributeWindowingStrategy windowingStrategy,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Constructor and Description |
---|
InputPriorityConflictResolver(List<ExecNode<?>> roots,
InputProperty.DamBehavior safeDamBehavior,
StreamExchangeMode exchangeMode,
ReadableConfig tableConfig)
Create a
InputPriorityConflictResolver for the given ExecNode graph. |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
SerdeContext.getConfiguration() |
Constructor and Description |
---|
StreamExecAggregateBase(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
StreamExecCalc(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecCalc(ReadableConfig tableConfig,
List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecChangelogNormalize(Integer id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] uniqueKeys,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecChangelogNormalize(ReadableConfig tableConfig,
int[] uniqueKeys,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode invocation,
org.apache.calcite.rex.RexNode condition,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecCorrelate(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecDataStreamScan(ReadableConfig tableConfig,
DataStream<?> dataStream,
DataType sourceType,
int[] fieldIndexes,
String[] fieldNames,
List<String> qualifiedName,
RowType outputType,
String description) |
StreamExecDeduplicate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] uniqueKeys,
boolean isRowtime,
boolean keepLastRow,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecDeduplicate(ReadableConfig tableConfig,
int[] uniqueKeys,
boolean isRowtime,
boolean keepLastRow,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecDropUpdateBefore(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecDropUpdateBefore(ReadableConfig tableConfig,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecExchange(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecExchange(ReadableConfig tableConfig,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecExpand(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<List<org.apache.calcite.rex.RexNode>> projects,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecExpand(ReadableConfig tableConfig,
List<List<org.apache.calcite.rex.RexNode>> projects,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGlobalGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
RowType localAggInputRowType,
boolean generateUpdateBefore,
boolean needRetraction,
Integer indexOfCountStar,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecGlobalGroupAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
RowType localAggInputRowType,
boolean generateUpdateBefore,
boolean needRetraction,
Integer indexOfCountStar,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGlobalWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
List<InputProperty> inputProperties,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecGlobalWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecGroupAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGroupTableAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGroupWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
NamedWindowProperty[] namedWindowProperties,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecGroupWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
NamedWindowProperty[] namedWindowProperties,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecIncrementalGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] partialAggGrouping,
int[] finalAggGrouping,
org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls,
boolean[] partialAggCallNeedRetractions,
RowType partialLocalAggInputType,
boolean partialAggNeedRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecIncrementalGroupAggregate(ReadableConfig tableConfig,
int[] partialAggGrouping,
int[] finalAggGrouping,
org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls,
boolean[] partialAggCallNeedRetractions,
RowType partialLocalAggInputType,
boolean partialAggNeedRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecIntervalJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
IntervalJoinSpec intervalJoinSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecIntervalJoin(ReadableConfig tableConfig,
IntervalJoinSpec intervalJoinSpec,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
JoinSpec joinSpec,
List<int[]> leftUpsertKeys,
List<int[]> rightUpsertKeys,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecJoin(ReadableConfig tableConfig,
JoinSpec joinSpec,
List<int[]> leftUpsertKeys,
List<int[]> rightUpsertKeys,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecLegacySink(ReadableConfig tableConfig,
TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
InputProperty inputProperty,
LogicalType outputType,
String description) |
StreamExecLegacyTableSourceScan(ReadableConfig tableConfig,
TableSource<?> tableSource,
List<String> qualifiedName,
RowType outputType,
String description) |
StreamExecLimit(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLimit(ReadableConfig tableConfig,
long limitStart,
long limitEnd,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecLocalGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLocalGroupAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecLocalWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLocalWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecLookupJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
boolean lookupKeyContainsPrimaryKey,
boolean upsertMaterialize,
LookupJoinUtil.AsyncLookupOptions asyncLookupOptions,
LookupJoinUtil.RetryLookupOptions retryOptions,
ChangelogMode inputChangelogMode,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecLookupJoin(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode joinCondition,
TemporalTableSourceSpec temporalTableSourceSpec,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable,
org.apache.calcite.rex.RexNode filterOnTemporalTable,
boolean lookupKeyContainsPrimaryKey,
boolean upsertMaterialize,
LookupJoinUtil.AsyncLookupOptions asyncLookupOptions,
LookupJoinUtil.RetryLookupOptions retryOptions,
ChangelogMode inputChangelogMode,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecMatch(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
MatchSpec matchSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecMatch(ReadableConfig tableConfig,
MatchSpec matchSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecMiniBatchAssigner(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
MiniBatchInterval miniBatchInterval,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecMiniBatchAssigner(ReadableConfig tableConfig,
MiniBatchInterval miniBatchInterval,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecMultipleInput(ReadableConfig tableConfig,
List<InputProperty> inputProperties,
ExecNode<?> rootNode,
String description) |
StreamExecOverAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
OverSpec overSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecOverAggregate(ReadableConfig tableConfig,
OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonCalc(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<org.apache.calcite.rex.RexNode> projection,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonCalc(ReadableConfig tableConfig,
List<org.apache.calcite.rex.RexNode> projection,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonCorrelate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexNode invocation,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonCorrelate(ReadableConfig tableConfig,
FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonGroupAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonGroupTableAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonGroupWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
NamedWindowProperty[] namedWindowProperties,
boolean generateUpdateBefore,
boolean needRetraction,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonGroupWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
NamedWindowProperty[] namedWindowProperties,
boolean generateUpdateBefore,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonOverAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
OverSpec overSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecPythonOverAggregate(ReadableConfig tableConfig,
OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecRank(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
RankProcessStrategy rankStrategy,
boolean outputRankNumber,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecRank(ReadableConfig tableConfig,
RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
RankProcessStrategy rankStrategy,
boolean outputRankNumber,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecSink(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
List<InputProperty> inputProperties,
LogicalType outputType,
boolean upsertMaterialize,
int[] inputUpsertKey,
String description) |
StreamExecSink(ReadableConfig tableConfig,
DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
InputProperty inputProperty,
LogicalType outputType,
boolean upsertMaterialize,
int[] inputUpsertKey,
String description) |
StreamExecSort(ReadableConfig tableConfig,
SortSpec sortSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecSortLimit(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
SortSpec sortSpec,
ConstantRankRange rankRange,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecSortLimit(ReadableConfig tableConfig,
SortSpec sortSpec,
long limitStart,
long limitEnd,
RankProcessStrategy rankStrategy,
boolean generateUpdateBefore,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecTableSourceScan(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
DynamicTableSourceSpec tableSourceSpec,
RowType outputType,
String description) |
StreamExecTableSourceScan(ReadableConfig tableConfig,
DynamicTableSourceSpec tableSourceSpec,
RowType outputType,
String description) |
StreamExecTemporalJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
JoinSpec joinSpec,
boolean isTemporalTableFunctionJoin,
int leftTimeAttributeIndex,
int rightTimeAttributeIndex,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecTemporalJoin(ReadableConfig tableConfig,
JoinSpec joinSpec,
boolean isTemporalTableFunctionJoin,
int leftTimeAttributeIndex,
int rightTimeAttributeIndex,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecTemporalSort(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
SortSpec sortSpec,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecTemporalSort(ReadableConfig tableConfig,
SortSpec sortSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecUnion(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecUnion(ReadableConfig tableConfig,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecValues(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<List<RexLiteral>> tuples,
RowType outputType,
String description) |
StreamExecValues(ReadableConfig tableConfig,
List<List<RexLiteral>> tuples,
RowType outputType,
String description) |
StreamExecWatermarkAssigner(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
org.apache.calcite.rex.RexNode watermarkExpr,
int rowtimeFieldIndex,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWatermarkAssigner(ReadableConfig tableConfig,
org.apache.calcite.rex.RexNode watermarkExpr,
int rowtimeFieldIndex,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowAggregate(ReadableConfig tableConfig,
int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
NamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowAggregateBase(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
StreamExecWindowDeduplicate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] partitionKeys,
int orderKey,
boolean keepLastRow,
WindowingStrategy windowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowDeduplicate(ReadableConfig tableConfig,
int[] partitionKeys,
int orderKey,
boolean keepLastRow,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
JoinSpec joinSpec,
WindowingStrategy leftWindowing,
WindowingStrategy rightWindowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowJoin(ReadableConfig tableConfig,
JoinSpec joinSpec,
WindowingStrategy leftWindowing,
WindowingStrategy rightWindowing,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecWindowRank(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
boolean outputRankNumber,
WindowingStrategy windowing,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowRank(ReadableConfig tableConfig,
RankType rankType,
PartitionSpec partitionSpec,
SortSpec sortSpec,
RankRange rankRange,
boolean outputRankNumber,
WindowingStrategy windowing,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecWindowTableFunction(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TimeAttributeWindowingStrategy windowingStrategy,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowTableFunction(ReadableConfig tableConfig,
TimeAttributeWindowingStrategy windowingStrategy,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
static Configuration |
CommonPythonUtil.extractPythonConfiguration(StreamExecutionEnvironment env,
ReadableConfig tableConfig,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
static <T extends ExecNode<?>> |
ExecNodeMetadataUtil.newPersistedConfig(Class<T> execNodeClass,
ReadableConfig tableConfig,
java.util.stream.Stream<ConfigOption<?>> configOptions) |
Modifier and Type | Method and Description |
---|---|
static <T extends ExecNode<?>> |
ExecNodeMetadataUtil.newPersistedConfig(Class<T> execNodeClass,
ReadableConfig tableConfig,
java.util.stream.Stream<ConfigOption<?>> configOptions) |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
DummyStreamExecutionEnvironment.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
static AggregatePhaseStrategy |
TableConfigUtils.getAggPhaseStrategy(ReadableConfig tableConfig)
Returns the aggregate phase strategy configuration.
|
static StreamExchangeMode |
StreamExchangeModeUtils.getBatchStreamExchangeMode(ReadableConfig config,
StreamExchangeMode requiredExchangeMode) |
static java.time.ZoneId |
TableConfigUtils.getLocalTimeZone(ReadableConfig tableConfig)
Similar to
TableConfig.getLocalTimeZone() but extracting it from a generic ReadableConfig . |
static long |
TableConfigUtils.getMaxIdleStateRetentionTime(ReadableConfig tableConfig)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static ResourceManager |
ResourceManager.createResourceManager(URL[] urls,
ClassLoader parent,
ReadableConfig config) |
Constructor and Description |
---|
ResourceManager(ReadableConfig config,
MutableURLClassLoader userClassLoader) |
Constructor and Description |
---|
GeneratedAggsHandleFunction(String className,
String code,
Object[] references,
ReadableConfig conf) |
GeneratedClass(String className,
String code,
Object[] references,
ReadableConfig config) |
GeneratedCollector(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedCollector.
|
GeneratedFunction(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedFunction.
|
GeneratedHashFunction(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedHashFunction.
|
GeneratedInput(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedInput.
|
GeneratedJoinCondition(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedJoinCondition.
|
GeneratedNamespaceAggsHandleFunction(String className,
String code,
Object[] references,
ReadableConfig conf) |
GeneratedNamespaceTableAggsHandleFunction(String className,
String code,
Object[] references,
ReadableConfig conf) |
GeneratedNormalizedKeyComputer(String className,
String code,
ReadableConfig config)
Creates a GeneratedNormalizedKeyComputer.
|
GeneratedOperator(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedOperator.
|
GeneratedProjection(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedProjection.
|
GeneratedRecordComparator(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedRecordComparator.
|
GeneratedRecordEqualiser(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedRecordEqualiser.
|
GeneratedResultFuture(String className,
String code,
Object[] references,
ReadableConfig conf)
Creates a GeneratedResultFuture.
|
GeneratedTableAggsHandleFunction(String className,
String code,
Object[] references,
ReadableConfig conf) |
GeneratedWatermarkGenerator(String className,
String code,
Object[] references,
ReadableConfig conf) |
Modifier and Type | Method and Description |
---|---|
static MutableURLClassLoader |
FlinkUserCodeClassLoaders.create(URL[] urls,
ClassLoader parent,
ReadableConfig config) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.