@Test public void testCircleCondition() throws Exception { DataSet<Embedding> candidateEdges = getExecutionEnvironment().fromElements( createEmbedding(b, e1, c), createEmbedding(b, e2, a) ); DataSet<Embedding> input = getExecutionEnvironment().fromElements( createEmbedding(a, e0, b) ); ExpandEmbeddings op = getOperator( input, candidateEdges, 2, 1, 2, ExpandDirection.OUT, new ArrayList<>(), new ArrayList<>(), 0 ); DataSet<Embedding> result = op.evaluate(); assertEquals(1, result.count()); assertEmbeddingExists(result, a, e0, b, e2, a); }
@Override public DataSet<Embedding> evaluate() { DataSet<ExpandEmbedding> initialWorkingSet = preProcess(); DataSet<ExpandEmbedding> iterationResults = iterate(initialWorkingSet); return postProcess(iterationResults); }
ExpandEmbeddings implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { DataSet<ExpandEmbedding> initialWorkingSet = preProcess(); DataSet<ExpandEmbedding> iterationResults = iterate(initialWorkingSet); return postProcess(iterationResults); } }
ExpandEmbeddings implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { DataSet<ExpandEmbedding> initialWorkingSet = preProcess(); DataSet<ExpandEmbedding> iterationResults = iterate(initialWorkingSet); return postProcess(iterationResults); } ExpandEmbeddings(DataSet<Embedding> input, DataSet<Embedding> candidateEdges,
    int expandColumn, int lowerBound, int upperBound, ExpandDirection direction,
    List<Integer> distinctVertexColumns, List<Integer> distinctEdgeColumns, int closingColumn,
    JoinOperatorBase.JoinHint joinHint); }
ExpandEmbeddings implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { DataSet<ExpandEmbedding> initialWorkingSet = preProcess(); DataSet<ExpandEmbedding> iterationResults = iterate(initialWorkingSet); return postProcess(iterationResults); } ExpandEmbeddings(DataSet<Embedding> input, DataSet<Embedding> candidateEdges,
    int expandColumn, int lowerBound, int upperBound, ExpandDirection direction,
    List<Integer> distinctVertexColumns, List<Integer> distinctEdgeColumns, int closingColumn,
    JoinOperatorBase.JoinHint joinHint); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName(); }
ExpandEmbeddings implements PhysicalOperator { @Override public DataSet<Embedding> evaluate() { DataSet<ExpandEmbedding> initialWorkingSet = preProcess(); DataSet<ExpandEmbedding> iterationResults = iterate(initialWorkingSet); return postProcess(iterationResults); } ExpandEmbeddings(DataSet<Embedding> input, DataSet<Embedding> candidateEdges,
    int expandColumn, int lowerBound, int upperBound, ExpandDirection direction,
    List<Integer> distinctVertexColumns, List<Integer> distinctEdgeColumns, int closingColumn,
    JoinOperatorBase.JoinHint joinHint); @Override DataSet<Embedding> evaluate(); @Override void setName(String newName); @Override String getName();  }