@Test public void shouldPerformAntiJoin2() { final SopremoTestPlan sopremoPlan = new SopremoTestPlan(2, 1); final EvaluationExpression leftTwoSourceJoinKey = new ArrayCreation(JsonUtil.createPath("0", "v3", "worksFor")); final EvaluationExpression rightTwoSourceJoinKey = new ArrayCreation(JsonUtil.createPath("1", "v3", "worksFor")); final BinaryBooleanExpression condition = new ElementInSetExpression(leftTwoSourceJoinKey, Quantor.EXISTS_NOT_IN, rightTwoSourceJoinKey); final TwoSourceJoin join = new TwoSourceJoin().withCondition(condition); join.setInputs(sopremoPlan.getInputOperators(0, 2)); join.setResultProjection(ObjectCreation.CONCATENATION); sopremoPlan.getOutputOperator(0).setInputs(join); sopremoPlan.getInput(0). addObject("v3", JsonUtil.createObjectNode("id", null, "worksFor", "CompanyABC")). addObject("v3", JsonUtil.createObjectNode("id", null, "worksFor", "CompanyUVW")). addObject("v3", JsonUtil.createObjectNode("id", null, "worksFor", "CompanyXYZ")); sopremoPlan.getInput(1). addObject("v3", JsonUtil.createObjectNode("id", null, "worksFor", "CompanyUVW")). addObject("v3", JsonUtil.createObjectNode("id", null, "worksFor", "CompanyXYZ")); sopremoPlan.getExpectedOutput(0). addObject("v3", JsonUtil.createObjectNode("id", null, "worksFor", "CompanyABC")); sopremoPlan.trace(); 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);  }