Package nz.org.riskscape.engine.pipeline
Class TupleIteratorSink.Iterator
java.lang.Object
nz.org.riskscape.engine.relation.PeekingTupleIterator
nz.org.riskscape.engine.pipeline.TupleIteratorSink.Iterator
- All Implemented Interfaces:
AutoCloseable
,Iterator<nz.org.riskscape.engine.Tuple>
,nz.org.riskscape.engine.relation.TupleIterator
- Enclosing class:
- TupleIteratorSink
public class TupleIteratorSink.Iterator
extends nz.org.riskscape.engine.relation.PeekingTupleIterator
Iterator that reads tuples as they are accepted by the sink
-
Field Summary
Fields inherited from interface nz.org.riskscape.engine.relation.TupleIterator
EMPTY
-
Constructor Summary
-
Method Summary
Methods inherited from class nz.org.riskscape.engine.relation.PeekingTupleIterator
close, hasNext, next, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface nz.org.riskscape.engine.relation.TupleIterator
collect, forEachRemaining
-
Constructor Details
-
Iterator
public Iterator()
-
-
Method Details
-
get
protected nz.org.riskscape.engine.Tuple get()- Specified by:
get
in classnz.org.riskscape.engine.relation.PeekingTupleIterator
-
getSource
- Specified by:
getSource
in classnz.org.riskscape.engine.relation.PeekingTupleIterator
-
finish
public void finish()
-