Package org.apache.beam.runners.flink.translation.wrappers.streaming.state

Class FlinkStateInternals.FlinkStateNamespaceKeySerializer.FlinkStateNameSpaceSerializerSnapshot

java.lang.Object

org.apache.beam.runners.flink.translation.wrappers.streaming.state.FlinkStateInternals.FlinkStateNamespaceKeySerializer.FlinkStateNameSpaceSerializerSnapshot

All Implemented Interfaces:

org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.beam.runners.core.StateNamespace>

Enclosing class:

FlinkStateInternals.FlinkStateNamespaceKeySerializer

public static final class FlinkStateInternals.FlinkStateNamespaceKeySerializer.FlinkStateNameSpaceSerializerSnapshot
extends Object
implements org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.beam.runners.core.StateNamespace>

Serializer configuration snapshot for compatibility and format evolution.

Constructor Summary

Constructors

Constructor	Description
FlinkStateNameSpaceSerializerSnapshot()

Method Summary

Modifier and Type	Method	Description
int	getCurrentVersion()
void	readSnapshot(int readVersion, org.apache.flink.core.memory.DataInputView in, ClassLoader userCodeClassLoader)
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<org.apache.beam.runners.core.StateNamespace>	resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.beam.runners.core.StateNamespace> newSerializer)
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.beam.runners.core.StateNamespace>	restoreSerializer()
void	writeSnapshot(org.apache.flink.core.memory.DataOutputView out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FlinkStateNameSpaceSerializerSnapshot

public FlinkStateNameSpaceSerializerSnapshot()

Method Details

getCurrentVersion

public int getCurrentVersion()

Specified by:

getCurrentVersion in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.beam.runners.core.StateNamespace>

writeSnapshot

public void writeSnapshot(org.apache.flink.core.memory.DataOutputView out)
                   throws IOException

Specified by:

writeSnapshot in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.beam.runners.core.StateNamespace>

Throws:

IOException

readSnapshot

public void readSnapshot(int readVersion,
 org.apache.flink.core.memory.DataInputView in,
 ClassLoader userCodeClassLoader)
                  throws IOException

Specified by:

readSnapshot in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.beam.runners.core.StateNamespace>

Throws:

IOException

restoreSerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.beam.runners.core.StateNamespace> restoreSerializer()

Specified by:

restoreSerializer in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.beam.runners.core.StateNamespace>

resolveSchemaCompatibility

public org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<org.apache.beam.runners.core.StateNamespace> resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.beam.runners.core.StateNamespace> newSerializer)

Specified by:

resolveSchemaCompatibility in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.beam.runners.core.StateNamespace>