public class ReaderProcess extends AbstractOutProcess<Record>
| Constructor and Description |
|---|
ReaderProcess() |
ReaderProcess(Channel<Record> out,
RecordIterator reader) |
ReaderProcess(RecordIterator reader) |
ReaderProcess(RecordIterator reader,
int bufferSize) |
| Modifier and Type | Method and Description |
|---|---|
RecordIterator |
getReader() |
protected void |
run(Channel<Record> out) |
void |
setReader(RecordIterator reader) |
destroy, getOut, getOutBufferSize, init, run, setOut, setOutBufferSizegetBeanName, getProcessNetwork, setBeanName, setProcessNetwork, stop, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetBeanName, getProcessNetwork, setProcessNetworkpublic ReaderProcess()
public ReaderProcess(Channel<Record> out, RecordIterator reader)
public ReaderProcess(RecordIterator reader)
public ReaderProcess(RecordIterator reader, int bufferSize)
public RecordIterator getReader()
protected void run(Channel<Record> out)
run in class AbstractOutProcess<Record>public void setReader(RecordIterator reader)
reader - the reader to setCopyright © 2015 Revolution Systems Inc.. All rights reserved.