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
TypeSerializerConfigSnapshot s that do not have any parameters. |
Modifier and Type | Method and Description |
---|---|
static TypeSerializerConfigSnapshot |
TypeSerializerSerializationUtil.readSerializerConfigSnapshot(DataInputView in,
ClassLoader userCodeClassLoader)
Reads from a data input view a
TypeSerializerConfigSnapshot that was previously
written using TypeSerializerSerializationUtil.writeSerializerConfigSnapshot(DataOutputView, TypeSerializerConfigSnapshot) . |
static TypeSerializerConfigSnapshot[] |
TypeSerializerSerializationUtil.readSerializerConfigSnapshots(DataInputView in,
ClassLoader userCodeClassLoader)
Reads from a data input view multiple
TypeSerializerConfigSnapshot s that was previously
written using TypeSerializerSerializationUtil.writeSerializerConfigSnapshot(DataOutputView, TypeSerializerConfigSnapshot) . |
TypeSerializerConfigSnapshot |
TypeDeserializerAdapter.snapshotConfiguration() |
TypeSerializerConfigSnapshot |
UnloadableDummyTypeSerializer.snapshotConfiguration() |
abstract TypeSerializerConfigSnapshot |
TypeSerializer.snapshotConfiguration()
Create a snapshot of the serializer's current configuration to be stored along with the managed state it is
registered to (if any - this method is only relevant if this serializer is registered for serialization of
managed state).
|
Modifier and Type | Method and Description |
---|---|
List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
CompositeTypeSerializerConfigSnapshot.getNestedSerializersAndConfigs() |
Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> |
CompositeTypeSerializerConfigSnapshot.getSingleNestedSerializerAndConfig() |
static List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
TypeSerializerSerializationUtil.readSerializersAndConfigsWithResilience(DataInputView in,
ClassLoader userCodeClassLoader)
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 |
---|---|
CompatibilityResult<T> |
TypeDeserializerAdapter.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
UnloadableDummyTypeSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
abstract CompatibilityResult<T> |
TypeSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot)
Ensure compatibility of this serializer with a preceding serializer that was registered for serialization of
the same managed state (if any - this method is only relevant if this serializer is registered for
serialization of managed state).
|
static <T> CompatibilityResult<T> |
CompatibilityUtil.resolveCompatibilityResult(TypeSerializer<?> precedingSerializer,
Class<?> dummySerializerClassTag,
TypeSerializerConfigSnapshot precedingSerializerConfigSnapshot,
TypeSerializer<T> newSerializer)
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 void |
TypeSerializerSerializationUtil.writeSerializerConfigSnapshot(DataOutputView out,
TypeSerializerConfigSnapshot serializerConfigSnapshot)
Writes a
TypeSerializerConfigSnapshot to the provided data output view. |
static void |
TypeSerializerSerializationUtil.writeSerializerConfigSnapshots(DataOutputView out,
TypeSerializerConfigSnapshot... serializerConfigSnapshots)
Writes multiple
TypeSerializerConfigSnapshot s to the provided data output view. |
Modifier and Type | Method and Description |
---|---|
static void |
TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView out,
List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> serializersAndConfigs)
Write a list of serializers and their corresponding config snapshots to the provided
data output view.
|
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 | Method and Description |
---|---|
TypeSerializerConfigSnapshot |
TypeSerializerSingleton.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<C[]> |
GenericArraySerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
TypeSerializerSingleton.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<Map<K,V>> |
MapSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<List<T>> |
ListSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
EnumSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
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 | Method and Description |
---|---|
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
PojoSerializer.PojoSerializerConfigSnapshot.getFieldToSerializerConfigSnapshot() |
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
PojoSerializer.PojoSerializerConfigSnapshot.getNonRegisteredSubclassesToSerializerConfigSnapshots() |
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
PojoSerializer.PojoSerializerConfigSnapshot.getRegisteredSubclassesToSerializerConfigSnapshots() |
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<E>
A
TypeSerializerConfigSnapshot for the Scala TraversableSerializer . |
Modifier and Type | Method and Description |
---|---|
TypeSerializerConfigSnapshot |
NonDuplicatingTypeSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
NonDuplicatingTypeSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
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 | Method and Description |
---|---|
TypeSerializerConfigSnapshot |
NFA.NFASerializer.snapshotConfiguration() |
TypeSerializerConfigSnapshot |
SharedBuffer.SharedBufferSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<NFA<T>> |
NFA.NFASerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<SharedBuffer<K,V>> |
SharedBuffer.SharedBufferSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
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 | Method and Description |
---|---|
TypeSerializerConfigSnapshot |
BackwardsCompatibleAvroSerializer.snapshotConfiguration() |
TypeSerializerConfigSnapshot |
AvroSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
BackwardsCompatibleAvroSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
AvroSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerConfigSnapshot |
KeyedBackendSerializationProxy.getKeySerializerConfigSnapshot() |
TypeSerializerConfigSnapshot |
RegisteredKeyedBackendStateMetaInfo.Snapshot.getNamespaceSerializerConfigSnapshot() |
TypeSerializerConfigSnapshot |
RegisteredOperatorBackendStateMetaInfo.Snapshot.getPartitionStateSerializerConfigSnapshot() |
TypeSerializerConfigSnapshot |
RegisteredKeyedBackendStateMetaInfo.Snapshot.getStateSerializerConfigSnapshot() |
TypeSerializerConfigSnapshot |
ArrayListSerializer.snapshotConfiguration() |
TypeSerializerConfigSnapshot |
HashMapSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<ArrayList<T>> |
ArrayListSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<HashMap<K,V>> |
HashMapSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
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.StateSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> |
TwoPhaseCommitSinkFunction.StateSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerConfigSnapshot |
InternalTimersSnapshot.getKeySerializerConfigSnapshot() |
TypeSerializerConfigSnapshot |
InternalTimersSnapshot.getNamespaceSerializerConfigSnapshot() |
TypeSerializerConfigSnapshot |
InternalTimer.TimerSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<InternalTimer<K,N>> |
InternalTimer.TimerSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
void |
InternalTimersSnapshot.setKeySerializerConfigSnapshot(TypeSerializerConfigSnapshot keySerializerConfigSnapshot) |
void |
InternalTimersSnapshot.setNamespaceSerializerConfigSnapshot(TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot) |
Constructor and Description |
---|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializerConfigSnapshot keySerializerConfigSnapshot,
TypeSerializer<N> namespaceSerializer,
TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot,
Set<InternalTimer<K,N>> eventTimeTimers,
Set<InternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
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) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.