Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Field and Description |
---|---|
protected CloseableRegistry |
AbstractKeyedStateBackend.cancelStreamRegistry
Registry for all opened streams, so they can be closed if the task using this backend is closed
|
Modifier and Type | Method and Description |
---|---|
CloseableRegistry |
StateInitializationContextImpl.getClosableRegistry() |
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyGroupsStateHandle> keyGroupsStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
StateSnapshotContextSynchronousImpl(long checkpointId,
long checkpointTimestamp,
CheckpointStreamFactory streamFactory,
KeyGroupRange keyGroupRange,
CloseableRegistry closableRegistry) |
Modifier and Type | Method and Description |
---|---|
CloseableRegistry |
StreamTask.getCancelables() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.