@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);
}