public abstract class InputProcessingIterator extends MoveIterator
Extending classes need to implement getNext() only.
Modifier and Type | Field and Description |
---|---|
protected TsIterator |
input_iterator |
schema
Constructor and Description |
---|
InputProcessingIterator(TsIterator input_iterator,
TsSchema output_schema) |
Modifier and Type | Method and Description |
---|---|
ProcessingChain |
getProcessingChain()
Default implementation: Get processing chain with this as source entry.
|
close, getNext, hasNext, next
getNames, getSchema, isLive, isNotLive, toSchemas, toString, toTimeSeries, toTimestampSeries, writeConsole, writeConsole, writeCSV
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getProcessingTitle
createUnknown, of
createUnknown
protected final TsIterator input_iterator
public InputProcessingIterator(TsIterator input_iterator, TsSchema output_schema)
public ProcessingChain getProcessingChain()
ProcessingChainNode