public class MultiTableCommittableSerializer extends Object implements org.apache.flink.core.io.SimpleVersionedSerializer<MultiTableCommittable>
SimpleVersionedSerializer
for MultiTableCommittable
. If a type info class is
using this this serde of MultiTableCommittable. It should make sure that the operator that
produces it will include the database, table, and commit user information. This can be done by
calling MultiTableCommittable::fromCommittable.Constructor and Description |
---|
MultiTableCommittableSerializer(CommitMessageSerializer commitMessageSerializer) |
Modifier and Type | Method and Description |
---|---|
MultiTableCommittable |
deserialize(int committableVersion,
byte[] bytes) |
Committable |
deserializeCommittable(int committableVersion,
byte[] bytes) |
int |
getVersion() |
byte[] |
serialize(MultiTableCommittable committable) |
byte[] |
serializeCommittable(MultiTableCommittable committable) |
public MultiTableCommittableSerializer(CommitMessageSerializer commitMessageSerializer)
public int getVersion()
getVersion
in interface org.apache.flink.core.io.SimpleVersionedSerializer<MultiTableCommittable>
getVersion
in interface org.apache.flink.core.io.Versioned
public byte[] serialize(MultiTableCommittable committable) throws IOException
serialize
in interface org.apache.flink.core.io.SimpleVersionedSerializer<MultiTableCommittable>
IOException
public MultiTableCommittable deserialize(int committableVersion, byte[] bytes) throws IOException
deserialize
in interface org.apache.flink.core.io.SimpleVersionedSerializer<MultiTableCommittable>
IOException
public byte[] serializeCommittable(MultiTableCommittable committable) throws IOException
IOException
public Committable deserializeCommittable(int committableVersion, byte[] bytes) throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.