class GafferSink extends RichSinkFunction<Element> {

    @Override
    public void invoke(final Element element) throws Exception {
        adder.add(element);
    }

    public <OP extends Validatable & Operation> GafferSink(final OP validatable, final Store store);
    public  GafferSink(final GafferAdder adder);

}