@Test
public void testGenCollector() throws FlumeSpecException {

  EventSink snk = FlumeBuilder.buildSink(LogicalNodeContext.testingContext(),
      "collector() { customDfsSink(\"file:///tmp/foo\",\"foo\") }");
  assertTrue(snk instanceof CollectorSink);
}