Package io.github.flink.gcp.connector.cloudtasks.sink

Class CloudTasksCommittableSerializer

java.lang.Object

io.github.flink.gcp.connector.cloudtasks.sink.CloudTasksCommittableSerializer

All Implemented Interfaces:

org.apache.flink.core.io.SimpleVersionedSerializer<CloudTasksCommittable>, org.apache.flink.core.io.Versioned

@Internal
public final class CloudTasksCommittableSerializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<CloudTasksCommittable>

Bounded v1 framing for one envelope; the Flink collector owns batch counts and redistribution.

Constructor Summary

Constructors

Constructor	Description
CloudTasksCommittableSerializer()

Method Summary

Modifier and Type	Method	Description
CloudTasksCommittable	deserialize(int version, byte[] bytes)
int	getVersion()
byte[]	serialize(CloudTasksCommittable envelope)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CloudTasksCommittableSerializer

public CloudTasksCommittableSerializer()

Method Details

getVersion

public int getVersion()

Specified by:

getVersion in interface org.apache.flink.core.io.SimpleVersionedSerializer<CloudTasksCommittable>

Specified by:

getVersion in interface org.apache.flink.core.io.Versioned

serialize

public byte[] serialize(CloudTasksCommittable envelope)
                 throws IOException

Specified by:

serialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<CloudTasksCommittable>

Throws:

IOException

deserialize

public CloudTasksCommittable deserialize(int version,
 byte[] bytes)
                                  throws IOException

Specified by:

deserialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<CloudTasksCommittable>

Throws:

IOException