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

    Methods inherited from interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot

    resolveSchemaCompatibility

  • 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>