Interface IKVSerializer
- All Known Implementing Classes:
KVSerializer
@Private
public interface IKVSerializer
serializes key-value pair
-
Method Summary
Modifier and TypeMethodDescriptionintdeserializeKV(DataInputStream in, SizedWritable<?> key, SizedWritable<?> value) intserializeKV(DataOutputStream out, SizedWritable<?> key, SizedWritable<?> value) intserializePartitionKV(DataOutputStream out, int partitionId, SizedWritable<?> key, SizedWritable<?> value) voidupdateLength(SizedWritable<?> key, SizedWritable<?> value) update the length field of SizedWritable
-
Method Details
-
updateLength
update the length field of SizedWritable- Throws:
IOException
-
serializeKV
int serializeKV(DataOutputStream out, SizedWritable<?> key, SizedWritable<?> value) throws IOException - Throws:
IOException
-
serializePartitionKV
int serializePartitionKV(DataOutputStream out, int partitionId, SizedWritable<?> key, SizedWritable<?> value) throws IOException - Throws:
IOException
-
deserializeKV
int deserializeKV(DataInputStream in, SizedWritable<?> key, SizedWritable<?> value) throws IOException - Throws:
IOException
-