com.neurosys.etl.readers

Class ExecuteJobReader

java.lang.Object

com.neurosys.etl.process.EventAwareProcess

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

com.neurosys.etl.readers.AbstractReader<Void,Void,Void>

com.neurosys.etl.readers.ExecuteJobReader

All Implemented Interfaces:

FailFastAware, Identifiable, ParamsAware, BatchProcess, ControllableProcess<Void>, Process, RealTimeLineReader<Void>, ResourceAwareRealTimeLineReader<Void>, TransformAwareReader, TupleContextAwareReader<Void,Void>, Serializable, Iterator<Void>

public class ExecuteJobReader
extends AbstractReader<Void,Void,Void>

Simply executes a Job
If the BaseIterativeProcessor.getTransformer() is a TransformerChain then the first level chain elements are each considered a Different Job and each passed the BaseIterativeProcessor.getParams()

If the BaseIterativeProcessor.getTransformer() return any String or List of String then those will be added to BaseIterativeProcessor.getMessages() TODO: Add unit test case for Single & multiple Jobs in TransformerChain

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
ExecuteJobReader() Default Constructor to allow lazy initialization If so, init() must be called by the calling API explicitly after calling BaseIterativeProcessor.setResource(Resource)

Method Summary

Modifier and Type	Method and Description
void	dispose() Un-initialize reader, so that it maybe re consumed Except for the main Resource & configuration set by Spring context all other instance variables used will be re-set/disposed/cleared.
Long	getCurrentRawIndex(Void row) Get the raw index/position on the source; BaseIterativeProcessor.getCurrentIndex() only tracks the relevant position.
Void	getState() Get current state of process
void	init() Allow lazy initialization of Reader in cases where the resource may not be known @ PostConstruct time
boolean	isInitialized() Allow the calling API to determine if the reader has been initialized via RealTimeLineReader.init() or PostConstruct phase If not RealTimeLineReader.init() should be called upon the instance.
protected Void	nextRecord()
protected void	processValue(Object value) Process the output for a Job step.
void	resumeFromState(Void state) Resume process from the given State provided
Long	size() Get number of tuples/records in resource

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

close, filter, getCurrentIndex, getCurrentTupleIdentifier, getExceptions, getFilter, getId, getMessages, getMeta, getParams, getResource, getSourceLocation, getTransformer, handleMiscException, hasNext, isFailFast, isPaused, kill, next, 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

Constructor Detail

ExecuteJobReader

public ExecuteJobReader()

Default Constructor to allow lazy initialization
If so, init() must be called by the calling API explicitly after calling BaseIterativeProcessor.setResource(Resource)

Method Detail

init

@PostConstruct
public void init()
                         throws IOException,
                                Exception

Description copied from interface: RealTimeLineReader

Allow lazy initialization of Reader in cases where the resource may not be known @ PostConstruct time

Specified by:

init in interface RealTimeLineReader<Void>

Overrides:

init in class BaseIterativeProcessor<Void,Void,Void>

Throws:

Exception

IOException

isInitialized

public boolean isInitialized()
                      throws Exception

Description copied from interface: RealTimeLineReader

Allow the calling API to determine if the reader has been initialized via RealTimeLineReader.init() or PostConstruct phase
If not RealTimeLineReader.init() should be called upon the instance.

Throws:

Exception

dispose

public void dispose()
             throws Exception

Description copied from interface: RealTimeLineReader

Un-initialize reader, so that it maybe re consumed
Except for the main Resource & configuration set by Spring context all other instance variables used will be re-set/disposed/cleared.

Throws:

Exception

size

public Long size()

Description copied from interface: ResourceAwareRealTimeLineReader

Get number of tuples/records in resource

Returns:

Long

getState

public Void getState()
              throws Exception

Description copied from interface: ControllableProcess

Get current state of process

Throws:

Exception

resumeFromState

public void resumeFromState(Void state)
                     throws Exception

Description copied from interface: ControllableProcess

Resume process from the given State provided

Throws:

Exception

processValue

protected void processValue(Object value)

Process the output for a Job step. This method adds it to the BaseIterativeProcessor.getMessages()

Parameters:

value -

nextRecord

protected Void nextRecord()

Specified by:

nextRecord in class BaseIterativeProcessor<Void,Void,Void>

getCurrentRawIndex

public Long getCurrentRawIndex(Void row)

Description copied from class: BaseIterativeProcessor

Get the raw index/position on the source; BaseIterativeProcessor.getCurrentIndex() only tracks the relevant position. This method allows us to get the position on the source.
In many cases/implementations this maybe used internally to derive the BaseIterativeProcessor.getCurrentIndex()

Specified by:

getCurrentRawIndex in class BaseIterativeProcessor<Void,Void,Void>

Returns:

Long