org.apache.flink.streaming.api.operators.co

Class IntervalJoinOperator.BufferSerializerConfigSnapshot<T>

java.lang.Object

org.apache.flink.core.io.VersionedIOReadableWritable

org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot<T>

org.apache.flink.api.common.typeutils.CompositeTypeSerializerConfigSnapshot<IntervalJoinOperator.BufferEntry<T>>

org.apache.flink.streaming.api.operators.co.IntervalJoinOperator.BufferSerializerConfigSnapshot<T>

All Implemented Interfaces:

TypeSerializerSnapshot<IntervalJoinOperator.BufferEntry<T>>, IOReadableWritable, Versioned

Enclosing class:

IntervalJoinOperator<K,T1,T2,OUT>

Deprecated.

this snapshot class is no longer in use, and is maintained only for backwards compatibility. It is fully replaced by IntervalJoinOperator.BufferEntrySerializerSnapshot.

@Deprecated
public static class IntervalJoinOperator.BufferSerializerConfigSnapshot<T>
extends CompositeTypeSerializerConfigSnapshot<IntervalJoinOperator.BufferEntry<T>>

The configuration of our serializer.

Nested Class Summary

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

TypeSerializerConfigSnapshot.SelfResolvingTypeSerializer<E>

Constructor Summary

Constructors

Constructor and Description
BufferSerializerConfigSnapshot() Deprecated.
BufferSerializerConfigSnapshot(TypeSerializer<T> userTypeSerializer) Deprecated.

Method Summary

Modifier and Type	Method and Description
int	getVersion() Deprecated. Returns the version number of the object.
TypeSerializerSchemaCompatibility<IntervalJoinOperator.BufferEntry<T>>	resolveSchemaCompatibility(TypeSerializer<IntervalJoinOperator.BufferEntry<T>> newSerializer) Deprecated. Checks a new serializer's compatibility to read data written by the prior serializer.

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

equals, getNestedSerializersAndConfigs, getNestedSerializerSnapshots, getSingleNestedSerializerAndConfig, hashCode, read, write

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

getCurrentVersion, getUserCodeClassLoader, readSnapshot, restoreSerializer, setPriorSerializer, setUserCodeClassLoader, writeSnapshot

Methods inherited from class org.apache.flink.core.io.VersionedIOReadableWritable

getCompatibleVersions, getReadVersion

Methods inherited from class java.lang.Object

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

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

readVersionedSnapshot, writeVersionedSnapshot

Constructor Detail

BufferSerializerConfigSnapshot

public BufferSerializerConfigSnapshot()

Deprecated.

BufferSerializerConfigSnapshot

public BufferSerializerConfigSnapshot(TypeSerializer<T> userTypeSerializer)

Deprecated.

Method Detail

getVersion

public int getVersion()

Deprecated.

Description copied from interface: Versioned

Returns the version number of the object. Versions numbers can be used to differentiate evolving classes.

resolveSchemaCompatibility

public TypeSerializerSchemaCompatibility<IntervalJoinOperator.BufferEntry<T>> resolveSchemaCompatibility(TypeSerializer<IntervalJoinOperator.BufferEntry<T>> newSerializer)

Deprecated.

Description copied from interface: TypeSerializerSnapshot

Checks a new serializer's compatibility to read data written by the prior serializer.

When a checkpoint/savepoint is restored, this method checks whether the serialization format of the data in the checkpoint/savepoint is compatible for the format of the serializer used by the program that restores the checkpoint/savepoint. The outcome can be that the serialization format is compatible, that the program's serializer needs to reconfigure itself (meaning to incorporate some information from the TypeSerializerSnapshot to be compatible), that the format is outright incompatible, or that a migration needed. In the latter case, the TypeSerializerSnapshot produces a serializer to deserialize the data, and the restoring program's serializer re-serializes the data, thus converting the format during the restore operation.

Specified by:

resolveSchemaCompatibility in interface TypeSerializerSnapshot<IntervalJoinOperator.BufferEntry<T>>

Overrides:

resolveSchemaCompatibility in class TypeSerializerConfigSnapshot<IntervalJoinOperator.BufferEntry<T>>

Parameters:

newSerializer - the new serializer to check.

Returns:

the serializer compatibility result.