class SourceCoordinatorContext implements SplitEnumeratorContext<SplitT>, AutoCloseable {

	void unregisterSourceReader(int subtaskId) {
		registeredReaders.remove(subtaskId);
	}

	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);

}