ColumnSerializationUtil { public static Serializable deserializeColumn( @NonNull final Map<String, ByteBuffer> entity, @NonNull final String column) { final ByteBuffer byteBuffer = entity.get(column); if (byteBuffer == null) { return null; } final ByteBufferInputStream inputStream = new ByteBufferInputStream(byteBuffer); return (Serializable) SerializationUtils.deserialize(inputStream); }  static byte[] serializeColumn(@NonNull final Column oldColumn); static Serializable deserializeColumn(
      @NonNull final Map<String, ByteBuffer> entity, @NonNull final String column);  }
@Test public void testDeserializeColumn() throws Exception { Mutation mutation = new Mutation( MutationType.DELETE, TIMESTAMP, SOURCE_ID, DATA_SOURCE, BINLOG_HEADER, TABLE, getEntity()); TSerializer serializer = new TSerializer(new TBinaryProtocol.Factory()); TDeserializer deserializer = new TDeserializer(new TBinaryProtocol.Factory()); byte[] serialized = serializer.serialize(mutation); Mutation deserialized = new Mutation(); deserializer.deserialize(deserialized, serialized); assertEquals(mutation, deserialized); }