org.wikimedia.eventutilities.flink

Class EventRowSerializer.EventRowSerializerSnapshot

java.lang.Object

org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot

All Implemented Interfaces:

org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.types.Row>

Enclosing class:

EventRowSerializer

public static class EventRowSerializer.EventRowSerializerSnapshot
extends Object
implements org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.types.Row>

The serialiazer snapshot, this object is meant to represent the state of a particular EventRowSerializer. It is able to durably store this state (reason why it allows specifying a version). When storing TypeSerializerSnapshotSerializationUtil#writeSerializerSnapshot(DataOutputView, TypeSerializerSnapshot) is used and will store

• the classname
• its version with getCurrentVersion()
• its data with writeSnapshot(DataOutputView)

When restoring using TypeSerializerSnapshotSerializationUtil#readSerializerSnapshot(DataInputView, ClassLoader) it will:

• instantiate the TypeSerializerSnapshot using the classname stored (using the empty ctor)
• read the version
• restore the state TypeSerializerSnapshot.readVersionedSnapshot(DataInputView, ClassLoader)

This class must then be able to restore the serializer able to deserialize the data that it had previously written with restoreSerializer(). And also determine its level of compatibility with the runtime serializer with resolveSchemaCompatibility(TypeSerializerSnapshot).

Constructor Summary

Constructors

Constructor and Description
EventRowSerializerSnapshot()
EventRowSerializerSnapshot(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] fieldSerializers, LinkedHashMap<String,Integer> positionByNames)

Method Summary

Modifier and Type	Method and Description
int	getCurrentVersion()
void	readSnapshot(int readVersion, org.apache.flink.core.memory.DataInputView in, ClassLoader userCodeClassLoader)
void	readV1(org.apache.flink.core.memory.DataInputView in, ClassLoader userCodeClassLoader)
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<org.apache.flink.types.Row>	resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.types.Row> oldSerializerSnapshot)
<E> org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<E>	resolveSubFieldCompat(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<?> newFieldSnapshot, org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<?> oldFieldSnapshot)
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row>	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

readVersionedSnapshot, resolveSchemaCompatibility, writeVersionedSnapshot

Constructor Detail

EventRowSerializerSnapshot

public EventRowSerializerSnapshot()

EventRowSerializerSnapshot

public EventRowSerializerSnapshot(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] fieldSerializers,
                                  LinkedHashMap<String,Integer> positionByNames)

Method Detail

getCurrentVersion

public int getCurrentVersion()

Specified by:

getCurrentVersion in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.types.Row>

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.flink.types.Row>

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.flink.types.Row>

Throws:

IOException

readV1

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

Throws:

IOException

restoreSerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row> restoreSerializer()

Specified by:

restoreSerializer in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.types.Row>

resolveSchemaCompatibility

public org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<org.apache.flink.types.Row> resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.types.Row> oldSerializerSnapshot)

Specified by:

resolveSchemaCompatibility in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.types.Row>

resolveSubFieldCompat

public <E> org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<E> resolveSubFieldCompat(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<?> newFieldSnapshot,
                                                                                                            org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<?> oldFieldSnapshot)