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