class CassandraSinkBase extends RichSinkFunction<IN> implements CheckpointedFunction {

	@Override
	public void invoke(IN value) throws Exception {
		checkAsyncErrors();
		tryAcquire();
		final ListenableFuture<V> result = send(value);
		Futures.addCallback(result, callback);
	}

	  CassandraSinkBase(ClusterBuilder builder, CassandraSinkBaseConfig config, CassandraFailureHandler failureHandler);

}