public class CommittableSerializer extends Object implements org.apache.flink.core.io.SimpleVersionedSerializer<Committable>
SimpleVersionedSerializer
for Committable
.Constructor and Description |
---|
CommittableSerializer(CommitMessageSerializer commitMessageSerializer) |
Modifier and Type | Method and Description |
---|---|
Committable |
deserialize(int committableVersion,
byte[] bytes) |
int |
getVersion() |
byte[] |
serialize(Committable committable) |
public CommittableSerializer(CommitMessageSerializer commitMessageSerializer)
public int getVersion()
getVersion
in interface org.apache.flink.core.io.SimpleVersionedSerializer<Committable>
getVersion
in interface org.apache.flink.core.io.Versioned
public byte[] serialize(Committable committable) throws IOException
serialize
in interface org.apache.flink.core.io.SimpleVersionedSerializer<Committable>
IOException
public Committable deserialize(int committableVersion, byte[] bytes) throws IOException
deserialize
in interface org.apache.flink.core.io.SimpleVersionedSerializer<Committable>
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.