@Test
public void getCustomFormatter() {

  SequenceFileSerializer formatter = SequenceFileSerializerFactory.getSerializer(
      "org.apache.flume.sink.hdfs.MyCustomSerializer$Builder", new Context());
  assertTrue(formatter != null);
  assertTrue(formatter.getClass().getName(),
      formatter instanceof MyCustomSerializer);
}