Skip to content

Commit 0f9b29a

Browse files
author
arvid
committed
Merge remote-tracking branch 'hpi/master'
2 parents c68c67b + 25f3474 commit 0f9b29a

File tree

34 files changed

+21
-2251
lines changed

34 files changed

+21
-2251
lines changed

pact/pact-tests/bin/pom.xml

Lines changed: 0 additions & 154 deletions
This file was deleted.

pact/pact-tests/bin/src/test/resources/TestPlan/expected.json

Lines changed: 0 additions & 1 deletion
This file was deleted.

pact/pact-tests/bin/src/test/resources/TestPlan/test.json

Lines changed: 0 additions & 25 deletions
This file was deleted.

sopremo/sopremo-common/bin/Jaql.tokens

Lines changed: 0 additions & 94 deletions
This file was deleted.

sopremo/sopremo-common/bin/JaqlTree.tokens

Lines changed: 0 additions & 94 deletions
This file was deleted.

sopremo/sopremo-common/src/main/java/eu/stratosphere/sopremo/testing/SopremoTestPlan.java

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -396,6 +396,25 @@ public void setInputOperator(final int index, final Source operator) {
396396
public void setOutputOperator(final int index, final Sink operator) {
397397
this.actualOutputs[index].setOperator(operator);
398398
}
399+
400+
401+
/**
402+
* Returns the degree of parallelism of the
403+
* test plan.
404+
*/
405+
public int getDegreeOfParallelism() {
406+
return this.testPlan.getDegreeOfParallelism();
407+
}
408+
409+
/**
410+
* Returns the degree of parallelism of the
411+
* test plan.
412+
*/
413+
public void setDegreeOfParallelism(final int dop) {
414+
if (dop < 1)
415+
throw new IllegalArgumentException("Degree of parallelism must be greater than 0!");
416+
this.testPlan.setDegreeOfParallelism(dop);
417+
}
399418

400419
@Override
401420
public String toString() {

0 commit comments

Comments
 (0)