@Test
public void testDigestBuilder() throws IOException, FlumeSpecException, InterruptedException {

  EventSink snk =
      new CompositeSink(new Context(),
          "{ digest(\"MD5\", \"digest\") => counter(\"count\") }");
  snk.open();
  Event e = new EventImpl("content".getBytes());
  snk.append(e);
  snk.close();
}