ambit2.base.processors.batch

Class BatchProcessor<INPUT,Target>

java.lang.Object

net.idea.modbcum.p.DefaultAmbitProcessor<INPUT,net.idea.modbcum.i.batch.IBatchStatistics>

ambit2.base.processors.batch.BatchProcessor<INPUT,Target>

All Implemented Interfaces:

IBatchProcessor<INPUT,Target,net.idea.modbcum.i.batch.IBatchStatistics>, Serializable, net.idea.modbcum.i.processors.IProcessor<INPUT,net.idea.modbcum.i.batch.IBatchStatistics>

public abstract class BatchProcessor<INPUT,Target>
extends net.idea.modbcum.p.DefaultAmbitProcessor<INPUT,net.idea.modbcum.i.batch.IBatchStatistics>
implements IBatchProcessor<INPUT,Target,net.idea.modbcum.i.batch.IBatchStatistics>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	cancelled
protected net.idea.modbcum.i.processors.ProcessorsChain<Target,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor>	processor
static String	PROPERTY_BATCHSTATS
protected long	timeout

Fields inherited from class net.idea.modbcum.p.DefaultAmbitProcessor

enabled, logger, propertyChangeSupport

Constructor Summary

Constructors

Constructor and Description
BatchProcessor()
BatchProcessor(net.idea.modbcum.i.processors.ProcessorsChain<Target,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor> processor)

Method Summary

Modifier and Type	Method and Description
void	cancel()
protected abstract void	closeIterator(Iterator iterator)
net.idea.modbcum.i.processors.ProcessorsChain<Target,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor>	getProcessorChain()
long	getTimeout()
net.idea.modbcum.i.batch.IBatchStatistics	process(INPUT target)
void	setProcessorChain(net.idea.modbcum.i.processors.ProcessorsChain<Target,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor> processor)
void	setTimeout(long timeout)

Methods inherited from class net.idea.modbcum.p.DefaultAmbitProcessor

addPropertyChangeListener, addPropertyChangeListener, close, getID, isEnabled, open, removePropertyChangeListener, removePropertyChangeListener, setEnabled, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface ambit2.base.interfaces.IBatchProcessor

afterProcessing, beforeProcessing, getIterator, getResult, onError, onItemProcessed, onItemRead

Field Detail

PROPERTY_BATCHSTATS

public static String PROPERTY_BATCHSTATS

processor

protected net.idea.modbcum.i.processors.ProcessorsChain<Target,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor> processor

cancelled

protected boolean cancelled

timeout

protected long timeout

Constructor Detail

BatchProcessor

public BatchProcessor()

BatchProcessor

public BatchProcessor(net.idea.modbcum.i.processors.ProcessorsChain<Target,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor> processor)

Method Detail

getProcessorChain

public net.idea.modbcum.i.processors.ProcessorsChain<Target,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor> getProcessorChain()

Specified by:

getProcessorChain in interface IBatchProcessor<INPUT,Target,net.idea.modbcum.i.batch.IBatchStatistics>

setProcessorChain

public void setProcessorChain(net.idea.modbcum.i.processors.ProcessorsChain<Target,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor> processor)

Specified by:

setProcessorChain in interface IBatchProcessor<INPUT,Target,net.idea.modbcum.i.batch.IBatchStatistics>

closeIterator

protected abstract void closeIterator(Iterator iterator)
                               throws net.idea.modbcum.i.exceptions.AmbitException

Throws:

net.idea.modbcum.i.exceptions.AmbitException

process

public net.idea.modbcum.i.batch.IBatchStatistics process(INPUT target)
                                                  throws net.idea.modbcum.i.exceptions.AmbitException

Specified by:

process in interface net.idea.modbcum.i.processors.IProcessor<INPUT,net.idea.modbcum.i.batch.IBatchStatistics>

Throws:

net.idea.modbcum.i.exceptions.AmbitException

cancel

public void cancel()

Specified by:

cancel in interface IBatchProcessor<INPUT,Target,net.idea.modbcum.i.batch.IBatchStatistics>

setTimeout

public void setTimeout(long timeout)

Specified by:

setTimeout in interface IBatchProcessor<INPUT,Target,net.idea.modbcum.i.batch.IBatchStatistics>

getTimeout

public long getTimeout()

Specified by:

getTimeout in interface IBatchProcessor<INPUT,Target,net.idea.modbcum.i.batch.IBatchStatistics>