public class TupleSource extends Object implements StaticObservable, Stage
Constructor and Description |
---|
TupleSource(Observer<TupleEvent> out,
int max,
int numThreads,
boolean evenOnly) |
public TupleSource(Observer<TupleEvent> out, int max, int numThreads, boolean evenOnly)
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2015 The Apache Software Foundation. All rights reserved.