Modifier and Type | Class and Description |
---|---|
static class |
CompositeSerializer.ConfigSnapshot
Snapshot field serializers of composite type.
|
class |
CompositeTypeSerializerConfigSnapshot<T>
A
TypeSerializerConfigSnapshot for serializers that has multiple nested serializers. |
class |
GenericTypeSerializerConfigSnapshot<T>
Configuration snapshot for serializers for generic types.
|
class |
ParameterlessTypeSerializerConfig<T>
A base class for
TypeSerializerConfigSnapshot s that do not have any parameters. |
Modifier and Type | Method and Description |
---|---|
TypeSerializerConfigSnapshot |
CompositeSerializer.snapshotConfiguration() |
TypeSerializerConfigSnapshot<T> |
TypeDeserializerAdapter.snapshotConfiguration() |
TypeSerializerConfigSnapshot<T> |
UnloadableDummyTypeSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
CompositeSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
TypeDeserializerAdapter.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
CompatibilityResult<T> |
UnloadableDummyTypeSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
CompatibilityResult<T> |
TypeSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
CollectionSerializerConfigSnapshot<C extends Collection<T>,T>
Deprecated.
this snapshot class should no longer be used by any serializers as their snapshot.
|
static class |
EnumSerializer.EnumSerializerConfigSnapshot<T extends Enum<T>>
Configuration snapshot of a serializer for enumerations.
|
class |
MapSerializerConfigSnapshot<K,V>
Deprecated.
this snapshot class should not be used by any serializer anymore.
|
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
TypeSerializerSingleton.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
CompatibilityResult<T> |
EnumSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
Modifier and Type | Class and Description |
---|---|
static class |
CopyableValueSerializer.CopyableValueSerializerConfigSnapshot<T extends CopyableValue<T>> |
class |
EitherSerializerConfigSnapshot<L,R>
Deprecated.
|
class |
KryoRegistrationSerializerConfigSnapshot<T>
Configuration snapshot base class for serializers that use Kryo for serialization.
|
static class |
NullableSerializer.NullableSerializerConfigSnapshot<T>
Configuration snapshot for serializers of nullable types, containing the
configuration snapshot of its original serializer.
|
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 | Method and Description |
---|---|
CompatibilityResult<T> |
NullableSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
WritableSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
CompatibilityResult<T> |
ValueSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
CompatibilityResult<T> |
CopyableValueSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
CompatibilityResult<T> |
TupleSerializerBase.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
CompatibilityResult<Row> |
RowSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
CompatibilityResult<T> |
PojoSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
Modifier and Type | Class and Description |
---|---|
static class |
KryoSerializer.KryoSerializerConfigSnapshot<T> |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
KryoSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
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<T extends scala.collection.TraversableOnce<E>,E>
A
TypeSerializerConfigSnapshot for the Scala TraversableSerializer . |
Modifier and Type | Class and Description |
---|---|
static class |
NFA.NFASerializerConfigSnapshot<T>
Deprecated.
|
static class |
SharedBuffer.SharedBufferSerializerConfigSnapshot<K,V>
Deprecated.
The
TypeSerializerConfigSnapshot serializer configuration to be stored with the managed state. |
Modifier and Type | Method and Description |
---|---|
TypeSerializerConfigSnapshot<NFA.MigratedNFA<T>> |
NFA.NFASerializer.snapshotConfiguration()
Deprecated.
|
TypeSerializerConfigSnapshot<SharedBuffer<V>> |
SharedBuffer.SharedBufferSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<NFA.MigratedNFA<T>> |
NFA.NFASerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot)
Deprecated.
|
CompatibilityResult<SharedBuffer<V>> |
SharedBuffer.SharedBufferSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<Lockable<E>> |
Lockable.LockableTypeSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot)
This cannot be removed until
TypeSerializerConfigSnapshot is no longer supported. |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<ArrayList<T>> |
ArrayListSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot)
NOTE: this method cannot be removed until
CollectionSerializerConfigSnapshot is fully removed. |
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 | Method and Description |
---|---|
TypeSerializerConfigSnapshot<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> |
TwoPhaseCommitSinkFunction.StateSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> |
TwoPhaseCommitSinkFunction.StateSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
Modifier and Type | Class and Description |
---|---|
static class |
TimerSerializer.TimerSerializerConfigSnapshot<K,N>
Snaphot of a
TimerSerializer . |
Modifier and Type | Method and Description |
---|---|
TypeSerializerConfigSnapshot<TimerHeapInternalTimer<K,N>> |
TimerSerializer.snapshotConfiguration() |
TypeSerializerConfigSnapshot |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<TimerHeapInternalTimer<K,N>> |
TimerSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<TimerHeapInternalTimer<K,N>> |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Class and Description |
---|---|
static class |
IntervalJoinOperator.BufferSerializerConfigSnapshot<T>
The
configuration of our serializer. |
Modifier and Type | Class and Description |
---|---|
static class |
StreamElementSerializer.StreamElementSerializerConfigSnapshot<T>
Configuration snapshot specific to the
StreamElementSerializer . |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<StreamElement> |
StreamElementSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerConfigSnapshot<ComplexPayload> |
StatefulComplexPayloadSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<ComplexPayload> |
StatefulComplexPayloadSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.