com.neurosys.etl.readers

Class AbstractReader<TUPLE_IN,RECORD_OUT,STATE>

java.lang.Object

com.neurosys.etl.process.EventAwareProcess

com.neurosys.etl.readers.BaseIterativeProcessor<TUPLE_IN,RECORD_OUT,STATE>

com.neurosys.etl.readers.AbstractReader<TUPLE_IN,RECORD_OUT,STATE>

All Implemented Interfaces:

FailFastAware, Identifiable, ParamsAware, BatchProcess, ControllableProcess<STATE>, Process, RealTimeLineReader<RECORD_OUT>, ResourceAwareRealTimeLineReader<RECORD_OUT>, TransformAwareReader, TupleContextAwareReader<TUPLE_IN,RECORD_OUT>, Serializable, Iterator<RECORD_OUT>

Direct Known Subclasses:

ChainIterativeReader, ExcelRowByRowReader, ExecuteJobReader, FileReader

public abstract class AbstractReader<TUPLE_IN,RECORD_OUT,STATE>
extends BaseIterativeProcessor<TUPLE_IN,RECORD_OUT,STATE>

Support generic Process Aware aspects for Read operations and their boiler plate management

Author:

Arjun Dhar

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.neurosys.etl.process.Process

Process.Event, Process.EventPoint

Field Summary

Fields inherited from class com.neurosys.etl.readers.BaseIterativeProcessor

exceptions, failFast, filter, hasNext, index, messages, params, paused, resource, transformer

Fields inherited from class com.neurosys.etl.process.EventAwareProcess

listeners, processState

Constructor Summary

Constructors

Constructor and Description
AbstractReader(org.springframework.core.io.Resource resource)

Method Summary

Methods inherited from class com.neurosys.etl.readers.BaseIterativeProcessor

close, filter, getCurrentIndex, getCurrentRawIndex, getCurrentTupleIdentifier, getExceptions, getFilter, getId, getMessages, getMeta, getParams, getResource, getSourceLocation, getTransformer, handleMiscException, hasNext, init, isFailFast, isPaused, kill, next, nextRecord, nextTupleResult, pause, remove, resume, setExceptions, setFailFast, setFilter, setId, setMessages, setMeta, setParams, setResource, setTransformer, stop, transform

Methods inherited from class com.neurosys.etl.process.EventAwareProcess

addListener, getListeners, onChangeHandler, setListeners

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining

Methods inherited from interface com.neurosys.etl.readers.ResourceAwareRealTimeLineReader

size

Methods inherited from interface com.neurosys.etl.readers.RealTimeLineReader

dispose, isInitialized

Methods inherited from interface com.neurosys.etl.process.ControllableProcess

getState, resumeFromState

Constructor Detail

AbstractReader

public AbstractReader(org.springframework.core.io.Resource resource)