ds_state_processor_blog_5.java

public static <T> void writeVersionAndSerialize(
        SimpleVersionedSerializer<T> serializer, T datum, DataOutputView out)
        throws IOException {
    checkNotNull(serializer, "serializer");
    checkNotNull(datum, "datum");
    checkNotNull(out, "out");

    final byte[] data = serializer.serialize(datum);

    out.writeInt(serializer.getVersion());
    out.writeInt(data.length);
    out.write(data);
}