class OperatorCoordinatorHolder implements OperatorCoordinator, OperatorCoordinatorCheckpointContext {

	@Override
	public void resetToCheckpoint(byte[] checkpointData) throws Exception {
		// ideally we would like to check this here, however this method is called early during
		// execution graph construction, before the main thread executor is set

		eventValve.reset();
		coordinator.resetToCheckpoint(checkpointData);
	}

	private  OperatorCoordinatorHolder(
			final OperatorID operatorId,
			final OperatorCoordinator coordinator,
			final LazyInitializedCoordinatorContext context,
			final OperatorEventValve eventValve,
			final int operatorParallelism,
			final int operatorMaxParallelism);

}