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