com.revolsys.gis.parallel

Class AbstractMergeProcess

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

com.revolsys.parallel.process.AbstractInOutProcess<Record,Record>

com.revolsys.gis.parallel.AbstractMergeProcess

All Implemented Interfaces:

InOutProcess<Record,Record>, InProcess<Record>, OutProcess<Record>, Process, Runnable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

Direct Known Subclasses:

CompareProcessor

public abstract class AbstractMergeProcess
extends AbstractInOutProcess<Record,Record>

Constructor Summary

Constructors

Constructor and Description
AbstractMergeProcess()

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	acceptObject(Record object)
protected abstract void	addOtherObject(Record object) Add an object from the other (otherId) channel.
protected abstract void	addSourceObject(Record object) Add an object from the source (in) channel.
Channel<Record>	getOtherIn()
int	getOtherInBufferSize()
protected abstract void	processObjects(RecordDefinition currentType, Channel<Record> out)
protected void	run(Channel<Record> in, Channel<Record> out)
void	setOtherIn(Channel<Record> in)
void	setOtherInBufferSize(int otherInBufferSize)
protected void	setUp()
protected void	tearDown()

Methods inherited from class com.revolsys.parallel.process.AbstractInOutProcess

createInValueStore, createOutValueStore, destroy, getIn, getInBufferSize, getOut, getOutBufferSize, init, run, setIn, setInBufferSize, setOut, setOutBufferSize

Methods inherited from class com.revolsys.parallel.process.AbstractProcess

getBeanName, getProcessNetwork, setBeanName, setProcessNetwork, stop, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.revolsys.parallel.process.Process

getBeanName, getProcessNetwork, setProcessNetwork

Methods inherited from interface org.springframework.beans.factory.BeanNameAware

setBeanName

Constructor Detail

AbstractMergeProcess

public AbstractMergeProcess()

Method Detail

acceptObject

protected boolean acceptObject(Record object)

addOtherObject

protected abstract void addOtherObject(Record object)

Add an object from the other (otherId) channel.

Parameters:

object - The object to add.

addSourceObject

protected abstract void addSourceObject(Record object)

Add an object from the source (in) channel.

Parameters:

object - The object to add.

getOtherIn

public Channel<Record> getOtherIn()

Returns:

the in

getOtherInBufferSize

public int getOtherInBufferSize()

processObjects

protected abstract void processObjects(RecordDefinition currentType,
                  Channel<Record> out)

run

protected void run(Channel<Record> in,
       Channel<Record> out)

Specified by:

run in class AbstractInOutProcess<Record,Record>

setOtherIn

public void setOtherIn(Channel<Record> in)

Parameters:

in - the in to set

setOtherInBufferSize

public void setOtherInBufferSize(int otherInBufferSize)

setUp

protected void setUp()

tearDown

protected void tearDown()