Package | Description |
---|---|
org.apache.flink.migration.runtime.checkpoint.savepoint | |
org.apache.flink.migration.streaming.runtime.tasks |
Modifier and Type | Method and Description |
---|---|
static StreamStateHandle |
SavepointV0Serializer.convertOperatorAndFunctionState(StreamTaskState streamTaskState)
This is public so that we can use it when restoring a legacy snapshot
in
AbstractStreamOperatorTestHarness . |
Modifier and Type | Method and Description |
---|---|
StreamTaskState[] |
StreamTaskStateList.getState(ClassLoader userCodeClassLoader)
Deprecated.
|
Constructor and Description |
---|
StreamTaskStateList(StreamTaskState[] states)
Deprecated.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.