org.apache.flink.streaming.api.functions.sink

Class TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot<TXN,CONTEXT>

java.lang.Object

org.apache.flink.core.io.VersionedIOReadableWritable

org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot

org.apache.flink.api.common.typeutils.CompositeTypeSerializerConfigSnapshot

org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot<TXN,CONTEXT>

All Implemented Interfaces:

org.apache.flink.core.io.IOReadableWritable, org.apache.flink.core.io.Versioned

Enclosing class:

TwoPhaseCommitSinkFunction<IN,TXN,CONTEXT>

@Internal
public static final class TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot<TXN,CONTEXT>
extends org.apache.flink.api.common.typeutils.CompositeTypeSerializerConfigSnapshot

TypeSerializerConfigSnapshot for sink state. This has to be public so that it can be deserialized/instantiated, should not be used anywhere outside TwoPhaseCommitSinkFunction.

Constructor Summary

Constructors

Constructor and Description
StateSerializerConfigSnapshot() This empty nullary constructor is required for deserializing the configuration.
StateSerializerConfigSnapshot(org.apache.flink.api.common.typeutils.TypeSerializer<TXN> transactionSerializer, org.apache.flink.api.common.typeutils.TypeSerializer<CONTEXT> contextSerializer)

Method Summary

Modifier and Type	Method and Description
int	getVersion()

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

equals, getNestedSerializersAndConfigs, getSingleNestedSerializerAndConfig, hashCode, read, write

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

getUserCodeClassLoader, setUserCodeClassLoader

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

Constructor Detail

StateSerializerConfigSnapshot

public StateSerializerConfigSnapshot()

This empty nullary constructor is required for deserializing the configuration.

StateSerializerConfigSnapshot

public StateSerializerConfigSnapshot(org.apache.flink.api.common.typeutils.TypeSerializer<TXN> transactionSerializer,
                                     org.apache.flink.api.common.typeutils.TypeSerializer<CONTEXT> contextSerializer)

Method Detail

getVersion

public int getVersion()