Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.savepoint | |
org.apache.flink.runtime.state | |
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 |
---|---|
static Map<OperatorInstanceID,List<OperatorStateHandle>> |
StateAssignmentOperation.applyRepartitioner(OperatorID operatorID,
OperatorStateRepartitioner opStateRepartitioner,
List<OperatorStateHandle> chainOpParallelStates,
int oldParallelism,
int newParallelism) |
static List<Collection<OperatorStateHandle>> |
StateAssignmentOperation.applyRepartitioner(OperatorStateRepartitioner opStateRepartitioner,
List<OperatorStateHandle> chainOpParallelStates,
int oldParallelism,
int newParallelism)
Repartitions the given operator state using the given
OperatorStateRepartitioner with respect to the new
parallelism. |
Collection<OperatorStateHandle> |
OperatorSubtaskState.getManagedOperatorState()
Returns a handle to the managed operator state.
|
ChainedStateHandle<OperatorStateHandle> |
SubtaskState.getManagedOperatorState() |
Collection<OperatorStateHandle> |
OperatorSubtaskState.getRawOperatorState()
Returns a handle to the raw operator state.
|
ChainedStateHandle<OperatorStateHandle> |
SubtaskState.getRawOperatorState() |
List<Collection<OperatorStateHandle>> |
RoundRobinOperatorStateRepartitioner.repartitionState(List<OperatorStateHandle> previousParallelSubtaskStates,
int parallelism) |
List<Collection<OperatorStateHandle>> |
OperatorStateRepartitioner.repartitionState(List<OperatorStateHandle> previousParallelSubtaskStates,
int parallelism) |
Modifier and Type | Method and Description |
---|---|
static Map<OperatorInstanceID,List<OperatorStateHandle>> |
StateAssignmentOperation.applyRepartitioner(OperatorID operatorID,
OperatorStateRepartitioner opStateRepartitioner,
List<OperatorStateHandle> chainOpParallelStates,
int oldParallelism,
int newParallelism) |
static List<Collection<OperatorStateHandle>> |
StateAssignmentOperation.applyRepartitioner(OperatorStateRepartitioner opStateRepartitioner,
List<OperatorStateHandle> chainOpParallelStates,
int oldParallelism,
int newParallelism)
Repartitions the given operator state using the given
OperatorStateRepartitioner with respect to the new
parallelism. |
static OperatorSubtaskState |
StateAssignmentOperation.operatorSubtaskStateFrom(OperatorInstanceID instanceID,
Map<OperatorInstanceID,List<OperatorStateHandle>> subManagedOperatorState,
Map<OperatorInstanceID,List<OperatorStateHandle>> subRawOperatorState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subManagedKeyedState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subRawKeyedState) |
static OperatorSubtaskState |
StateAssignmentOperation.operatorSubtaskStateFrom(OperatorInstanceID instanceID,
Map<OperatorInstanceID,List<OperatorStateHandle>> subManagedOperatorState,
Map<OperatorInstanceID,List<OperatorStateHandle>> subRawOperatorState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subManagedKeyedState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subRawKeyedState) |
List<Collection<OperatorStateHandle>> |
RoundRobinOperatorStateRepartitioner.repartitionState(List<OperatorStateHandle> previousParallelSubtaskStates,
int parallelism) |
List<Collection<OperatorStateHandle>> |
OperatorStateRepartitioner.repartitionState(List<OperatorStateHandle> previousParallelSubtaskStates,
int parallelism) |
Constructor and Description |
---|
OperatorSubtaskState(OperatorStateHandle managedOperatorState,
OperatorStateHandle rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState)
For convenience because the size of the collections is typically 0 or 1.
|
Constructor and Description |
---|
OperatorSubtaskState(Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState) |
OperatorSubtaskState(Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState) |
SubtaskState(ChainedStateHandle<OperatorStateHandle> managedOperatorState,
ChainedStateHandle<OperatorStateHandle> rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState) |
SubtaskState(ChainedStateHandle<OperatorStateHandle> managedOperatorState,
ChainedStateHandle<OperatorStateHandle> rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState) |
Modifier and Type | Method and Description |
---|---|
static OperatorStateHandle |
SavepointV1Serializer.deserializeOperatorStateHandle(DataInputStream dis) |
Modifier and Type | Method and Description |
---|---|
static void |
SavepointV1Serializer.serializeOperatorStateHandle(OperatorStateHandle stateHandle,
DataOutputStream dos) |
Modifier and Type | Method and Description |
---|---|
Collection<OperatorStateHandle> |
StateInitializationContextImpl.getOperatorStateHandles() |
RunnableFuture<OperatorStateHandle> |
StateSnapshotContextSynchronousImpl.getOperatorStateStreamFuture() |
RunnableFuture<OperatorStateHandle> |
DefaultOperatorStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultOperatorStateBackend.restore(Collection<OperatorStateHandle> restoreSnapshots) |
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyedStateHandle> keyedStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<OperatorStateHandle> |
OperatorSnapshotResult.getOperatorStateManagedFuture() |
RunnableFuture<OperatorStateHandle> |
OperatorSnapshotResult.getOperatorStateRawFuture() |
Modifier and Type | Method and Description |
---|---|
void |
OperatorSnapshotResult.setOperatorStateManagedFuture(RunnableFuture<OperatorStateHandle> operatorStateManagedFuture) |
void |
OperatorSnapshotResult.setOperatorStateRawFuture(RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
Constructor and Description |
---|
OperatorSnapshotResult(RunnableFuture<KeyedStateHandle> keyedStateManagedFuture,
RunnableFuture<KeyedStateHandle> keyedStateRawFuture,
RunnableFuture<OperatorStateHandle> operatorStateManagedFuture,
RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
OperatorSnapshotResult(RunnableFuture<KeyedStateHandle> keyedStateManagedFuture,
RunnableFuture<KeyedStateHandle> keyedStateRawFuture,
RunnableFuture<OperatorStateHandle> operatorStateManagedFuture,
RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
Modifier and Type | Method and Description |
---|---|
Collection<OperatorStateHandle> |
OperatorStateHandles.getManagedOperatorState() |
Collection<OperatorStateHandle> |
OperatorStateHandles.getRawOperatorState() |
Modifier and Type | Method and Description |
---|---|
OperatorStateBackend |
StreamTask.createOperatorStateBackend(StreamOperator<?> op,
Collection<OperatorStateHandle> restoreStateHandles) |
Constructor and Description |
---|
OperatorStateHandles(int operatorChainIndex,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
OperatorStateHandles(int operatorChainIndex,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.