Modifier and Type | Method and Description |
---|---|
static <T> CompatibilityResult<T> |
CompatibilityResult.compatible()
Returns a result that signals that the new serializer is compatible and no migration is required.
|
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).
|
CompatibilityResult<T> |
TypeDeserializerAdapter.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
static <T> CompatibilityResult<T> |
CompatibilityResult.requiresMigration()
Returns a result that signals migration to be performed.
|
static <T> CompatibilityResult<T> |
CompatibilityResult.requiresMigration(TypeDeserializer<T> convertDeserializer)
Returns a result that signals migration to be performed, and in the case that the preceding serializer
cannot be found or restored to read the previous data during migration, a provided convert deserializer
can be used.
|
static <T> CompatibilityResult<T> |
CompatibilityResult.requiresMigration(TypeSerializer<T> convertSerializer)
Returns a result that signals migration to be performed, and in the case that the preceding serializer
cannot be found or restored to read the previous data during migration, a provided convert serializer
can be used.
|
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.
|
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
TypeSerializerSingleton.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<Map<K,V>> |
MapSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<List<T>> |
ListSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<C[]> |
GenericArraySerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
EnumSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
WritableSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
ValueSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
TupleSerializerBase.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<Row> |
RowSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
PojoSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<Either<L,R>> |
EitherSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
CopyableValueSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
AvroSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
KryoSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
TraversableSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<Object> |
NothingSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<scala.Option<A>> |
OptionSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
EitherSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<scala.util.Try<A>> |
TrySerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<scala.Enumeration.Value> |
EnumValueSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<T> |
NonDuplicatingTypeSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<SharedBuffer<K,V>> |
SharedBuffer.SharedBufferSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<NFA<T>> |
NFA.NFASerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<Serializable> |
MigrationNamespaceSerializerProxy.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<StreamRecord<T>> |
StreamRecordSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<StreamElement> |
MultiplexingStreamRecordSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<HashMap<K,V>> |
HashMapSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<ArrayList<T>> |
ArrayListSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<InternalTimer<K,N>> |
InternalTimer.TimerSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<StreamElement> |
StreamElementSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<CRow> |
CRowSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.