@Test public void testDistinctGraphs() throws Exception { FlinkAsciiGraphLoader loader = getLoaderFromString("(v1) (v2) g1[(v1)] g2[(v1) (v2)]"); int limit = 2; GraphCollection inputCollection = loader.getGraphCollectionByVariables("g1", "g2"); collectAndAssertTrue(inputCollection.equalsByGraphElementData(inputCollection.limit(limit))); }
public Limit(int limit) { this.limit = limit; }
Limit extends SelectionBase<G, V, E, LG, GC> implements UnaryBaseGraphCollectionToBaseGraphCollectionOperator<GC> { public Limit(int limit) { this.limit = limit; } }
Limit extends SelectionBase<G, V, E, LG, GC> implements UnaryBaseGraphCollectionToBaseGraphCollectionOperator<GC> { public Limit(int limit) { this.limit = limit; } Limit(int limit); }
Limit extends SelectionBase<G, V, E, LG, GC> implements UnaryBaseGraphCollectionToBaseGraphCollectionOperator<GC> { public Limit(int limit) { this.limit = limit; } Limit(int limit); @Override GC execute(GC collection); }
Limit extends SelectionBase<G, V, E, LG, GC> implements UnaryBaseGraphCollectionToBaseGraphCollectionOperator<GC> { public Limit(int limit) { this.limit = limit; } Limit(int limit); @Override GC execute(GC collection);  }