org.apache.flink.cep.nfa.sharedbuffer

Class SharedBufferEdge.SharedBufferEdgeSerializer.SharedBufferEdgeSerializerSnapshot

java.lang.Object

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<SharedBufferEdge,SharedBufferEdge.SharedBufferEdgeSerializer>

org.apache.flink.cep.nfa.sharedbuffer.SharedBufferEdge.SharedBufferEdgeSerializer.SharedBufferEdgeSerializerSnapshot

All Implemented Interfaces:

TypeSerializerSnapshot<SharedBufferEdge>

Enclosing class:

SharedBufferEdge.SharedBufferEdgeSerializer

public static final class SharedBufferEdge.SharedBufferEdgeSerializer.SharedBufferEdgeSerializerSnapshot
extends CompositeTypeSerializerSnapshot<SharedBufferEdge,SharedBufferEdge.SharedBufferEdgeSerializer>

Serializer configuration snapshot for compatibility and format evolution.

Nested Class Summary

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

CompositeTypeSerializerSnapshot.OuterSchemaCompatibility

Constructor Summary

Constructors

Constructor and Description
SharedBufferEdgeSerializerSnapshot()
SharedBufferEdgeSerializerSnapshot(SharedBufferEdge.SharedBufferEdgeSerializer sharedBufferEdgeSerializer)

Method Summary

Modifier and Type	Method and Description
protected SharedBufferEdge.SharedBufferEdgeSerializer	createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) Creates an instance of the outer serializer with a given array of its nested serializers.
protected int	getCurrentOuterSnapshotVersion() Returns the version of the current outer snapshot's written binary format.
protected TypeSerializer<?>[]	getNestedSerializers(SharedBufferEdge.SharedBufferEdgeSerializer outerSerializer) Gets the nested serializers from the outer serializer.

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

getCurrentVersion, getNestedSerializerSnapshots, isOuterSnapshotCompatible, readOuterSnapshot, readSnapshot, 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

readVersionedSnapshot, writeVersionedSnapshot

Constructor Detail

SharedBufferEdgeSerializerSnapshot

public SharedBufferEdgeSerializerSnapshot()

SharedBufferEdgeSerializerSnapshot

public SharedBufferEdgeSerializerSnapshot(SharedBufferEdge.SharedBufferEdgeSerializer sharedBufferEdgeSerializer)

Method Detail

getCurrentOuterSnapshotVersion

protected int getCurrentOuterSnapshotVersion()

Description copied from class: CompositeTypeSerializerSnapshot

Returns the version of the current outer snapshot's written binary format.

Specified by:

getCurrentOuterSnapshotVersion in class CompositeTypeSerializerSnapshot<SharedBufferEdge,SharedBufferEdge.SharedBufferEdgeSerializer>

Returns:

the version of the current outer snapshot's written binary format.

createOuterSerializerWithNestedSerializers

protected SharedBufferEdge.SharedBufferEdgeSerializer createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)

Description copied from class: CompositeTypeSerializerSnapshot

Creates an instance of the outer serializer with a given array of its nested serializers.

Specified by:

createOuterSerializerWithNestedSerializers in class CompositeTypeSerializerSnapshot<SharedBufferEdge,SharedBufferEdge.SharedBufferEdgeSerializer>

Parameters:

nestedSerializers - array of nested serializers to create the outer serializer with.

Returns:

an instance of the outer serializer.

getNestedSerializers

protected TypeSerializer<?>[] getNestedSerializers(SharedBufferEdge.SharedBufferEdgeSerializer outerSerializer)

Description copied from class: CompositeTypeSerializerSnapshot

Gets the nested serializers from the outer serializer.

Specified by:

getNestedSerializers in class CompositeTypeSerializerSnapshot<SharedBufferEdge,SharedBufferEdge.SharedBufferEdgeSerializer>

Parameters:

outerSerializer - the outer serializer.

Returns:

the nested serializers.