@Test public void testCheckProducingPipelinedInput() { final List<TestingSchedulingResultPartition> partitions = addResultPartition() .withPartitionType(PIPELINED) .withPartitionState(PRODUCING) .finish(); final TestingSchedulingExecutionVertex vertex = addSchedulingExecutionVertex() .withConsumedPartitions(partitions) .finish(); final InputDependencyConstraintChecker inputChecker = createInputDependencyConstraintChecker(partitions); assertTrue(inputChecker.check(vertex)); }
public boolean check(final SchedulingExecutionVertex schedulingExecutionVertex) { final InputDependencyConstraint inputConstraint = schedulingExecutionVertex.getInputDependencyConstraint(); if (schedulingExecutionVertex.getConsumedResultPartitions().isEmpty() || ALL.equals(inputConstraint)) { return checkAll(schedulingExecutionVertex); } else if (ANY.equals(inputConstraint)) { return checkAny(schedulingExecutionVertex); } else { throw new IllegalArgumentException(); } }
InputDependencyConstraintChecker { public boolean check(final SchedulingExecutionVertex schedulingExecutionVertex) { final InputDependencyConstraint inputConstraint = schedulingExecutionVertex.getInputDependencyConstraint(); if (schedulingExecutionVertex.getConsumedResultPartitions().isEmpty() || ALL.equals(inputConstraint)) { return checkAll(schedulingExecutionVertex); } else if (ANY.equals(inputConstraint)) { return checkAny(schedulingExecutionVertex); } else { throw new IllegalArgumentException(); } } }
InputDependencyConstraintChecker { public boolean check(final SchedulingExecutionVertex schedulingExecutionVertex) { final InputDependencyConstraint inputConstraint = schedulingExecutionVertex.getInputDependencyConstraint(); if (schedulingExecutionVertex.getConsumedResultPartitions().isEmpty() || ALL.equals(inputConstraint)) { return checkAll(schedulingExecutionVertex); } else if (ANY.equals(inputConstraint)) { return checkAny(schedulingExecutionVertex); } else { throw new IllegalArgumentException(); } }  }
InputDependencyConstraintChecker { public boolean check(final SchedulingExecutionVertex schedulingExecutionVertex) { final InputDependencyConstraint inputConstraint = schedulingExecutionVertex.getInputDependencyConstraint(); if (schedulingExecutionVertex.getConsumedResultPartitions().isEmpty() || ALL.equals(inputConstraint)) { return checkAll(schedulingExecutionVertex); } else if (ANY.equals(inputConstraint)) { return checkAny(schedulingExecutionVertex); } else { throw new IllegalArgumentException(); } }  boolean check(final SchedulingExecutionVertex schedulingExecutionVertex); }
InputDependencyConstraintChecker { public boolean check(final SchedulingExecutionVertex schedulingExecutionVertex) { final InputDependencyConstraint inputConstraint = schedulingExecutionVertex.getInputDependencyConstraint(); if (schedulingExecutionVertex.getConsumedResultPartitions().isEmpty() || ALL.equals(inputConstraint)) { return checkAll(schedulingExecutionVertex); } else if (ANY.equals(inputConstraint)) { return checkAny(schedulingExecutionVertex); } else { throw new IllegalArgumentException(); } }  boolean check(final SchedulingExecutionVertex schedulingExecutionVertex);  }