GafferSink extends RichSinkFunction<Element> { @Override public void open(final Configuration parameters) throws Exception { super.open(parameters); adder.initialise(); } <OP extends Validatable & Operation> GafferSink(final OP validatable, final Store store);  GafferSink(final GafferAdder adder); @Override void open(final Configuration parameters); @Override void invoke(final Element element);  }
@Test public void shouldDelegateOpenToGafferAddedInitialise() throws Exception { final GafferAdder adder = mock(GafferAdder.class); final GafferSink sink = new GafferSink(adder); sink.open(null); verify(adder).initialise(); }