@Test public void testOutOfBound() throws Exception { FlinkAsciiGraphLoader loader = getSocialNetworkLoader(); GraphCollection inputCollection = loader.getGraphCollectionByVariables("g0", "g1"); int limit = 4; int expectedCount = 2; GraphCollection outputCollection = inputCollection.limit(limit); assertEquals(expectedCount, outputCollection.getGraphHeads().count()); }
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);  }