class ChannelStateCheckpointWriter {

	void writeInput(InputChannelInfo info, Buffer buffer) throws Exception {
		write(inputChannelOffsets, info, buffer, !allInputsReceived);
	}

	  ChannelStateCheckpointWriter(
			CheckpointStartRequest startCheckpointItem,
			CheckpointStreamFactory streamFactory,
			ChannelStateSerializer serializer,
			RunnableWithException onComplete);
	  ChannelStateCheckpointWriter(
			long checkpointId,
			ChannelStateWriteResult result,
			CheckpointStateOutputStream stream,
			ChannelStateSerializer serializer,
			RunnableWithException onComplete);
	  ChannelStateCheckpointWriter(
			long checkpointId,
			ChannelStateWriteResult result,
			ChannelStateSerializer serializer,
			RunnableWithException onComplete,
			CheckpointStateOutputStream checkpointStateOutputStream,
			DataOutputStream dataStream);

}