@Test public void testFromGraph() throws Exception { TemporalGraph temporalGraph = TemporalGraph.fromGraph(testLogicalGraph); Collection<TemporalGraphHead> loadedGraphHeads = new ArrayList<>(); Collection<TemporalVertex> loadedVertices = new ArrayList<>(); Collection<TemporalEdge> loadedEdges = new ArrayList<>(); temporalGraph.getGraphHead().output(new LocalCollectionOutputFormat<>(loadedGraphHeads)); temporalGraph.getVertices().output(new LocalCollectionOutputFormat<>(loadedVertices)); temporalGraph.getEdges().output(new LocalCollectionOutputFormat<>(loadedEdges)); Collection<EPGMGraphHead> epgmGraphHeads = new ArrayList<>(); Collection<EPGMVertex> epgmVertices = new ArrayList<>(); Collection<EPGMEdge> epgmEdges = new ArrayList<>(); testLogicalGraph.getGraphHead().output(new LocalCollectionOutputFormat<>(epgmGraphHeads)); testLogicalGraph.getVertices().output(new LocalCollectionOutputFormat<>(epgmVertices)); testLogicalGraph.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>> TemporalGraph fromGraph(LG baseGraph) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraph.getConfig()).getTemporalGraphFactory() .fromNonTemporalGraph(baseGraph); }
TemporalGraph implements BaseGraph<TemporalGraphHead, TemporalVertex, TemporalEdge,
  TemporalGraph, TemporalGraphCollection>, TemporalGraphOperators { 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>> TemporalGraph fromGraph(LG baseGraph) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraph.getConfig()).getTemporalGraphFactory() .fromNonTemporalGraph(baseGraph); } }
TemporalGraph implements BaseGraph<TemporalGraphHead, TemporalVertex, TemporalEdge,
  TemporalGraph, TemporalGraphCollection>, TemporalGraphOperators { 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>> TemporalGraph fromGraph(LG baseGraph) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraph.getConfig()).getTemporalGraphFactory() .fromNonTemporalGraph(baseGraph); } TemporalGraph(LogicalGraphLayout<TemporalGraphHead, TemporalVertex, TemporalEdge> layout,
    TemporalGradoopConfig config); }
TemporalGraph implements BaseGraph<TemporalGraphHead, TemporalVertex, TemporalEdge,
  TemporalGraph, TemporalGraphCollection>, TemporalGraphOperators { 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>> TemporalGraph fromGraph(LG baseGraph) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraph.getConfig()).getTemporalGraphFactory() .fromNonTemporalGraph(baseGraph); } TemporalGraph(LogicalGraphLayout<TemporalGraphHead, TemporalVertex, TemporalEdge> layout,
    TemporalGradoopConfig config); @Override TemporalGradoopConfig getConfig(); @Override BaseGraphFactory<TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph,
      TemporalGraphCollection> getFactory(); @Override BaseGraphCollectionFactory<TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph,
      TemporalGraphCollection> getCollectionFactory(); void writeTo(TemporalDataSink dataSink); void writeTo(TemporalDataSink dataSink, boolean overWrite); @Override boolean isGVELayout(); @Override boolean isIndexedGVELayout(); @Override DataSet<TemporalGraphHead> getGraphHead(); @Override DataSet<TemporalVertex> getVertices(); @Override DataSet<TemporalVertex> getVerticesByLabel(String label); @Override DataSet<TemporalEdge> getEdges(); @Override DataSet<TemporalEdge> getEdgesByLabel(String label); @Override DataSet<Boolean> equalsByElementData(TemporalGraph other); @Override DataSet<Boolean> equalsByData(TemporalGraph other); @Override T callForValue(UnaryBaseGraphToValueOperator<TemporalGraph, T> operator); @Override T callForValue(BinaryBaseGraphToValueOperator<TemporalGraph, T> operator,
                            TemporalGraph otherGraph); @Override LogicalGraph toLogicalGraph(); static TemporalGraph fromGraph(LG baseGraph); static TemporalGraph fromGraph(LG baseGraph,
      TimeIntervalExtractor<G> graphTimeExtractor,
      TimeIntervalExtractor<V> vertexTimeExtractor,
      TimeIntervalExtractor<E> edgeTimeExtractor); void print(); }
TemporalGraph implements BaseGraph<TemporalGraphHead, TemporalVertex, TemporalEdge,
  TemporalGraph, TemporalGraphCollection>, TemporalGraphOperators { 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>> TemporalGraph fromGraph(LG baseGraph) { return TemporalGradoopConfig.fromGradoopFlinkConfig(baseGraph.getConfig()).getTemporalGraphFactory() .fromNonTemporalGraph(baseGraph); } TemporalGraph(LogicalGraphLayout<TemporalGraphHead, TemporalVertex, TemporalEdge> layout,
    TemporalGradoopConfig config); @Override TemporalGradoopConfig getConfig(); @Override BaseGraphFactory<TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph,
      TemporalGraphCollection> getFactory(); @Override BaseGraphCollectionFactory<TemporalGraphHead, TemporalVertex, TemporalEdge, TemporalGraph,
      TemporalGraphCollection> getCollectionFactory(); void writeTo(TemporalDataSink dataSink); void writeTo(TemporalDataSink dataSink, boolean overWrite); @Override boolean isGVELayout(); @Override boolean isIndexedGVELayout(); @Override DataSet<TemporalGraphHead> getGraphHead(); @Override DataSet<TemporalVertex> getVertices(); @Override DataSet<TemporalVertex> getVerticesByLabel(String label); @Override DataSet<TemporalEdge> getEdges(); @Override DataSet<TemporalEdge> getEdgesByLabel(String label); @Override DataSet<Boolean> equalsByElementData(TemporalGraph other); @Override DataSet<Boolean> equalsByData(TemporalGraph other); @Override T callForValue(UnaryBaseGraphToValueOperator<TemporalGraph, T> operator); @Override T callForValue(BinaryBaseGraphToValueOperator<TemporalGraph, T> operator,
                            TemporalGraph otherGraph); @Override LogicalGraph toLogicalGraph(); static TemporalGraph fromGraph(LG baseGraph); static TemporalGraph fromGraph(LG baseGraph,
      TimeIntervalExtractor<G> graphTimeExtractor,
      TimeIntervalExtractor<V> vertexTimeExtractor,
      TimeIntervalExtractor<E> edgeTimeExtractor); void print();  }