class ChannelStateWriterImpl implements ChannelStateWriter {

	public void open() {
		executor.start();
	}

	public  ChannelStateWriterImpl(String taskName, CheckpointStorageWorkerView streamFactoryResolver);
	  ChannelStateWriterImpl(String taskName, CheckpointStorageWorkerView streamFactoryResolver, int maxCheckpoints);
	  ChannelStateWriterImpl(
			String taskName,
			ConcurrentMap<Long, ChannelStateWriteResult> results,
			ChannelStateWriteRequestExecutor executor,
			int maxCheckpoints);

}