class Emitter implements Runnable {

	public void stop() {
		running = false;
	}

	public  Emitter(
			final Object checkpointLock,
			final Output<StreamRecord<OUT>> output,
			final StreamElementQueue streamElementQueue,
			final OperatorActions operatorActions);

}