com.neurosys.modules.etl.admin.wicket.pages.panels

Class ReaderProcess<IN,T>

java.lang.Object

com.neurosys.modules.etl.admin.wicket.pages.panels.ReaderProcess<IN,T>

Type Parameters:

IN - as input type.

T - as the resultant output type for each tuple in the process.

All Implemented Interfaces:

ControllableProcess<Serializable>, Process, ChangeGenerator<Object>, IAdminPanel, Serializable, Runnable

public class ReaderProcess<IN,T>
extends Object
implements Runnable, ControllableProcess<Serializable>, ChangeGenerator<Object>, IAdminPanel

A process for allowing AbstractReaders to read in their own thread (non blocking UI)

Author:

Arjun Dhar

See Also:

(TODO use that or extend that), Serialized Form

Nested Class Summary

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

Process.Event, Process.EventPoint

Constructor Summary

Constructors

Constructor and Description
ReaderProcess(org.springframework.context.ConfigurableApplicationContext context)
ReaderProcess(org.springframework.context.ConfigurableApplicationContext context, AbstractReader<IN,T,Serializable> reader, String anyUploadedResource, Progression progression, org.apache.wicket.markup.html.panel.Panel feedback, Boolean onlyVerify, ETLMeta<FacetMeta> meta, String processId)

Method Summary

Modifier and Type	Method and Description
static void	add(ChangeListener changeListener)
void	addChangeListener(ChangeListener changeListener) Allow Notify all ChangeListeners about a change
String	getAnyUploadedResource()
org.apache.wicket.markup.html.panel.Panel	getFeedback()
List	getListeners() Get list directly.
ETLMeta<FacetMeta>	getMeta()
Boolean	getOnlyVerify()
String	getProcessId()
Progression	getProgression()
AbstractReader<IN,T,Serializable>	getReader()
Serializable	getState() Get current state of process
protected void	init() All Thread/Reading init based activities
protected void	injectContext(org.apache.commons.collections.Transformer t) Inject context data into ParamsAware and ReaderAware like transformer implementation.
boolean	isPaused()
void	kill() Kill a process
void	notifyAllListeners(Object object) Whenever a node is selected/updated, it also notifies its listeners.
void	pause() Pause till resume
protected void	processGeneratedEntity(T entity) Process the final Entity produced from the ETL Process. This is a convenient way to simply provide Transformer based processing over input/reader produced output as AbstractReader are not required at times.
void	resume()
void	resumeFromState(Serializable state) Resume process from the given State provided
void	run()
void	setAnyUploadedResource(String anyUploadedResource)
void	setFeedback(org.apache.wicket.markup.html.panel.FeedbackPanel feedback)
void	setListeners(List listeners) Set list directly.
void	setProgression(Progression progression)
void	setReader(AbstractReader<IN,T,Serializable> reader)
void	stop() Request graceful Shutdown
protected void	threadInit() Init before the thread runs.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReaderProcess

public ReaderProcess(org.springframework.context.ConfigurableApplicationContext context)

ReaderProcess

public ReaderProcess(org.springframework.context.ConfigurableApplicationContext context,
                     AbstractReader<IN,T,Serializable> reader,
                     String anyUploadedResource,
                     Progression progression,
                     org.apache.wicket.markup.html.panel.Panel feedback,
                     Boolean onlyVerify,
                     ETLMeta<FacetMeta> meta,
                     String processId)

Parameters:

context - as String Context

reader - as AbstractReader derived from Name of Reader matching bean name

anyUploadedResource - as String

progression - as Progression

feedback - as Panel

onlyVerify - as Boolean

meta - as ETLMeta. Like processEntityTranformer as Transformer; process the final entity from the ETL process when onlyVerify is false. Eample: Persist entity after it is processed and ready.

processId - as String; attributed Process Id

Method Detail

threadInit

protected void threadInit()

Init before the thread runs.

injectContext

protected void injectContext(org.apache.commons.collections.Transformer t)

Inject context data into ParamsAware and ReaderAware like transformer implementation.

Parameters:

t - as Transformer

init

protected void init()
             throws Exception

All Thread/Reading init based activities

Throws:

Exception

processGeneratedEntity

protected void processGeneratedEntity(T entity)

Process the final Entity produced from the ETL Process.
This is a convenient way to simply provide Transformer based processing over input/reader produced output as AbstractReader are not required at times.

Parameters:

entity - as T @nullable true

run

@Transactional(readOnly=false)
public void run()

Specified by:

run in interface Runnable

getReader

public AbstractReader<IN,T,Serializable> getReader()

setReader

public void setReader(AbstractReader<IN,T,Serializable> reader)

getAnyUploadedResource

public String getAnyUploadedResource()

setAnyUploadedResource

public void setAnyUploadedResource(String anyUploadedResource)

getProgression

public Progression getProgression()

setProgression

public void setProgression(Progression progression)

getFeedback

public org.apache.wicket.markup.html.panel.Panel getFeedback()

setFeedback

public void setFeedback(org.apache.wicket.markup.html.panel.FeedbackPanel feedback)

getOnlyVerify

public Boolean getOnlyVerify()

getMeta

public ETLMeta<FacetMeta> getMeta()

stop

public void stop()
          throws Exception

Description copied from interface: ControllableProcess

Request graceful Shutdown

Specified by:

stop in interface ControllableProcess<Serializable>

Throws:

Exception

pause

public void pause()
           throws Exception

Description copied from interface: ControllableProcess

Pause till resume

Specified by:

pause in interface ControllableProcess<Serializable>

Throws:

Exception

isPaused

public boolean isPaused()

Specified by:

isPaused in interface ControllableProcess<Serializable>

resume

public void resume()
            throws Exception

Specified by:

resume in interface ControllableProcess<Serializable>

Throws:

Exception

kill

public void kill()
          throws Exception

Description copied from interface: ControllableProcess

Kill a process

Specified by:

kill in interface ControllableProcess<Serializable>

Throws:

Exception

getState

public Serializable getState()
                      throws Exception

Description copied from interface: ControllableProcess

Get current state of process

Specified by:

getState in interface ControllableProcess<Serializable>

Throws:

Exception

resumeFromState

public void resumeFromState(Serializable state)
                     throws Exception

Description copied from interface: ControllableProcess

Resume process from the given State provided

Specified by:

resumeFromState in interface ControllableProcess<Serializable>

Throws:

Exception

getProcessId

public String getProcessId()

add

public static void add(ChangeListener changeListener)

addChangeListener

public void addChangeListener(ChangeListener changeListener)

Description copied from interface: ChangeGenerator

Allow Notify all ChangeListeners about a change

Specified by:

addChangeListener in interface ChangeGenerator<Object>

notifyAllListeners

public void notifyAllListeners(Object object)

Description copied from interface: ChangeGenerator

Whenever a node is selected/updated, it also notifies its listeners.

Specified by:

notifyAllListeners in interface ChangeGenerator<Object>

getListeners

public List getListeners()

Description copied from interface: ChangeGenerator

Get list directly. Support DI; like Spring IOC

Specified by:

getListeners in interface ChangeGenerator<Object>

setListeners

public void setListeners(List listeners)

Description copied from interface: ChangeGenerator

Set list directly. Support DI; like Spring IOC

Specified by:

setListeners in interface ChangeGenerator<Object>