Package | Description |
---|---|
org.apache.flink.api.common.typeutils |
Modifier and Type | Class and Description |
---|---|
class |
TypeDeserializerAdapter<T>
A utility class that is used to bridge a
TypeSerializer and TypeDeserializer . |
Modifier and Type | Method and Description |
---|---|
TypeDeserializer<T> |
CompatibilityResult.getConvertDeserializer() |
Modifier and Type | Method and Description |
---|---|
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.
|
Constructor and Description |
---|
TypeDeserializerAdapter(TypeDeserializer<T> deserializer)
Creates a
TypeDeserializerAdapter that wraps a TypeDeserializer . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.