@Test public void testFromGraphCollection() throws Exception { TemporalGraphCollection temporalCollection = TemporalGraphCollection.fromGraphCollection(testCollection); Collection<TemporalGraphHead> loadedGraphHeads = new ArrayList<>(); Collection<TemporalVertex> loadedVertices = new ArrayList<>(); Collection<TemporalEdge> loadedEdges = new ArrayList<>(); temporalCollection.getGraphHeads().output(new LocalCollectionOutputFormat<>(loadedGraphHeads)); temporalCollection.getVertices().output(new LocalCollectionOutputFormat<>(loadedVertices)); temporalCollection.getEdges().output(new LocalCollectionOutputFormat<>(loadedEdges)); Collection<EPGMGraphHead> epgmGraphHeads = new ArrayList<>(); Collection<EPGMVertex> epgmVertices = new ArrayList<>(); Collection<EPGMEdge> epgmEdges = new ArrayList<>(); testCollection.getGraphHeads().output(new LocalCollectionOutputFormat<>(epgmGraphHeads)); testCollection.getVertices().output(new LocalCollectionOutputFormat<>(epgmVertices)); testCollection.getEdges().output(new LocalCollectionOutputFormat<>(epgmEdges)); getExecutionEnvironment().execute(); assertFalse(loadedGraphHeads.isEmpty()); assertFalse(loadedVertices.isEmpty()); assertFalse(loadedEdges.isEmpty()); validateElementCollections(epgmGraphHeads, loadedGraphHeads); validateElementCollections(epgmVertices, loadedVertices); validateElementCollections(epgmEdges, loadedEdges); validateGraphElementCollections(epgmVertices, loadedVertices); validateGraphElementCollections(epgmEdges, loadedEdges); loadedGraphHeads.forEach(this::checkDefaultTemporalElement); loadedVertices.forEach(this::checkDefaultTemporalElement); loadedEdges.forEach(this::checkDefaultTemporalElement); }
public static < G extends GraphHead, V extends Vertex, E extends Edge, LG extends BaseGraph<G, V, E, LG, GC>, GC extends BaseGraphCollection<G, V, E, LG, GC>> TemporalGraphCollection fromGraphCollection(GC baseGraphCollection) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraphCollection.getConfig()) .getTemporalGraphCollectionFactory().fromNonTemporalGraphCollection(baseGraphCollection); }
TemporalGraphCollection implements BaseGraphCollection<
    TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph, TemporalGraphCollection>,
  GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge>,
  TemporalGraphCollectionOperators { public static < G extends GraphHead, V extends Vertex, E extends Edge, LG extends BaseGraph<G, V, E, LG, GC>, GC extends BaseGraphCollection<G, V, E, LG, GC>> TemporalGraphCollection fromGraphCollection(GC baseGraphCollection) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraphCollection.getConfig()) .getTemporalGraphCollectionFactory().fromNonTemporalGraphCollection(baseGraphCollection); } }
TemporalGraphCollection implements BaseGraphCollection<
    TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph, TemporalGraphCollection>,
  GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge>,
  TemporalGraphCollectionOperators { public static < G extends GraphHead, V extends Vertex, E extends Edge, LG extends BaseGraph<G, V, E, LG, GC>, GC extends BaseGraphCollection<G, V, E, LG, GC>> TemporalGraphCollection fromGraphCollection(GC baseGraphCollection) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraphCollection.getConfig()) .getTemporalGraphCollectionFactory().fromNonTemporalGraphCollection(baseGraphCollection); } TemporalGraphCollection(
    GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge> layout,
    TemporalGradoopConfig config); }
TemporalGraphCollection implements BaseGraphCollection<
    TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph, TemporalGraphCollection>,
  GraphCollectionLayout<TemporalGraphHead, TemporalVertex, TemporalEdge>,
  TemporalGraphCollectionOperators { public static < G extends GraphHead, V extends Vertex, E extends Edge, LG extends BaseGraph<G, V, E, LG, GC>, GC extends BaseGraphCollection<G, V, E, LG, GC>> TemporalGraphCollection fromGraphCollection(GC baseGraphCollection) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraphCollection.getConfig()) .getTemporalGraphCollectionFactory().fromNonTemporalGraphCollection(baseGraphCollection); } 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 { public static < G extends GraphHead, V extends Vertex, E extends Edge, LG extends BaseGraph<G, V, E, LG, GC>, GC extends BaseGraphCollection<G, V, E, LG, GC>> TemporalGraphCollection fromGraphCollection(GC baseGraphCollection) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraphCollection.getConfig()) .getTemporalGraphCollectionFactory().fromNonTemporalGraphCollection(baseGraphCollection); } 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();  }