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 |
---|---|
ChainedStateHandle<OperatorStateHandle> |
SubtaskState.getManagedOperatorState() |
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 |
---|---|
List<Collection<OperatorStateHandle>> |
RoundRobinOperatorStateRepartitioner.repartitionState(List<OperatorStateHandle> previousParallelSubtaskStates,
int parallelism) |
List<Collection<OperatorStateHandle>> |
OperatorStateRepartitioner.repartitionState(List<OperatorStateHandle> previousParallelSubtaskStates,
int parallelism) |
Constructor and Description |
---|
SubtaskState(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
ChainedStateHandle<OperatorStateHandle> managedOperatorState,
ChainedStateHandle<OperatorStateHandle> rawOperatorState,
KeyGroupsStateHandle managedKeyedState,
KeyGroupsStateHandle rawKeyedState) |
SubtaskState(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
ChainedStateHandle<OperatorStateHandle> managedOperatorState,
ChainedStateHandle<OperatorStateHandle> rawOperatorState,
KeyGroupsStateHandle managedKeyedState,
KeyGroupsStateHandle 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 |
---|---|
List<Collection<OperatorStateHandle>> |
TaskStateHandles.getManagedOperatorState() |
Collection<OperatorStateHandle> |
StateInitializationContextImpl.getOperatorStateHandles() |
RunnableFuture<OperatorStateHandle> |
StateSnapshotContextSynchronousImpl.getOperatorStateStreamFuture() |
List<Collection<OperatorStateHandle>> |
TaskStateHandles.getRawOperatorState() |
RunnableFuture<OperatorStateHandle> |
DefaultOperatorStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultOperatorStateBackend.restore(Collection<OperatorStateHandle> restoreSnapshots) |
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyGroupsStateHandle> keyGroupsStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
TaskStateHandles(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
List<Collection<OperatorStateHandle>> managedOperatorState,
List<Collection<OperatorStateHandle>> rawOperatorState,
Collection<KeyGroupsStateHandle> managedKeyedState,
Collection<KeyGroupsStateHandle> rawKeyedState) |
TaskStateHandles(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
List<Collection<OperatorStateHandle>> managedOperatorState,
List<Collection<OperatorStateHandle>> rawOperatorState,
Collection<KeyGroupsStateHandle> managedKeyedState,
Collection<KeyGroupsStateHandle> rawKeyedState) |
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<KeyGroupsStateHandle> keyedStateManagedFuture,
RunnableFuture<KeyGroupsStateHandle> keyedStateRawFuture,
RunnableFuture<OperatorStateHandle> operatorStateManagedFuture,
RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
OperatorSnapshotResult(RunnableFuture<KeyGroupsStateHandle> keyedStateManagedFuture,
RunnableFuture<KeyGroupsStateHandle> 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,
StreamStateHandle legacyOperatorState,
Collection<KeyGroupsStateHandle> managedKeyedState,
Collection<KeyGroupsStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
OperatorStateHandles(int operatorChainIndex,
StreamStateHandle legacyOperatorState,
Collection<KeyGroupsStateHandle> managedKeyedState,
Collection<KeyGroupsStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.