public class MapReaderRecordReader extends AbstractReader<Record> implements RecordReader, Iterator<Record>
| Constructor and Description |
|---|
MapReaderRecordReader(RecordDefinition recordDefinition,
Reader<Map<String,Object>> mapReader) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close the reader and all resources associated with it.
|
RecordDefinition |
getRecordDefinition() |
boolean |
hasNext() |
Iterator<Record> |
iterator()
Return a new iterator for type T at the first item to read.
|
Record |
next() |
void |
open()
Open the reader so that it is ready to be read from.
|
void |
remove() |
read, visitclearProperties, getProperties, getProperty, getProperty, removeProperty, setProperties, setProperty, setPropertySoft, setPropertyWeakclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclearProperties, getProperties, getProperty, getProperty, removeProperty, setProperties, setProperty, setPropertySoft, setPropertyWeakpublic MapReaderRecordReader(RecordDefinition recordDefinition, Reader<Map<String,Object>> mapReader)
public void close()
Readerclose in interface Reader<Record>close in interface AutoCloseableclose in class AbstractObjectWithPropertiespublic RecordDefinition getRecordDefinition()
getRecordDefinition in interface RecordReaderpublic Iterator<Record> iterator()
Readerpublic void open()
ReaderCopyright © 2015 Revolution Systems Inc.. All rights reserved.