public abstract class BaseRecordReader extends java.lang.Object implements RecordReader
Modifier and Type | Field and Description |
---|---|
protected java.util.List<RecordListener> |
listeners |
APPEND_LABEL, LABELS, NAME_SPACE
Constructor and Description |
---|
BaseRecordReader() |
Modifier and Type | Method and Description |
---|---|
java.util.List<RecordListener> |
getListeners()
Get the record listeners for this record reader.
|
protected void |
invokeListeners(java.lang.Object record)
Invokes
RecordListener.recordRead(RecordReader, Object) on all listeners. |
void |
setListeners(java.util.Collection<RecordListener> listeners)
Set the record listeners for this record reader.
|
void |
setListeners(RecordListener... listeners)
Set the record listeners for this record reader.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getLabels, hasNext, initialize, initialize, loadFromMetaData, loadFromMetaData, next, nextRecord, record, reset
getConf, setConf
protected java.util.List<RecordListener> listeners
protected void invokeListeners(java.lang.Object record)
RecordListener.recordRead(RecordReader, Object)
on all listeners.public java.util.List<RecordListener> getListeners()
RecordReader
getListeners
in interface RecordReader
public void setListeners(java.util.Collection<RecordListener> listeners)
RecordReader
setListeners
in interface RecordReader
public void setListeners(RecordListener... listeners)
RecordReader
setListeners
in interface RecordReader