@Test public void testDiffOnGraph() throws Exception { FlinkAsciiGraphLoader loader = getTemporalSocialNetworkLoader(); loader.appendToDatabaseFromString("expected:Forum[" + "(gpse:Forum {title: \"Graph Processing\", _diff: 0})" + "(davee:Person {name: \"Dave\", gender: \"m\", city: \"Dresden\", age: 40," + "__valFrom: 1543700000000L, _diff: 1})" + "(carole:Person {name : \"Carol\", gender : \"f\", city : \"Dresden\", age : 30," + "__valFrom: 1543600000000L, _diff: 0})" + "(gpse)-[:hasMember{ __valFrom: 1543600000000L, __valTo: 1543800000000L, _diff: -1}]->" + "(davee) (gpse)-[:hasMember {_diff: 0}]->(carole)" + "-[:knows {since : 2014 , __valFrom : 1543700000000L, _diff: 1}]->(davee)" + "]"); LogicalGraph inputGraphEpgm = loader.getLogicalGraphByVariable("g3"); TemporalGraph temporalGraph = toTemporalGraphWithDefaultExtractors(inputGraphEpgm); TemporalGraph result = temporalGraph.diff(new AsOf(1543600000000L), new AsOf(1543800000000L)); collectAndAssertTrue(toTemporalGraphWithDefaultExtractors(loader.getLogicalGraphByVariable("expected")) .equalsByData(result)); }
public Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate) { this(firstPredicate, secondPredicate, TimeDimension.VALID_TIME); }
Diff implements UnaryBaseGraphToBaseGraphOperator<TemporalGraph> { public Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate) { this(firstPredicate, secondPredicate, TimeDimension.VALID_TIME); } }
Diff implements UnaryBaseGraphToBaseGraphOperator<TemporalGraph> { public Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate) { this(firstPredicate, secondPredicate, TimeDimension.VALID_TIME); } Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate);  Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate, TimeDimension dimension); }
Diff implements UnaryBaseGraphToBaseGraphOperator<TemporalGraph> { public Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate) { this(firstPredicate, secondPredicate, TimeDimension.VALID_TIME); } Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate);  Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate, TimeDimension dimension); @Override TemporalGraph execute(TemporalGraph graph); }
Diff implements UnaryBaseGraphToBaseGraphOperator<TemporalGraph> { public Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate) { this(firstPredicate, secondPredicate, TimeDimension.VALID_TIME); } Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate);  Diff(TemporalPredicate firstPredicate, TemporalPredicate secondPredicate, TimeDimension dimension); @Override TemporalGraph execute(TemporalGraph graph); static final String PROPERTY_KEY; static final PropertyValue VALUE_ADDED; static final PropertyValue VALUE_EQUAL; static final PropertyValue VALUE_REMOVED; }