Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.iterative.task | |
org.apache.flink.runtime.jobgraph.tasks | |
org.apache.flink.runtime.operators | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
<K> AbstractKeyedStateBackend<K> |
RocksDBStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup) |
OperatorStateBackend |
RocksDBStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier) |
Constructor and Description |
---|
AbstractIterativeTask(Environment environment)
Create an Invokable task and set its environment.
|
IterationHeadTask(Environment environment)
Create an Invokable task and set its environment.
|
IterationIntermediateTask(Environment environment)
Create an Invokable task and set its environment.
|
IterationSynchronizationSinkTask(Environment environment)
Create an Invokable task and set its environment.
|
IterationTailTask(Environment environment)
Create an Invokable task and set its environment.
|
Modifier and Type | Method and Description |
---|---|
Environment |
AbstractInvokable.getEnvironment()
Returns the environment of this task.
|
Constructor and Description |
---|
AbstractInvokable(Environment environment)
Create an Invokable task and set its environment.
|
Constructor and Description |
---|
BatchTask(Environment environment)
Create an Invokable task and set its environment.
|
DataSinkTask(Environment environment)
Create an Invokable task and set its environment.
|
DataSourceTask(Environment environment)
Create an Invokable task and set its environment.
|
Modifier and Type | Method and Description |
---|---|
default <K> AbstractKeyedStateBackend<K> |
StateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry)
Creates a new
AbstractKeyedStateBackend that is responsible for holding keyed state
and checkpointing it. |
default <K> AbstractKeyedStateBackend<K> |
StateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider)
Creates a new
AbstractKeyedStateBackend that is responsible for holding keyed state
and checkpointing it. |
<K> AbstractKeyedStateBackend<K> |
StateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup)
Creates a new
AbstractKeyedStateBackend that is responsible for holding keyed state
and checkpointing it. |
abstract <K> AbstractKeyedStateBackend<K> |
AbstractStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup) |
OperatorStateBackend |
StateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier)
Creates a new
OperatorStateBackend that can be used for storing operator state. |
abstract OperatorStateBackend |
AbstractStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier) |
Modifier and Type | Method and Description |
---|---|
<K> AbstractKeyedStateBackend<K> |
FsStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup) |
OperatorStateBackend |
FsStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier) |
Modifier and Type | Method and Description |
---|---|
<K> AbstractKeyedStateBackend<K> |
MemoryStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup) |
OperatorStateBackend |
MemoryStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier) |
Modifier and Type | Class and Description |
---|---|
class |
RuntimeEnvironment
In implementation of the
Environment . |
Constructor and Description |
---|
StreamingRuntimeContext(AbstractStreamOperator<?> operator,
Environment env,
Map<String,Accumulator<?,?>> accumulators) |
StreamTaskStateInitializerImpl(Environment environment,
StateBackend stateBackend,
ProcessingTimeService processingTimeService) |
Modifier and Type | Method and Description |
---|---|
CheckpointExceptionHandler |
CheckpointExceptionHandlerFactory.createCheckpointExceptionHandler(boolean failTaskOnCheckpointException,
Environment environment)
Returns a
CheckpointExceptionHandler that either causes a task to fail completely or to just declines
checkpoint on exception, depending on the parameter flag. |
static <OUT> List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>> |
StreamTask.createStreamRecordWriters(StreamConfig configuration,
Environment environment) |
Constructor and Description |
---|
OneInputStreamTask(Environment env)
Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
|
OneInputStreamTask(Environment env,
ProcessingTimeService timeProvider)
Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
|
SourceStreamTask(Environment env) |
StoppableSourceStreamTask(Environment environment) |
StreamIterationHead(Environment env) |
StreamIterationTail(Environment environment) |
StreamTask(Environment env)
Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
|
StreamTask(Environment environment,
ProcessingTimeService timeProvider)
Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
|
TwoInputStreamTask(Environment env)
Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.