com.revolsys.gis.parallel

Class OrderedEqualCompareProcessor

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

com.revolsys.parallel.process.AbstractInProcess<Record>

com.revolsys.gis.parallel.OrderedEqualCompareProcessor

All Implemented Interfaces:

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

public class OrderedEqualCompareProcessor
extends AbstractInProcess<Record>

Constructor Summary

Constructors

Constructor and Description
OrderedEqualCompareProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	geometryEquals(Record object1, Record object2)
List<String>	getEqualExclude()
String	getFieldName()
protected Set<String>	getNotEqualFieldNames(Record object1, Record object2)
Channel<Record>	getOtherIn()
int	getOtherInBufferSize()
String	getOtherName()
String	getSourceName()
protected void	logNoMatch(Record object, boolean other)
protected void	logNotEqual(Record sourceObject, Record otherObject, Set<String> notEqualFieldNames, boolean geometryEquals)
protected Record	readObject(Channel<Record> channel)
protected void	run(Channel<Record> in)
void	setEqualExclude(List<String> equalExclude)
void	setFieldName(String fieldName)
void	setOtherIn(Channel<Record> in)
void	setOtherInBufferSize(int otherInBufferSize)
void	setOtherName(String otherName)
void	setRecordDefinition1(RecordDefinition recordDefinition1)
void	setRecordDefinition2(RecordDefinition recordDefinition2)
void	setSourceName(String sourceName)
protected boolean	valueEquals(Object value1, Object value2)

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

destroy, getIn, getInBufferSize, init, run, setIn, setInBufferSize

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

OrderedEqualCompareProcessor

public OrderedEqualCompareProcessor()

Method Detail

geometryEquals

protected boolean geometryEquals(Record object1,
                     Record object2)

getEqualExclude

public List<String> getEqualExclude()

getFieldName

public String getFieldName()

getNotEqualFieldNames

protected Set<String> getNotEqualFieldNames(Record object1,
                                Record object2)

getOtherIn

public Channel<Record> getOtherIn()

Returns:

the in

getOtherInBufferSize

public int getOtherInBufferSize()

getOtherName

public String getOtherName()

getSourceName

public String getSourceName()

logNoMatch

protected void logNoMatch(Record object,
              boolean other)

logNotEqual

protected void logNotEqual(Record sourceObject,
               Record otherObject,
               Set<String> notEqualFieldNames,
               boolean geometryEquals)

readObject

protected Record readObject(Channel<Record> channel)

run

protected void run(Channel<Record> in)

Specified by:

run in class AbstractInProcess<Record>

setEqualExclude

public void setEqualExclude(List<String> equalExclude)

setFieldName

public void setFieldName(String fieldName)

setOtherIn

public void setOtherIn(Channel<Record> in)

Parameters:

in - the in to set

setOtherInBufferSize

public void setOtherInBufferSize(int otherInBufferSize)

setOtherName

public void setOtherName(String otherName)

setRecordDefinition1

public void setRecordDefinition1(RecordDefinition recordDefinition1)

setRecordDefinition2

public void setRecordDefinition2(RecordDefinition recordDefinition2)

setSourceName

public void setSourceName(String sourceName)

valueEquals

protected boolean valueEquals(Object value1,
                  Object value2)