Modifier and Type | Class and Description |
---|---|
static class |
SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessCheckingTypeSerializerSnapshot<T> |
Modifier and Type | Method and Description |
---|---|
static <T> TypeSerializerSchemaCompatibility<T> |
CompositeTypeSerializerUtil.delegateCompatibilityCheckToNewSnapshot(TypeSerializer<T> newSerializer,
CompositeTypeSerializerSnapshot<T,? extends TypeSerializer> newCompositeSnapshot,
TypeSerializerSnapshot<?>... legacyNestedSnapshots)
Delegates compatibility checks to a
CompositeTypeSerializerSnapshot instance. |
static void |
CompositeTypeSerializerUtil.setNestedSerializersSnapshots(CompositeTypeSerializerSnapshot<?,?> compositeSnapshot,
TypeSerializerSnapshot<?>... nestedSnapshots)
Overrides the existing nested serializer's snapshots with the provided
nestedSnapshots . |
Modifier and Type | Class and Description |
---|---|
class |
GenericArraySerializerSnapshot<C>
Point-in-time configuration of a
GenericArraySerializer . |
class |
ListSerializerSnapshot<T>
Snapshot class for the
ListSerializer . |
class |
MapSerializerSnapshot<K,V>
Snapshot class for the
MapSerializer . |
Modifier and Type | Class and Description |
---|---|
class |
JavaEitherSerializerSnapshot<L,R>
Snapshot class for the
EitherSerializer . |
static class |
NullableSerializer.NullableSerializerSnapshot<T>
Snapshot for serializers of nullable types, containing the snapshot of its original
serializer.
|
static class |
RowSerializer.RowSerializerSnapshot
A
TypeSerializerSnapshot for RowSerializer. |
class |
TupleSerializerSnapshot<T extends Tuple>
Snapshot of a tuple serializer's configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
ScalaCaseClassSerializerSnapshot<T extends scala.Product>
TypeSerializerSnapshot for ScalaCaseClassSerializer . |
class |
ScalaEitherSerializerSnapshot<L,R>
Configuration snapshot for serializers of Scala's
Either type, containing configuration
snapshots of the Left and Right serializers. |
class |
ScalaOptionSerializerSnapshot<E>
A
TypeSerializerSnapshot for the Scala OptionSerializer . |
class |
ScalaTrySerializerSnapshot<E>
A
TypeSerializerSnapshot for the Scala TrySerializer . |
class |
TraversableSerializerSnapshot<T extends scala.collection.TraversableOnce<E>,E>
A
TypeSerializerSnapshot for the Scala TraversableSerializer . |
class |
Tuple2CaseClassSerializerSnapshot<T1,T2>
TypeSerializerSnapshot for ScalaCaseClassSerializer . |
Modifier and Type | Class and Description |
---|---|
static class |
NFA.MigratedNFASerializerSnapshot<T>
A
TypeSerializerSnapshot for the legacy NFA.NFASerializer . |
class |
NFAStateSerializerSnapshot
Snapshot class for
NFAStateSerializer . |
static class |
SharedBuffer.SharedBufferSerializerSnapshot<K,V>
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
LockableTypeSerializerSnapshot<E>
|
static class |
NodeId.NodeIdSerializer.NodeIdSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
SharedBufferEdge.SharedBufferEdgeSerializer.SharedBufferEdgeSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
SharedBufferNode.SharedBufferNodeSerializer.SharedBufferNodeSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
Modifier and Type | Class and Description |
---|---|
class |
ArrayListSerializerSnapshot<T>
Snapshot class for the
ArrayListSerializer . |
Modifier and Type | Class and Description |
---|---|
static class |
TtlStateFactory.TtlSerializerSnapshot<T>
A
TypeSerializerSnapshot for TtlSerializer. |
Modifier and Type | Class and Description |
---|---|
static class |
CoGroupedStreams.UnionSerializerSnapshot<T1,T2>
The
TypeSerializerSnapshot for the CoGroupedStreams.UnionSerializer . |
Modifier and Type | Class and Description |
---|---|
static class |
TwoPhaseCommitSinkFunction.StateSerializerSnapshot<TXN,CONTEXT>
Snapshot for the
TwoPhaseCommitSinkFunction.StateSerializer . |
Modifier and Type | Class and Description |
---|---|
class |
TimerSerializerSnapshot<K,N>
Snapshot class for the
TimerSerializer . |
Modifier and Type | Class and Description |
---|---|
static class |
IntervalJoinOperator.BufferEntrySerializerSnapshot<T>
|
Modifier and Type | Class and Description |
---|---|
static class |
StreamElementSerializer.StreamElementSerializerSnapshot<T>
Configuration snapshot specific to the
StreamElementSerializer . |
Modifier and Type | Class and Description |
---|---|
static class |
ValueWithTs.ValueWithTsSerializerSnapshot
A
TypeSerializerSnapshot for ValueWithTs Serializer. |
Modifier and Type | Class and Description |
---|---|
class |
ListViewSerializerSnapshot<T>
Deprecated.
|
class |
MapViewSerializerSnapshot<K,V>
Deprecated.
|
class |
NullAwareMapSerializerSnapshot<K,V>
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
CRowSerializerSnapshot
Snapshot class for
CRowSerializer . |
Modifier and Type | Class and Description |
---|---|
static class |
ExternalSerializer.ExternalSerializerSnapshot<I,E>
|
static class |
RawValueDataSerializer.RawValueDataSerializerSnapshot<T>
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.