@Test public void testSameCollection() throws Exception { FlinkAsciiGraphLoader loader = getSocialNetworkLoader(); int limit = 2; GraphCollection input = loader.getGraphCollectionByVariables("g0", "g1"); collectAndAssertTrue(input.equalsByGraphElementData(input.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);  }