@Test public void shouldPerformThetaTwoSourceJoinWithReversedInputs() { final SopremoTestPlan sopremoPlan = new SopremoTestPlan(2, 1); final BinaryBooleanExpression condition = new ComparativeExpression(createPath("1", "id"), BinaryOperator.LESS, createPath("0", "userid")); final TwoSourceJoin join = new TwoSourceJoin().withCondition(condition); join.setInputs(sopremoPlan.getInputOperators(0, 2)); join.setResultProjection(ObjectCreation.CONCATENATION); sopremoPlan.getOutputOperator(0).setInputs(join); sopremoPlan.getInput(1). addObject("name", "Jon Doe", "password", "asdf1234", "id", 1). addObject("name", "Jane Doe", "password", "qwertyui", "id", 2). addObject("name", "Max Mustermann", "password", "q1w2e3r4", "id", 3); sopremoPlan.getInput(0). addObject("userid", 1, "url", "code.google.com/p/jaql/"). addObject("userid", 2, "url", "www.cnn.com"). addObject("userid", 4, "url", "www.nbc.com"). addObject("userid", 1, "url", "java.sun.com/javase/6/docs/api/"); sopremoPlan.getExpectedOutput(0). addObject("name", "Jon Doe", "password", "asdf1234", "id", 1, "userid", 2, "url", "www.cnn.com"). addObject("name", "Jon Doe", "password", "asdf1234", "id", 1, "userid", 4, "url", "www.nbc.com"). addObject("name", "Jane Doe", "password", "qwertyui", "id", 2, "userid", 4, "url", "www.nbc.com"). addObject("name", "Max Mustermann", "password", "q1w2e3r4", "id", 3, "userid", 4, "url", "www.nbc.com"); sopremoPlan.run(); }
public TwoSourceJoin withCondition(final BinaryBooleanExpression condition) { this.setCondition(condition); return this; }
TwoSourceJoin extends TwoSourceJoinBase<TwoSourceJoin> { public TwoSourceJoin withCondition(final BinaryBooleanExpression condition) { this.setCondition(condition); return this; } }
TwoSourceJoin extends TwoSourceJoinBase<TwoSourceJoin> { public TwoSourceJoin withCondition(final BinaryBooleanExpression condition) { this.setCondition(condition); return this; } TwoSourceJoin(); }
TwoSourceJoin extends TwoSourceJoinBase<TwoSourceJoin> { public TwoSourceJoin withCondition(final BinaryBooleanExpression condition) { this.setCondition(condition); return this; } TwoSourceJoin(); @Override void appendAsString(final Appendable appendable); @Override PactModule asPactModule(); @Override boolean equals(final Object obj); BinaryBooleanExpression getCondition(); @Override List<? extends EvaluationExpression> getKeyExpressions(final int inputIndex); int[] getOuterJoinIndices(); EvaluationExpression getOuterJoinSources(); @Override int hashCode(); @Property void setCondition(final BinaryBooleanExpression condition); void setOuterJoinIndices(final int... outerJoinIndices); @Property @Name(verb = "preserve") void setOuterJoinSources(final EvaluationExpression outerJoinSources); TwoSourceJoin withCondition(final BinaryBooleanExpression condition); TwoSourceJoin withOuterJoinIndices(final int... outerJoinIndices); TwoSourceJoin withOuterJoinSources(final EvaluationExpression outerJoinSources); }
TwoSourceJoin extends TwoSourceJoinBase<TwoSourceJoin> { public TwoSourceJoin withCondition(final BinaryBooleanExpression condition) { this.setCondition(condition); return this; } TwoSourceJoin(); @Override void appendAsString(final Appendable appendable); @Override PactModule asPactModule(); @Override boolean equals(final Object obj); BinaryBooleanExpression getCondition(); @Override List<? extends EvaluationExpression> getKeyExpressions(final int inputIndex); int[] getOuterJoinIndices(); EvaluationExpression getOuterJoinSources(); @Override int hashCode(); @Property void setCondition(final BinaryBooleanExpression condition); void setOuterJoinIndices(final int... outerJoinIndices); @Property @Name(verb = "preserve") void setOuterJoinSources(final EvaluationExpression outerJoinSources); TwoSourceJoin withCondition(final BinaryBooleanExpression condition); TwoSourceJoin withOuterJoinIndices(final int... outerJoinIndices); TwoSourceJoin withOuterJoinSources(final EvaluationExpression outerJoinSources);  }