class SourceCoordinator implements OperatorCoordinator {

	@Override
	public void start() throws Exception {
		LOG.info("Starting split enumerator for source {}.", operatorName);
		enumerator.start();
		started = true;
	}

	public  SourceCoordinator(
			String operatorName,
			ExecutorService coordinatorExecutor,
			Source<?, SplitT, EnumChkT> source,
			SourceCoordinatorContext<SplitT> context);

}