org.apache.flink.runtime.state.filesystem

Class RelativeFileStateHandle

java.lang.Object

org.apache.flink.runtime.state.filesystem.FileStateHandle

org.apache.flink.runtime.state.filesystem.RelativeFileStateHandle

All Implemented Interfaces:

Serializable, StateObject, StreamStateHandle

public class RelativeFileStateHandle
extends FileStateHandle

A StreamStateHandle for state that was written to a file stream. The differences between FileStateHandle and RelativeFileStateHandle is that RelativeFileStateHandle contains relativePath for the given handle.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.StateObject

StateObject.StateObjectLocation, StateObject.StateObjectSizeStatsCollector

Constructor Summary

Constructors

Constructor and Description
RelativeFileStateHandle(Path path, String relativePath, long stateSize)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getRelativePath()
int	hashCode()
String	toString()

Methods inherited from class org.apache.flink.runtime.state.filesystem.FileStateHandle

asBytesIfInMemory, collectSizeStats, discardState, getFilePath, getStateSize, getStreamStateHandleID, maybeGetPath, openInputStream

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

RelativeFileStateHandle

public RelativeFileStateHandle(Path path,
                               String relativePath,
                               long stateSize)

Method Detail

getRelativePath

public String getRelativePath()

equals

public boolean equals(Object o)

Overrides:

equals in class FileStateHandle

hashCode

public int hashCode()

Overrides:

hashCode in class FileStateHandle

toString

public String toString()

Overrides:

toString in class FileStateHandle