Package org.apache.flink.runtime.state
Class IncrementalKeyedStateHandle.HandleAndLocalPath
- java.lang.Object
-
- org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath
-
- All Implemented Interfaces:
Serializable
- Enclosing interface:
- IncrementalKeyedStateHandle
public static final class IncrementalKeyedStateHandle.HandleAndLocalPath extends Object implements Serializable
A Holder of StreamStateHandle and the corresponding localPath.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
StreamStateHandle
getHandle()
String
getLocalPath()
long
getStateSize()
int
hashCode()
static IncrementalKeyedStateHandle.HandleAndLocalPath
of(StreamStateHandle handle, String localPath)
void
replaceHandle(StreamStateHandle registryReturned)
Replace the StreamStateHandle with the registry returned one.String
toString()
-
-
-
Method Detail
-
of
public static IncrementalKeyedStateHandle.HandleAndLocalPath of(StreamStateHandle handle, String localPath)
-
getHandle
public StreamStateHandle getHandle()
-
getLocalPath
public String getLocalPath()
-
getStateSize
public long getStateSize()
-
replaceHandle
public void replaceHandle(StreamStateHandle registryReturned)
Replace the StreamStateHandle with the registry returned one.
-
-