public class VersionedSerializerWrapper<T> extends Object implements org.apache.flink.core.io.SimpleVersionedSerializer<T>
VersionedSerializer
to SimpleVersionedSerializer
.Constructor and Description |
---|
VersionedSerializerWrapper(VersionedSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
T |
deserialize(int version,
byte[] serialized) |
int |
getVersion() |
byte[] |
serialize(T obj) |
public VersionedSerializerWrapper(VersionedSerializer<T> serializer)
public int getVersion()
getVersion
in interface org.apache.flink.core.io.SimpleVersionedSerializer<T>
getVersion
in interface org.apache.flink.core.io.Versioned
public byte[] serialize(T obj) throws IOException
serialize
in interface org.apache.flink.core.io.SimpleVersionedSerializer<T>
IOException
public T deserialize(int version, byte[] serialized) throws IOException
deserialize
in interface org.apache.flink.core.io.SimpleVersionedSerializer<T>
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.