Modifier and Type | Class and Description |
---|---|
class |
BackwardsCompatibleSerializerSnapshot<T>
A utility
TypeSerializerConfigSnapshot that is used for backwards compatibility purposes. |
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. |
class |
SimpleTypeSerializerSnapshot<T>
A simple base class for TypeSerializerSnapshots, for serializers that have no
parameters.
|
class |
TypeSerializerConfigSnapshot<T>
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <T> TypeSerializerSnapshot<T> |
TypeSerializerSnapshotSerializationUtil.readAndInstantiateSnapshotClass(DataInputView in,
ClassLoader cl) |
static <T> TypeSerializerSnapshot<T> |
TypeSerializerSnapshotSerializationUtil.readSerializerSnapshot(DataInputView in,
ClassLoader userCodeClassLoader,
TypeSerializer<T> existingPriorSerializer)
Reads from a data input view a
TypeSerializerSnapshot that was previously
written using TypeSerializerSnapshotSerializationUtil.writeSerializerSnapshot(DataOutputView, TypeSerializerSnapshot, TypeSerializer) . |
static <T> TypeSerializerSnapshot<T> |
TypeSerializerSnapshot.readVersionedSnapshot(DataInputView in,
ClassLoader cl)
Reads a snapshot from the stream, performing resolving
|
static TypeSerializerSnapshot<?>[] |
TypeSerializerUtils.snapshotBackwardsCompatible(TypeSerializer<?>... originatingSerializers)
Takes config snapshots of the given serializers.
|
abstract TypeSerializerSnapshot<T> |
TypeSerializer.snapshotConfiguration()
Snapshots the configuration of this TypeSerializer.
|
Modifier and Type | Method and Description |
---|---|
List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
CompositeTypeSerializerConfigSnapshot.getNestedSerializersAndConfigs() |
Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> |
CompositeTypeSerializerConfigSnapshot.getSingleNestedSerializerAndConfig() |
static List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
TypeSerializerSerializationUtil.readSerializersAndConfigsWithResilience(DataInputView in,
ClassLoader userCodeClassLoader)
Deprecated.
Reads from a data input view a list of serializers and their corresponding config snapshots
written using
TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView, List) . |
Modifier and Type | Method and Description |
---|---|
static <T> CompatibilityResult<T> |
CompatibilityUtil.resolveCompatibilityResult(TypeSerializer<?> precedingSerializer,
Class<?> dummySerializerClassTag,
TypeSerializerSnapshot<?> precedingSerializerConfigSnapshot,
TypeSerializer<T> newSerializer)
Deprecated.
Resolves the final compatibility result of two serializers by taking into account compound information,
including the preceding serializer, the preceding serializer's configuration snapshot, and the new serializer.
|
static <T> CompatibilityResult<T> |
CompatibilityUtil.resolveCompatibilityResult(TypeSerializerSnapshot<T> precedingSerializerConfigSnapshot,
TypeSerializer<T> newSerializer)
Deprecated.
|
static <T> void |
TypeSerializerSnapshotSerializationUtil.writeSerializerSnapshot(DataOutputView out,
TypeSerializerSnapshot<T> serializerSnapshot,
TypeSerializer<T> serializer)
Writes a
TypeSerializerSnapshot to the provided data output view. |
static void |
TypeSerializerSnapshot.writeVersionedSnapshot(DataOutputView out,
TypeSerializerSnapshot<?> snapshot)
Writes the given snapshot to the out stream.
|
Modifier and Type | Method and Description |
---|---|
static void |
TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView out,
List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> serializersAndConfigs)
Deprecated.
Write a list of serializers and their corresponding config snapshots to the provided
data output view.
|
Modifier and Type | Class and Description |
---|---|
static class |
BigDecSerializer.BigDecSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
BigIntSerializer.BigIntSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
BooleanSerializer.BooleanSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
BooleanValueSerializer.BooleanValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
ByteSerializer.ByteSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
ByteValueSerializer.ByteValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
CharSerializer.CharSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
CharValueSerializer.CharValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
class |
CollectionSerializerConfigSnapshot<C extends Collection<T>,T>
Deprecated.
this snapshot class should no longer be used by any serializers as their snapshot.
|
static class |
DateSerializer.DateSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
DoubleSerializer.DoubleSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
DoubleValueSerializer.DoubleValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
EnumSerializer.EnumSerializerConfigSnapshot<T extends Enum<T>>
Configuration snapshot of a serializer for enumerations.
|
static class |
FloatSerializer.FloatSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
FloatValueSerializer.FloatValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
class |
GenericArraySerializerConfigSnapshot<C>
Point-in-time configuration of a
GenericArraySerializer . |
static class |
InstantSerializer.InstantSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
IntSerializer.IntSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
IntValueSerializer.IntValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
class |
ListSerializerSnapshot<T>
Snapshot class for the
ListSerializer . |
static class |
LongSerializer.LongSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
LongValueSerializer.LongValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
class |
MapSerializerConfigSnapshot<K,V>
Deprecated.
this snapshot class should not be used by any serializer anymore.
|
class |
MapSerializerSnapshot<K,V>
Snapshot class for the
MapSerializer . |
static class |
NullValueSerializer.NullValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
ShortSerializer.ShortSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
ShortValueSerializer.ShortValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
SqlDateSerializer.SqlDateSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
SqlTimeSerializer.SqlTimeSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
SqlTimestampSerializer.SqlTimestampSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
StringSerializer.StringSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
StringValueSerializer.StringValueSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
VoidSerializer.VoidSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
Modifier and Type | Class and Description |
---|---|
static class |
BooleanPrimitiveArraySerializer.BooleanPrimitiveArraySerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
BytePrimitiveArraySerializer.BytePrimitiveArraySerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
CharPrimitiveArraySerializer.CharPrimitiveArraySerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
DoublePrimitiveArraySerializer.DoublePrimitiveArraySerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
FloatPrimitiveArraySerializer.FloatPrimitiveArraySerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
IntPrimitiveArraySerializer.IntPrimitiveArraySerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
LongPrimitiveArraySerializer.LongPrimitiveArraySerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
ShortPrimitiveArraySerializer.ShortPrimitiveArraySerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
static class |
StringArraySerializer.StringArraySerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializerSnapshot<char[]> |
CharPrimitiveArraySerializer.snapshotConfiguration() |
TypeSerializerSnapshot<double[]> |
DoublePrimitiveArraySerializer.snapshotConfiguration() |
TypeSerializerSnapshot<byte[]> |
BytePrimitiveArraySerializer.snapshotConfiguration() |
TypeSerializerSnapshot<String[]> |
StringArraySerializer.snapshotConfiguration() |
TypeSerializerSnapshot<short[]> |
ShortPrimitiveArraySerializer.snapshotConfiguration() |
TypeSerializerSnapshot<boolean[]> |
BooleanPrimitiveArraySerializer.snapshotConfiguration() |
TypeSerializerSnapshot<float[]> |
FloatPrimitiveArraySerializer.snapshotConfiguration() |
TypeSerializerSnapshot<long[]> |
LongPrimitiveArraySerializer.snapshotConfiguration() |
TypeSerializerSnapshot<int[]> |
IntPrimitiveArraySerializer.snapshotConfiguration() |
Modifier and Type | Class and Description |
---|---|
static class |
CopyableValueSerializer.CopyableValueSerializerConfigSnapshot<T extends CopyableValue<T>> |
class |
EitherSerializerConfigSnapshot<L,R>
Deprecated.
|
class |
EitherSerializerSnapshot<L,R>
Configuration snapshot for the
EitherSerializer . |
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 |
---|---|
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
PojoSerializer.PojoSerializerConfigSnapshot.getFieldToSerializerConfigSnapshot() |
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
PojoSerializer.PojoSerializerConfigSnapshot.getNonRegisteredSubclassesToSerializerConfigSnapshots() |
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
PojoSerializer.PojoSerializerConfigSnapshot.getRegisteredSubclassesToSerializerConfigSnapshots() |
Constructor and Description |
---|
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots) |
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots) |
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots) |
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots,
boolean ignoreTypeSerializerSerialization) |
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots,
boolean ignoreTypeSerializerSerialization) |
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots,
boolean ignoreTypeSerializerSerialization) |
Modifier and Type | Class and Description |
---|---|
static class |
KryoSerializer.KryoSerializerConfigSnapshot<T> |
Modifier and Type | Class and Description |
---|---|
class |
ScalaEitherSerializerSnapshot<L,R>
Configuration snapshot for serializers of Scala's
Either type,
containing configuration snapshots of the Left and Right serializers. |
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 | Class and Description |
---|---|
class |
LockableTypeSerializerSnapshot<E>
|
Modifier and Type | Method and Description |
---|---|
TypeSerializerSnapshot<Lockable<E>> |
Lockable.LockableTypeSerializer.snapshotConfiguration() |
Modifier and Type | Class and Description |
---|---|
static class |
AvroSerializer.AvroSchemaSerializerConfigSnapshot<T>
Deprecated.
|
class |
AvroSerializerSnapshot<T>
An
Avro specific implementation of a TypeSerializerSnapshot . |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSnapshot<T> |
AvroSerializer.snapshotConfiguration() |
Modifier and Type | Class and Description |
---|---|
class |
ArrayListSerializerSnapshot<T>
Snapshot class for the
ArrayListSerializer . |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSnapshot<K> |
KeyedBackendSerializationProxy.getKeySerializerConfigSnapshot() |
TypeSerializerSnapshot<ArrayList<T>> |
ArrayListSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
static <T> StateSerializerProvider<T> |
StateSerializerProvider.fromRestoredState(TypeSerializerSnapshot<T> stateSerializerSnapshot)
Creates a
StateSerializerProvider for restored state from the previous serializer's snapshot. |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSnapshot<?> |
StateMetaInfoSnapshot.getTypeSerializerSnapshot(StateMetaInfoSnapshot.CommonSerializerKeys key) |
TypeSerializerSnapshot<?> |
StateMetaInfoSnapshot.getTypeSerializerSnapshot(String key) |
Modifier and Type | Method and Description |
---|---|
Map<String,TypeSerializerSnapshot<?>> |
StateMetaInfoSnapshot.getSerializerSnapshotsImmutable() |
Constructor and Description |
---|
StateMetaInfoSnapshot(String name,
StateMetaInfoSnapshot.BackendStateType backendStateType,
Map<String,String> options,
Map<String,TypeSerializerSnapshot<?>> serializerSnapshots) |
StateMetaInfoSnapshot(String name,
StateMetaInfoSnapshot.BackendStateType backendStateType,
Map<String,String> options,
Map<String,TypeSerializerSnapshot<?>> serializerSnapshots,
Map<String,TypeSerializer<?>> serializers)
TODO this variant, which requires providing the serializers,
TODO should actually be removed, leaving only
StateMetaInfoSnapshot.StateMetaInfoSnapshot(String, BackendStateType, Map, Map) . |
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 |
---|---|
static class |
TimerSerializer.TimerSerializerConfigSnapshot<K,N>
Snaphot of a
TimerSerializer . |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSnapshot<K> |
InternalTimersSnapshot.getKeySerializerConfigSnapshot() |
TypeSerializerSnapshot<N> |
InternalTimersSnapshot.getNamespaceSerializerConfigSnapshot() |
Modifier and Type | Method and Description |
---|---|
void |
InternalTimersSnapshot.setKeySerializerConfigSnapshot(TypeSerializerSnapshot<K> keySerializerConfigSnapshot) |
void |
InternalTimersSnapshot.setNamespaceSerializerConfigSnapshot(TypeSerializerSnapshot<N> namespaceSerializerConfigSnapshot) |
Constructor and Description |
---|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializerSnapshot<K> keySerializerConfigSnapshot,
TypeSerializer<N> namespaceSerializer,
TypeSerializerSnapshot<N> namespaceSerializerConfigSnapshot,
Set<TimerHeapInternalTimer<K,N>> eventTimeTimers,
Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializerSnapshot<K> keySerializerConfigSnapshot,
TypeSerializer<N> namespaceSerializer,
TypeSerializerSnapshot<N> namespaceSerializerConfigSnapshot,
Set<TimerHeapInternalTimer<K,N>> eventTimeTimers,
Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
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 | Class and Description |
---|---|
class |
ListViewSerializerSnapshot<T>
A
TypeSerializerSnapshot for the ListViewSerializer . |
class |
MapViewSerializerSnapshot<K,V>
A
TypeSerializerSnapshot for the MapViewSerializer . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.