Modifier and Type | Field and Description |
---|---|
protected ExecutionConfig |
Plan.executionConfig
Config object for runtime execution parameters.
|
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
ExecutionConfig.disableClosureCleaner()
Disables the ClosureCleaner.
|
ExecutionConfig |
ExecutionConfig.disableObjectReuse()
Disables reusing objects that Flink internally uses for deserialization and passing data to
user-code functions.
|
ExecutionConfig |
ExecutionConfig.disableSysoutLogging()
Deprecated.
Ineffective. Will be removed at 2.0.
|
ExecutionConfig |
ExecutionConfig.enableClosureCleaner()
Enables the ClosureCleaner.
|
ExecutionConfig |
ExecutionConfig.enableObjectReuse()
Enables reusing objects that Flink internally uses for deserialization and passing data to
user-code functions.
|
ExecutionConfig |
ExecutionConfig.enableSysoutLogging()
Deprecated.
Ineffective. Will be removed at 2.0.
|
ExecutionConfig |
Plan.getExecutionConfig()
Gets the execution config object.
|
ExecutionConfig |
ExecutionConfig.setAutoWatermarkInterval(long interval)
Sets the interval of the automatic watermark emission.
|
ExecutionConfig |
ExecutionConfig.setClosureCleanerLevel(ExecutionConfig.ClosureCleanerLevel level)
Configures the closure cleaner.
|
ExecutionConfig |
ExecutionConfig.setExecutionRetryDelay(long executionRetryDelay)
Deprecated.
This method will be replaced by
setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration) . The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the delay between
successive execution attempts. |
ExecutionConfig |
ExecutionConfig.setLatencyTrackingInterval(long interval)
Interval for sending latency tracking marks from the sources to the sinks.
|
ExecutionConfig |
ExecutionConfig.setNumberOfExecutionRetries(int numberOfExecutionRetries)
Deprecated.
This method will be replaced by
setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration) . The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the number of
execution retries. |
ExecutionConfig |
ExecutionConfig.setParallelism(int parallelism)
Sets the parallelism for operations executed through this environment.
|
ExecutionConfig |
ExecutionConfig.setTaskCancellationInterval(long interval)
Sets the configuration parameter specifying the interval (in milliseconds) between
consecutive attempts to cancel a running task.
|
ExecutionConfig |
ExecutionConfig.setTaskCancellationTimeout(long timeout)
Sets the timeout (in milliseconds) after which an ongoing task cancellation is considered
failed, leading to a fatal TaskManager error.
|
Modifier and Type | Method and Description |
---|---|
void |
Plan.setExecutionConfig(ExecutionConfig executionConfig)
Sets the runtime config object defining execution parameters.
|
Constructor and Description |
---|
ArchivedExecutionConfig(ExecutionConfig ec) |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
RuntimeContext.getExecutionConfig()
Returns the
ExecutionConfig for the currently executing
job. |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
AbstractRuntimeUDFContext.getExecutionConfig() |
Constructor and Description |
---|
AbstractRuntimeUDFContext(TaskInfo taskInfo,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
Map<String,Accumulator<?,?>> accumulators,
Map<String,Future<Path>> cpTasks,
MetricGroup metrics) |
RuntimeUDFContext(TaskInfo taskInfo,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
Map<String,Future<Path>> cpTasks,
Map<String,Accumulator<?,?>> accumulators,
MetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
protected abstract List<OUT> |
SingleInputOperator.executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected void |
GenericDataSinkBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected abstract List<OUT> |
DualInputOperator.executeOnCollections(List<IN1> inputData1,
List<IN2> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<T> |
Union.executeOnCollections(List<T> inputData1,
List<T> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
GenericDataSourceBase.executeOnCollections(RuntimeContext ctx,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
CollectionExecutor(ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
protected List<OUT> |
GroupReduceOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<IN> |
PartitionOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
MapPartitionOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
MapOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<IN> |
SortPartitionOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
GroupCombineOperatorBase.executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
FlatMapOperatorBase.executeOnCollections(List<IN> input,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
InnerJoinOperatorBase.executeOnCollections(List<IN1> inputData1,
List<IN2> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
CoGroupRawOperatorBase.executeOnCollections(List<IN1> input1,
List<IN2> input2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
OuterJoinOperatorBase.executeOnCollections(List<IN1> leftInput,
List<IN2> rightInput,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
CoGroupOperatorBase.executeOnCollections(List<IN1> input1,
List<IN2> input2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<OUT> |
CrossOperatorBase.executeOnCollections(List<IN1> inputData1,
List<IN2> inputData2,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<ST> |
DeltaIterationBase.executeOnCollections(List<ST> inputData1,
List<WT> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<T> |
BulkIterationBase.executeOnCollections(List<T> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<T> |
ReduceOperatorBase.executeOnCollections(List<T> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
protected List<T> |
FilterOperatorBase.executeOnCollections(List<T> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
TypeInformationSerializationSchema(TypeInformation<T> typeInfo,
ExecutionConfig ec)
Creates a new de-/serialization schema for the given type.
|
Modifier and Type | Method and Description |
---|---|
void |
StateDescriptor.initializeSerializerUnlessSet(ExecutionConfig executionConfig)
Initializes the serializer, unless it has been initialized before.
|
Modifier and Type | Method and Description |
---|---|
TypeComparator<T> |
LocalTimeTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
SqlTimeTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
BasicTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
PrimitiveArrayComparator<T,?> |
PrimitiveArrayTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
AtomicType.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig)
Creates a comparator for this type.
|
TypeSerializer<T> |
LocalTimeTypeInfo.createSerializer(ExecutionConfig executionConfig) |
abstract TypeSerializer<T> |
TypeInformation.createSerializer(ExecutionConfig config)
Creates a serializer for the type.
|
TypeSerializer<T> |
SqlTimeTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<Nothing> |
NothingTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
BasicArrayTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
BasicTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
PrimitiveArrayTypeInfo.createSerializer(ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<T> |
CompositeType.createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config)
Generic implementation of the comparator creation.
|
TypeComparator<T> |
CompositeType.TypeComparatorBuilder.createTypeComparator(ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
ExecutionEnvironment.getConfig()
Gets the config object that defines execution parameters.
|
Modifier and Type | Method and Description |
---|---|
void |
CsvOutputFormat.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
The purpose of this method is solely to check whether the data type to be processed is in
fact a tuple type.
|
void |
TypeSerializerOutputFormat.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig) |
void |
LocalCollectionOutputFormat.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
PlanProjectOperator(int[] fields,
String name,
TypeInformation<T> inType,
TypeInformation<R> outType,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
abstract void |
AvroUtils.addAvroSerializersIfRequired(ExecutionConfig reg,
Class<?> type)
Loads the utility class from
flink-avro and adds Avro-specific serializers. |
TypeComparator<T> |
WritableTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
GenericTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
EnumTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
ValueTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<Row> |
RowTypeInfo.createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config) |
TypeSerializer<Row> |
RowTypeInfo.createLegacySerializer(ExecutionConfig config)
Deprecated.
|
PojoSerializer<T> |
PojoTypeInfo.createPojoSerializer(ExecutionConfig config) |
TypeSerializer<T> |
WritableTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
GenericTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<Either<L,R>> |
EitherTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<Row> |
RowTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
ObjectArrayTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
PojoTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<Map<K,V>> |
MapTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
EnumTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<List<T>> |
ListTypeInfo.createSerializer(ExecutionConfig config) |
TupleSerializer<T> |
TupleTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<InvalidTypesException> |
MissingTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
ValueTypeInfo.createSerializer(ExecutionConfig executionConfig) |
void |
InputTypeConfigurable.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
Method that is called on an
OutputFormat when it is
passed to the DataSet's output method. |
Constructor and Description |
---|
PojoSerializer(Class<T> clazz,
TypeSerializer<?>[] fieldSerializers,
Field[] fields,
ExecutionConfig executionConfig)
Constructor to create a new
PojoSerializer . |
Modifier and Type | Method and Description |
---|---|
static void |
Serializers.recursivelyRegisterType(Class<?> type,
ExecutionConfig config,
Set<Class<?>> alreadySeen) |
static void |
Serializers.recursivelyRegisterType(TypeInformation<?> typeInfo,
ExecutionConfig config,
Set<Class<?>> alreadySeen) |
Constructor and Description |
---|
KryoSerializer(Class<T> type,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
PlanGenerator(List<DataSink<?>> sinks,
ExecutionConfig config,
int defaultParallelism,
List<Tuple2<String,DistributedCache.DistributedCacheEntry>> cacheFile,
String jobName) |
Modifier and Type | Method and Description |
---|---|
void |
ScalaCsvOutputFormat.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
The purpose of this method is solely to check whether the data type to be processed is in
fact a tuple type.
|
Constructor and Description |
---|
RocksDBKeyedStateBackend(ClassLoader userCodeClassLoader,
File instanceBasePath,
RocksDBResourceContainer optionsContainer,
java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
org.rocksdb.RocksDB db,
LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
int keyGroupPrefixBytes,
CloseableRegistry cancelStreamRegistry,
StreamCompressionDecorator keyGroupCompressionDecorator,
ResourceGuard rocksDBResourceGuard,
RocksDBSnapshotStrategyBase<K> checkpointSnapshotStrategy,
RocksDBSnapshotStrategyBase<K> savepointSnapshotStrategy,
RocksDBWriteBatchWrapper writeBatchWrapper,
org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle,
RocksDBNativeMetricMonitor nativeMetricMonitor,
org.apache.flink.contrib.streaming.state.RocksDBSerializedCompositeKeyBuilder<K> sharedRocksKeyBuilder,
PriorityQueueSetFactory priorityQueueFactory,
RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
InternalKeyContext<K> keyContext,
long writeBatchSize) |
RocksDBKeyedStateBackendBuilder(String operatorIdentifier,
ClassLoader userCodeClassLoader,
File instanceBasePath,
RocksDBResourceContainer optionsContainer,
java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig,
LocalRecoveryConfig localRecoveryConfig,
RocksDBStateBackend.PriorityQueueStateType priorityQueueStateType,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
StreamCompressionDecorator keyGroupCompressionDecorator,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<org.apache.avro.generic.GenericRecord> |
GenericRecordAvroTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
AvroTypeInfo.createSerializer(ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
AvroKryoSerializerUtils.addAvroSerializersIfRequired(ExecutionConfig reg,
Class<?> type) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<LongValueWithProperHashCode> |
LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeSerializer<LongValueWithProperHashCode> |
LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfo.createSerializer(ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<ValueArray<T>> |
ValueArrayTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeSerializer<ValueArray<T>> |
ValueArrayTypeInfo.createSerializer(ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
protected List<OUT> |
NoOpBinaryUdfOp.executeOnCollections(List<OUT> inputData1,
List<OUT> inputData2,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
protected List<OUT> |
NoOpUnaryUdfOp.executeOnCollections(List<OUT> inputData,
RuntimeContext runtimeContext,
ExecutionConfig executionConfig) |
static TypeComparatorFactory<?> |
Utils.getShipComparator(Channel channel,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
QueryableStateClient.getExecutionConfig()
Gets the
ExecutionConfig . |
ExecutionConfig |
QueryableStateClient.setExecutionConfig(ExecutionConfig config)
Replaces the existing
ExecutionConfig (possibly null ), with the provided one. |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<VoidNamespace> |
VoidNamespaceTypeInfo.createSerializer(ExecutionConfig config) |
ExecutionConfig |
QueryableStateClient.setExecutionConfig(ExecutionConfig config)
Replaces the existing
ExecutionConfig (possibly null ), with the provided one. |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
Environment.getExecutionConfig()
Returns the job specific
ExecutionConfig . |
Modifier and Type | Method and Description |
---|---|
SerializedValue<ExecutionConfig> |
JobInformation.getSerializedExecutionConfig() |
Constructor and Description |
---|
JobInformation(JobID jobId,
String jobName,
SerializedValue<ExecutionConfig> serializedExecutionConfig,
Configuration jobConfiguration,
Collection<PermanentBlobKey> requiredJarFileBlobKeys,
Collection<URL> requiredClasspathURLs) |
Modifier and Type | Method and Description |
---|---|
SerializedValue<ExecutionConfig> |
JobGraph.getSerializedExecutionConfig()
Returns the
ExecutionConfig |
Modifier and Type | Method and Description |
---|---|
void |
JobGraph.setExecutionConfig(ExecutionConfig executionConfig)
Sets the execution config.
|
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
AbstractInvokable.getExecutionConfig()
Returns the global ExecutionConfig.
|
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
TaskContext.getExecutionConfig() |
Modifier and Type | Method and Description |
---|---|
static <T> Collector<T> |
BatchTask.initOutputs(AbstractInvokable containingTask,
ClassLoader cl,
TaskConfig config,
List<ChainedDriver<?,?>> chainedTasksTarget,
List<RecordWriter<?>> eventualOutputs,
ExecutionConfig executionConfig,
Map<String,Accumulator<?,?>> accumulatorMap)
Creates a writer for each output.
|
Modifier and Type | Field and Description |
---|---|
protected ExecutionConfig |
ChainedDriver.executionConfig |
Modifier and Type | Method and Description |
---|---|
void |
ChainedDriver.setup(TaskConfig config,
String taskName,
Collector<OT> outputCollector,
AbstractInvokable parent,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
Map<String,Accumulator<?,?>> accumulatorMap) |
Constructor and Description |
---|
DistributedRuntimeUDFContext(TaskInfo taskInfo,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
Map<String,Future<Path>> cpTasks,
Map<String,Accumulator<?,?>> accumulators,
MetricGroup metrics,
ExternalResourceInfoProvider externalResourceInfoProvider) |
Modifier and Type | Field and Description |
---|---|
protected ExecutionConfig |
AbstractKeyedStateBackendBuilder.executionConfig |
protected ExecutionConfig |
DefaultKeyedStateStore.executionConfig |
protected ExecutionConfig |
DefaultOperatorStateBackendBuilder.executionConfig
The execution configuration.
|
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
DefaultOperatorStateBackend.getExecutionConfig() |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<VoidNamespace> |
VoidNamespaceTypeInfo.createSerializer(ExecutionConfig config) |
static StreamCompressionDecorator |
AbstractStateBackend.getCompressionDecorator(ExecutionConfig executionConfig) |
Constructor and Description |
---|
HeapKeyedStateBackend(TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
CloseableRegistry cancelStreamRegistry,
StreamCompressionDecorator keyGroupCompressionDecorator,
Map<String,StateTable<K,?,?>> registeredKVStates,
Map<String,HeapPriorityQueueSnapshotRestoreWrapper> registeredPQStates,
LocalRecoveryConfig localRecoveryConfig,
HeapPriorityQueueSetFactory priorityQueueSetFactory,
org.apache.flink.runtime.state.heap.HeapSnapshotStrategy<K> snapshotStrategy,
InternalKeyContext<K> keyContext) |
HeapKeyedStateBackendBuilder(TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
ClassLoader userCodeClassLoader,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
Collection<KeyedStateHandle> stateHandles,
StreamCompressionDecorator keyGroupCompressionDecorator,
LocalRecoveryConfig localRecoveryConfig,
HeapPriorityQueueSetFactory priorityQueueSetFactory,
boolean asynchronousSnapshots,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
RuntimeEnvironment.getExecutionConfig() |
Constructor and Description |
---|
RuntimeEnvironment(JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
ExecutionConfig executionConfig,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
ClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
TaskStateManager taskStateManager,
GlobalAggregateManager aggregateManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
IndexedInputGate[] inputGates,
TaskEventDispatcher taskEventDispatcher,
CheckpointResponder checkpointResponder,
TaskOperatorEventGateway operatorEventGateway,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask,
ExternalResourceInfoProvider externalResourceInfoProvider) |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
StateReaderOperator.getExecutionConfig() |
Modifier and Type | Method and Description |
---|---|
void |
StateReaderOperator.setup(ExecutionConfig executionConfig,
KeyedStateBackend<KEY> keyKeyedStateBackend,
InternalTimeServiceManager<KEY> timerServiceManager,
SavepointRuntimeContext ctx) |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
SavepointEnvironment.getExecutionConfig() |
ExecutionConfig |
SavepointRuntimeContext.getExecutionConfig() |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
DataStream.getExecutionConfig() |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
StreamExecutionEnvironment.getConfig()
Gets the config object.
|
Constructor and Description |
---|
ComparableAggregator(int positionToAggregate,
TypeInformation<T> typeInfo,
AggregationFunction.AggregationType aggregationType,
boolean first,
ExecutionConfig config) |
ComparableAggregator(int positionToAggregate,
TypeInformation<T> typeInfo,
AggregationFunction.AggregationType aggregationType,
ExecutionConfig config) |
ComparableAggregator(String field,
TypeInformation<T> typeInfo,
AggregationFunction.AggregationType aggregationType,
boolean first,
ExecutionConfig config) |
SumAggregator(int pos,
TypeInformation<T> typeInfo,
ExecutionConfig config) |
SumAggregator(String field,
TypeInformation<T> typeInfo,
ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
OutputFormatSinkFunction.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ContinuousFileReaderOperator.setOutputType(TypeInformation<OUT> outTypeInfo,
ExecutionConfig executionConfig) |
void |
ContinuousFileReaderOperatorFactory.setOutputType(TypeInformation<OUT> type,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
ContinuousFileReaderOperatorFactory(InputFormat<OUT,? super T> inputFormat,
TypeInformation<OUT> type,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
void |
FoldApplyProcessAllWindowFunction.setOutputType(TypeInformation<R> outTypeInfo,
ExecutionConfig executionConfig)
Deprecated.
|
void |
FoldApplyWindowFunction.setOutputType(TypeInformation<R> outTypeInfo,
ExecutionConfig executionConfig)
Deprecated.
|
void |
FoldApplyProcessWindowFunction.setOutputType(TypeInformation<R> outTypeInfo,
ExecutionConfig executionConfig)
Deprecated.
|
void |
FoldApplyAllWindowFunction.setOutputType(TypeInformation<R> outTypeInfo,
ExecutionConfig executionConfig)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
StreamGraph.getExecutionConfig() |
Constructor and Description |
---|
StreamGraph(ExecutionConfig executionConfig,
CheckpointConfig checkpointConfig,
SavepointRestoreSettings savepointRestoreSettings) |
StreamGraphGenerator(List<Transformation<?>> transformations,
ExecutionConfig executionConfig,
CheckpointConfig checkpointConfig) |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
AbstractStreamOperator.getExecutionConfig()
Gets the execution config defined on the execution environment of the job to which this
operator belongs.
|
ExecutionConfig |
AbstractStreamOperatorV2.getExecutionConfig()
Gets the execution config defined on the execution environment of the job to which this
operator belongs.
|
Constructor and Description |
---|
StreamOperatorStateHandler(StreamOperatorStateContext context,
ExecutionConfig executionConfig,
CloseableRegistry closeableRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
SequenceFileWriter.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
Deprecated.
|
void |
AvroKeyValueSinkWriter.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
BucketingSink.setInputType(TypeInformation<?> type,
ExecutionConfig executionConfig)
Deprecated.
|
Constructor and Description |
---|
AbstractPerWindowStateStore(KeyedStateBackend<?> keyedStateBackend,
ExecutionConfig executionConfig) |
MergingWindowStateStore(KeyedStateBackend<?> keyedStateBackend,
ExecutionConfig executionConfig) |
PerWindowStateStore(KeyedStateBackend<?> keyedStateBackend,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
SingleThreadAccessCheckingTypeInfo.createSerializer(ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
static <T> void |
StreamingFunctionUtils.setOutputType(Function userFunction,
TypeInformation<T> outTypeInfo,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
static <X> KeySelector<X,Tuple> |
KeySelectorUtil.getSelectorForKeys(Keys<X> keys,
TypeInformation<X> typeInfo,
ExecutionConfig executionConfig) |
static <X,K> KeySelector<X,K> |
KeySelectorUtil.getSelectorForOneKey(Keys<X> keys,
Partitioner<K> partitioner,
TypeInformation<X> typeInfo,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
TypeInformationKeyValueSerializationSchema(Class<K> keyClass,
Class<V> valueClass,
ExecutionConfig config)
Creates a new de-/serialization schema for the given types.
|
TypeInformationKeyValueSerializationSchema(TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
ExecutionConfig ec)
Creates a new de-/serialization schema for the given types.
|
TypeInformationSerializationSchema(TypeInformation<T> typeInfo,
ExecutionConfig ec)
Deprecated.
Creates a new de-/serialization schema for the given type.
|
Modifier and Type | Method and Description |
---|---|
static <T,F> FieldAccessor<T,F> |
FieldAccessorFactory.getAccessor(TypeInformation<T> typeInfo,
int pos,
ExecutionConfig config)
Creates a
FieldAccessor for the given field position, which can be used to get and
set the specified field on instances of this type. |
static <T,F> FieldAccessor<T,F> |
FieldAccessorFactory.getAccessor(TypeInformation<T> typeInfo,
String field,
ExecutionConfig config)
Creates a
FieldAccessor for the field that is given by a field expression, which can
be used to get and set the specified field on instances of this type. |
Modifier and Type | Method and Description |
---|---|
CatalogManager.Builder |
CatalogManager.Builder.executionConfig(ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
ExecutionContext.getExecutionConfig() |
Modifier and Type | Method and Description |
---|---|
<T> DynamicResult<T> |
ResultStore.createResult(Environment env,
TableSchema schema,
ExecutionConfig config,
ClassLoader classLoader)
Creates a result.
|
Constructor and Description |
---|
ChangelogCollectStreamResult(TableSchema tableSchema,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort,
ClassLoader classLoader) |
CollectStreamResult(TableSchema tableSchema,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort,
ClassLoader classLoader) |
MaterializedCollectBatchResult(TableSchema tableSchema,
ExecutionConfig config,
ClassLoader classLoader) |
MaterializedCollectStreamResult(TableSchema tableSchema,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort,
int maxRowCount,
ClassLoader classLoader) |
MaterializedCollectStreamResult(TableSchema tableSchema,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort,
int maxRowCount,
int overcommitThreshold,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<MapView<K,V>> |
MapViewTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<ListView<T>> |
ListViewTypeInfo.createSerializer(ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
DummyStreamExecutionEnvironment.getConfig() |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<TimeWindow> |
SessionWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<TimeWindow> |
SlidingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
abstract TypeSerializer<W> |
WindowAssigner.getWindowSerializer(ExecutionConfig executionConfig)
Returns a
TypeSerializer for serializing windows that are assigned by this WindowAssigner . |
TypeSerializer<CountWindow> |
CountTumblingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<TimeWindow> |
TumblingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<CountWindow> |
CountSlidingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
static TypeSerializer |
InternalSerializers.create(LogicalType type,
ExecutionConfig config)
Creates a
TypeSerializer for internal data structures of the given LogicalType . |
Modifier and Type | Method and Description |
---|---|
TypeComparator<RowData> |
RowDataTypeInfo.createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config) |
RowDataSerializer |
RowDataTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<DecimalData> |
DecimalDataTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
WrapperTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<SortedMap<K,V>> |
SortedMapTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<StringData> |
StringDataTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<TimestampData> |
TimestampDataTypeInfo.createSerializer(ExecutionConfig config) |
Constructor and Description |
---|
ArrayDataSerializer(LogicalType eleType,
ExecutionConfig conf) |
MapDataSerializer(LogicalType keyType,
LogicalType valueType,
ExecutionConfig conf) |
RowDataSerializer(ExecutionConfig config,
LogicalType... types) |
RowDataSerializer(ExecutionConfig config,
RowType rowType) |
Modifier and Type | Method and Description |
---|---|
RawType<T> |
TypeInformationRawType.resolve(ExecutionConfig config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeComparator<T> |
InternalTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
TimeIntervalTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig)
Deprecated.
|
TypeSerializer<T> |
InternalTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
TimeIntervalTypeInfo.createSerializer(ExecutionConfig config)
Deprecated.
|
TypeSerializer<Timestamp> |
TimeIndicatorTypeInfo.createSerializer(ExecutionConfig executionConfig)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
ExecutionConfig |
DummyStreamExecutionEnvironment.getConfig() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.