Class StateMetaInfoSnapshotReadersWriters
- java.lang.Object
-
- org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters
-
public class StateMetaInfoSnapshotReadersWriters extends Object
Static factory that gives out the write and readers for different versions ofStateMetaInfoSnapshot
.
-
-
Field Summary
Fields Modifier and Type Field Description static int
CURRENT_STATE_META_INFO_SNAPSHOT_VERSION
Current version for the serialization format ofStateMetaInfoSnapshotReadersWriters
.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static StateMetaInfoReader
getReader(int readVersion)
Returns a reader forStateMetaInfoSnapshot
with the requested state type and version number.static StateMetaInfoWriter
getWriter()
Returns the writer forStateMetaInfoSnapshot
.
-
-
-
Field Detail
-
CURRENT_STATE_META_INFO_SNAPSHOT_VERSION
public static final int CURRENT_STATE_META_INFO_SNAPSHOT_VERSION
Current version for the serialization format ofStateMetaInfoSnapshotReadersWriters
. - v6: since Flink 1.7.x- See Also:
- Constant Field Values
-
-
Method Detail
-
getWriter
@Nonnull public static StateMetaInfoWriter getWriter()
Returns the writer forStateMetaInfoSnapshot
.
-
getReader
@Nonnull public static StateMetaInfoReader getReader(int readVersion)
Returns a reader forStateMetaInfoSnapshot
with the requested state type and version number.- Parameters:
readVersion
- the format version to read.- Returns:
- the requested reader.
-
-