@Test public void testToGraphCollection() throws Exception { GraphCollection resultingCollection = testTemporalCollection.toGraphCollection(); collectAndAssertTrue(resultingCollection.equalsByGraphData(testCollection)); collectAndAssertTrue(resultingCollection.equalsByGraphElementData(testCollection)); collectAndAssertTrue(resultingCollection.equalsByGraphElementIds(testCollection)); }
@Override public GraphCollection toGraphCollection() { final GraphCollectionFactory collectionFactory = this.config.getGraphCollectionFactory(); return collectionFactory.fromDataSets( getGraphHeads().map(new TemporalGraphHeadToGraphHead(collectionFactory.getGraphHeadFactory())), getVertices().map(new TemporalVertexToVertex(collectionFactory.getVertexFactory())), getEdges().map(new TemporalEdgeToEdge(collectionFactory.getEdgeFactory()))); }
TemporalGraphCollection implements BaseGraphCollection<
    TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph, TemporalGraphCollection>,
  GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge>,
  TemporalGraphCollectionOperators { @Override public GraphCollection toGraphCollection() { final GraphCollectionFactory collectionFactory = this.config.getGraphCollectionFactory(); return collectionFactory.fromDataSets( getGraphHeads().map(new TemporalGraphHeadToGraphHead(collectionFactory.getGraphHeadFactory())), getVertices().map(new TemporalVertexToVertex(collectionFactory.getVertexFactory())), getEdges().map(new TemporalEdgeToEdge(collectionFactory.getEdgeFactory()))); } }
TemporalGraphCollection implements BaseGraphCollection<
    TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph, TemporalGraphCollection>,
  GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge>,
  TemporalGraphCollectionOperators { @Override public GraphCollection toGraphCollection() { final GraphCollectionFactory collectionFactory = this.config.getGraphCollectionFactory(); return collectionFactory.fromDataSets( getGraphHeads().map(new TemporalGraphHeadToGraphHead(collectionFactory.getGraphHeadFactory())), getVertices().map(new TemporalVertexToVertex(collectionFactory.getVertexFactory())), getEdges().map(new TemporalEdgeToEdge(collectionFactory.getEdgeFactory()))); } TemporalGraphCollection(
    GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge> layout,
    TemporalGradoopConfig config); }
TemporalGraphCollection implements BaseGraphCollection<
    TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph, TemporalGraphCollection>,
  GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge>,
  TemporalGraphCollectionOperators { @Override public GraphCollection toGraphCollection() { final GraphCollectionFactory collectionFactory = this.config.getGraphCollectionFactory(); return collectionFactory.fromDataSets( getGraphHeads().map(new TemporalGraphHeadToGraphHead(collectionFactory.getGraphHeadFactory())), getVertices().map(new TemporalVertexToVertex(collectionFactory.getVertexFactory())), getEdges().map(new TemporalEdgeToEdge(collectionFactory.getEdgeFactory()))); } TemporalGraphCollection(
    GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge> layout,
    TemporalGradoopConfig config); @Override GradoopFlinkConfig getConfig(); @Override BaseGraphCollectionFactory<TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph,
    TemporalGraphCollection> getFactory(); @Override BaseGraphFactory<TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph,
    TemporalGraphCollection> getGraphFactory(); void writeTo(TemporalDataSink dataSink); void writeTo(TemporalDataSink dataSink, boolean overWrite); @Override DataSet<TemporalVertex> getVertices(); @Override DataSet<TemporalVertex> getVerticesByLabel(String label); @Override DataSet<TemporalEdge> getEdges(); @Override DataSet<TemporalEdge> getEdgesByLabel(String label); @Override boolean isGVELayout(); @Override boolean isIndexedGVELayout(); @Override boolean isTransactionalLayout(); @Override DataSet<TemporalGraphHead> getGraphHeads(); @Override DataSet<TemporalGraphHead> getGraphHeadsByLabel(String label); @Override DataSet<GraphTransaction> getGraphTransactions(); @Override DataSet<Boolean> equalsByGraphElementData(TemporalGraphCollection otherCollection); @Override DataSet<Boolean> equalsByGraphData(TemporalGraphCollection otherCollection); @Override T callForValue(UnaryBaseGraphCollectionToValueOperator<TemporalGraphCollection, T> operator); @Override T callForValue(BinaryBaseGraphCollectionToValueOperator<TemporalGraphCollection, T> operator,
                            TemporalGraphCollection otherCollection); @Override GraphCollection toGraphCollection(); static TemporalGraphCollection fromGraphCollection(GC baseGraphCollection); static TemporalGraphCollection fromGraphCollection(GC baseGraphCollection,
      TimeIntervalExtractor<G> graphTimeExtractor,
      TimeIntervalExtractor<V> vertexTimeExtractor,
      TimeIntervalExtractor<E> edgeTimeExtractor); void print(); }
TemporalGraphCollection implements BaseGraphCollection<
    TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph, TemporalGraphCollection>,
  GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge>,
  TemporalGraphCollectionOperators { @Override public GraphCollection toGraphCollection() { final GraphCollectionFactory collectionFactory = this.config.getGraphCollectionFactory(); return collectionFactory.fromDataSets( getGraphHeads().map(new TemporalGraphHeadToGraphHead(collectionFactory.getGraphHeadFactory())), getVertices().map(new TemporalVertexToVertex(collectionFactory.getVertexFactory())), getEdges().map(new TemporalEdgeToEdge(collectionFactory.getEdgeFactory()))); } TemporalGraphCollection(
    GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge> layout,
    TemporalGradoopConfig config); @Override GradoopFlinkConfig getConfig(); @Override BaseGraphCollectionFactory<TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph,
    TemporalGraphCollection> getFactory(); @Override BaseGraphFactory<TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph,
    TemporalGraphCollection> getGraphFactory(); void writeTo(TemporalDataSink dataSink); void writeTo(TemporalDataSink dataSink, boolean overWrite); @Override DataSet<TemporalVertex> getVertices(); @Override DataSet<TemporalVertex> getVerticesByLabel(String label); @Override DataSet<TemporalEdge> getEdges(); @Override DataSet<TemporalEdge> getEdgesByLabel(String label); @Override boolean isGVELayout(); @Override boolean isIndexedGVELayout(); @Override boolean isTransactionalLayout(); @Override DataSet<TemporalGraphHead> getGraphHeads(); @Override DataSet<TemporalGraphHead> getGraphHeadsByLabel(String label); @Override DataSet<GraphTransaction> getGraphTransactions(); @Override DataSet<Boolean> equalsByGraphElementData(TemporalGraphCollection otherCollection); @Override DataSet<Boolean> equalsByGraphData(TemporalGraphCollection otherCollection); @Override T callForValue(UnaryBaseGraphCollectionToValueOperator<TemporalGraphCollection, T> operator); @Override T callForValue(BinaryBaseGraphCollectionToValueOperator<TemporalGraphCollection, T> operator,
                            TemporalGraphCollection otherCollection); @Override GraphCollection toGraphCollection(); static TemporalGraphCollection fromGraphCollection(GC baseGraphCollection); static TemporalGraphCollection fromGraphCollection(GC baseGraphCollection,
      TimeIntervalExtractor<G> graphTimeExtractor,
      TimeIntervalExtractor<V> vertexTimeExtractor,
      TimeIntervalExtractor<E> edgeTimeExtractor); void print();  }