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