class SourceCoordinatorContext implements SplitEnumeratorContext<SplitT>, AutoCloseable {

	@Override
	public Map<Integer, ReaderInfo> registeredReaders() {
		return Collections.unmodifiableMap(registeredReaders);
	}

	public  SourceCoordinatorContext(
			ExecutorService coordinatorExecutor,
			SourceCoordinatorProvider.CoordinatorExecutorThreadFactory coordinatorThreadFactory,
			int numWorkerThreads,
			OperatorCoordinator.Context operatorCoordinatorContext,
			SimpleVersionedSerializer<SplitT> splitSerializser);
	  SourceCoordinatorContext(
			ExecutorService coordinatorExecutor,
			SourceCoordinatorProvider.CoordinatorExecutorThreadFactory coordinatorThreadFactory,
			int numWorkerThreads,
			OperatorCoordinator.Context operatorCoordinatorContext,
			SimpleVersionedSerializer<SplitT> splitSerializer,
			SplitAssignmentTracker<SplitT> splitAssignmentTracker);

}