class InputProcessorUtil {

	public static CheckpointedInputGate[] createCheckpointedMultipleInputGate(
			AbstractInvokable toNotifyOnCheckpoint,
			StreamConfig config,
			SubtaskCheckpointCoordinator checkpointCoordinator,
			TaskIOMetricGroup taskIOMetricGroup,
			String taskName,
			MailboxExecutor mailboxExecutor,
			List<IndexedInputGate>[] inputGates,
			List<StreamTaskSourceInput<?>> sourceInputs) {
		CheckpointBarrierHandler barrierHandler = createCheckpointBarrierHandler(
			toNotifyOnCheckpoint,
			config,
			checkpointCoordinator,
			taskName,
			inputGates,
			sourceInputs);
		return createCheckpointedMultipleInputGate(
			mailboxExecutor,
			inputGates,
			taskIOMetricGroup,
			barrierHandler);
	}

}