class CheckpointBarrierUnaligner extends CheckpointBarrierHandler {

	@Override
	public long getLatestCheckpointId() {
		return currentCheckpointId;
	}

	  CheckpointBarrierUnaligner(
			SubtaskCheckpointCoordinator checkpointCoordinator,
			String taskName,
			AbstractInvokable toNotifyOnCheckpoint,
			CheckpointableInput... inputs);

}