Package org.apache.flink.cep.nfa.sharedbuffer

Class SharedBufferNode.SharedBufferNodeSerializer.SharedBufferNodeSerializerSnapshot

java.lang.Object

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<SharedBufferNode,SharedBufferNode.SharedBufferNodeSerializer>

org.apache.flink.cep.nfa.sharedbuffer.SharedBufferNode.SharedBufferNodeSerializer.SharedBufferNodeSerializerSnapshot

All Implemented Interfaces:

org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<SharedBufferNode>

Enclosing class:

SharedBufferNode.SharedBufferNodeSerializer

public static final class SharedBufferNode.SharedBufferNodeSerializer.SharedBufferNodeSerializerSnapshot
extends org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<SharedBufferNode,SharedBufferNode.SharedBufferNodeSerializer>

Serializer configuration snapshot for compatibility and format evolution.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot.OuterSchemaCompatibility

Constructor Summary

Constructors

Constructor	Description
SharedBufferNodeSerializerSnapshot()
SharedBufferNodeSerializerSnapshot(SharedBufferNode.SharedBufferNodeSerializer sharedBufferNodeSerializer)

Method Summary

Modifier and Type	Method	Description
protected SharedBufferNode.SharedBufferNodeSerializer	createOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)
protected int	getCurrentOuterSnapshotVersion()
protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[]	getNestedSerializers(SharedBufferNode.SharedBufferNodeSerializer outerSerializer)

Methods inherited from class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot

getCurrentVersion, getNestedSerializerSnapshots, isOuterSnapshotCompatible, readOuterSnapshot, readSnapshot, resolveOuterSchemaCompatibility, resolveOuterSchemaCompatibility, resolveSchemaCompatibility, restoreSerializer, writeOuterSnapshot, writeSnapshot

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 Detail

SharedBufferNodeSerializerSnapshot

public SharedBufferNodeSerializerSnapshot()

SharedBufferNodeSerializerSnapshot

public SharedBufferNodeSerializerSnapshot(SharedBufferNode.SharedBufferNodeSerializer sharedBufferNodeSerializer)

Method Detail

getCurrentOuterSnapshotVersion

protected int getCurrentOuterSnapshotVersion()

Specified by:

getCurrentOuterSnapshotVersion in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<SharedBufferNode,SharedBufferNode.SharedBufferNodeSerializer>

createOuterSerializerWithNestedSerializers

protected SharedBufferNode.SharedBufferNodeSerializer createOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)

Specified by:

createOuterSerializerWithNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<SharedBufferNode,SharedBufferNode.SharedBufferNodeSerializer>

getNestedSerializers

protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[] getNestedSerializers(SharedBufferNode.SharedBufferNodeSerializer outerSerializer)

Specified by:

getNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<SharedBufferNode,SharedBufferNode.SharedBufferNodeSerializer>