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> |
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> |
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<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 | Method and Description |
---|---|
CompatibilityResult<T> |
AvroSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot)
Deprecated.
|
CompatibilityResult<T> |
WritableSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
ValueSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<Either<L,R>> |
EitherSerializer.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 | Method and Description |
---|---|
CompatibilityResult<T> |
KryoSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
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 | Method and Description |
---|---|
CompatibilityResult<T> |
BackwardsCompatibleAvroSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
CompatibilityResult<T> |
AvroSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<ArrayList<T>> |
ArrayListSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> |
TwoPhaseCommitSinkFunction.StateSerializer.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) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.