@Test public void getVertices() throws Exception { TxCollectionLayout layout = new TxCollectionLayout( getExecutionEnvironment().fromElements(tx0, tx1)); Set<EPGMVertex> expected = Sets.newHashSet(tx0.getVertices()); expected.addAll(tx1.getVertices()); GradoopTestUtils.validateGraphElementCollections(expected, layout.getVertices().collect()); }
@Override public DataSet<EPGMVertex> getVertices() { return transactions .flatMap(new TransactionVertices<>()) .distinct(new Id<>()); }
TxCollectionLayout implements GraphCollectionLayout<EPGMGraphHead, EPGMVertex, EPGMEdge> { @Override public DataSet<EPGMVertex> getVertices() { return transactions .flatMap(new TransactionVertices<>()) .distinct(new Id<>()); } }
TxCollectionLayout implements GraphCollectionLayout<EPGMGraphHead, EPGMVertex, EPGMEdge> { @Override public DataSet<EPGMVertex> getVertices() { return transactions .flatMap(new TransactionVertices<>()) .distinct(new Id<>()); } TxCollectionLayout(DataSet<GraphTransaction> transactions); }
TxCollectionLayout implements GraphCollectionLayout<EPGMGraphHead, EPGMVertex, EPGMEdge> { @Override public DataSet<EPGMVertex> getVertices() { return transactions .flatMap(new TransactionVertices<>()) .distinct(new Id<>()); } TxCollectionLayout(DataSet<GraphTransaction> transactions); @Override boolean isGVELayout(); @Override boolean isIndexedGVELayout(); @Override boolean isTransactionalLayout(); @Override DataSet<EPGMGraphHead> getGraphHeads(); @Override DataSet<EPGMGraphHead> getGraphHeadsByLabel(String label); @Override DataSet<GraphTransaction> getGraphTransactions(); @Override DataSet<EPGMVertex> getVertices(); @Override DataSet<EPGMVertex> getVerticesByLabel(String label); @Override DataSet<EPGMEdge> getEdges(); @Override DataSet<EPGMEdge> getEdgesByLabel(String label); }
TxCollectionLayout implements GraphCollectionLayout<EPGMGraphHead, EPGMVertex, EPGMEdge> { @Override public DataSet<EPGMVertex> getVertices() { return transactions .flatMap(new TransactionVertices<>()) .distinct(new Id<>()); } TxCollectionLayout(DataSet<GraphTransaction> transactions); @Override boolean isGVELayout(); @Override boolean isIndexedGVELayout(); @Override boolean isTransactionalLayout(); @Override DataSet<EPGMGraphHead> getGraphHeads(); @Override DataSet<EPGMGraphHead> getGraphHeadsByLabel(String label); @Override DataSet<GraphTransaction> getGraphTransactions(); @Override DataSet<EPGMVertex> getVertices(); @Override DataSet<EPGMVertex> getVerticesByLabel(String label); @Override DataSet<EPGMEdge> getEdges(); @Override DataSet<EPGMEdge> getEdgesByLabel(String label);  }