| Modifier and Type | Class and Description |
|---|---|
class |
CompositeTypeSerializerConfigSnapshot
A
TypeSerializerConfigSnapshot for serializers that has multiple nested serializers. |
class |
GenericTypeSerializerConfigSnapshot<T>
Configuration snapshot for serializers for generic types.
|
class |
ParameterlessTypeSerializerConfig
A base class for
TypeSerializerConfigSnapshots that do not have any parameters. |
class |
TypeSerializerConfigSnapshot
A
TypeSerializerConfigSnapshot is a point-in-time view of a TypeSerializer's configuration. |
static class |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy<T>
Utility serialization proxy for a
TypeSerializer. |
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionSerializerConfigSnapshot<T>
Configuration snapshot of a serializer for collection types.
|
static class |
EnumSerializer.EnumSerializerConfigSnapshot<T extends Enum<T>>
Configuration snapshot of a serializer for enumerations.
|
class |
GenericArraySerializerConfigSnapshot<C>
Point-in-time configuration of a
GenericArraySerializer. |
class |
MapSerializerConfigSnapshot<K,V>
Configuration snapshot for serializers of maps, containing the
configuration snapshot of its key serializer and value serializer.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
AvroSerializer.AvroSerializerConfigSnapshot<T>
Deprecated.
Config snapshot for this serializer.
|
static class |
CopyableValueSerializer.CopyableValueSerializerConfigSnapshot<T extends CopyableValue<T>> |
class |
EitherSerializerConfigSnapshot<L,R>
Configuration snapshot for serializers of the
Either type,
containing configuration snapshots of the Left and Right serializers. |
class |
KryoRegistrationSerializerConfigSnapshot<T>
Configuration snapshot base class for serializers that use Kryo for serialization.
|
static class |
PojoSerializer.PojoSerializerConfigSnapshot<T> |
static class |
RowSerializer.RowSerializerConfigSnapshot |
class |
TupleSerializerConfigSnapshot<T>
Snapshot of a tuple serializer's configuration.
|
static class |
ValueSerializer.ValueSerializerConfigSnapshot<T extends Value> |
static class |
WritableSerializer.WritableSerializerConfigSnapshot<T extends org.apache.hadoop.io.Writable>
The config snapshot for this serializer.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
KryoSerializer.KryoSerializerConfigSnapshot<T> |
| Modifier and Type | Class and Description |
|---|---|
class |
ScalaOptionSerializerConfigSnapshot<E>
A
TypeSerializerConfigSnapshot for the Scala OptionSerializer. |
class |
ScalaTrySerializerConfigSnapshot<E>
A
TypeSerializerConfigSnapshot for the Scala TrySerializer. |
class |
TraversableSerializerConfigSnapshot<E>
A
TypeSerializerConfigSnapshot for the Scala TraversableSerializer. |
| Modifier and Type | Class and Description |
|---|---|
static class |
NFA.NFASerializerConfigSnapshot<T>
The
TypeSerializerConfigSnapshot serializer configuration to be stored with the managed state. |
static class |
SharedBuffer.SharedBufferSerializerConfigSnapshot<K,V>
The
TypeSerializerConfigSnapshot serializer configuration to be stored with the managed state. |
| Modifier and Type | Class and Description |
|---|---|
class |
PostVersionedIOReadableWritable
A
VersionedIOReadableWritable which allows to differentiate whether the previous
data was versioned with a VersionedIOReadableWritable. |
| Modifier and Type | Class and Description |
|---|---|
static class |
AvroSerializer.AvroSchemaSerializerConfigSnapshot
A config snapshot for the Avro Serializer that stores the Avro Schema to check compatibility.
|
| Modifier and Type | Class and Description |
|---|---|
class |
KeyedBackendSerializationProxy<K>
Serialization proxy for all meta data in keyed state backends.
|
class |
OperatorBackendSerializationProxy
Serialization proxy for all meta data in operator state backends.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
CoGroupedStreams.UnionSerializerConfigSnapshot<T1,T2>
The
TypeSerializerConfigSnapshot for the UnionSerializer. |
| Modifier and Type | Class and Description |
|---|---|
static class |
TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot<TXN,CONTEXT>
TypeSerializerConfigSnapshot for sink state. |
| Modifier and Type | Class and Description |
|---|---|
class |
InternalTimerServiceSerializationProxy<K,N>
Serialization proxy for the timer services for a given key-group.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
StreamElementSerializer.StreamElementSerializerConfigSnapshot<T>
Configuration snapshot specific to the
StreamElementSerializer. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.