com.revolsys.gis.parallel

Class RecordConverterProcess

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

com.revolsys.parallel.process.AbstractInOutProcess<I,O>

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

com.revolsys.gis.parallel.RecordConverterProcess

All Implemented Interfaces:

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

public class RecordConverterProcess
extends BaseInOutProcess<Record,Record>

Constructor Summary

Constructors

Constructor and Description
RecordConverterProcess()

Method Summary

Methods

Modifier and Type	Method and Description
void	addTypeConverter(String typePath, org.springframework.core.convert.converter.Converter<Record,Record> converter)
void	addTypeFilterConverter(String typePath, FilterRecordConverter filterConverter)
protected Record	convert(Record source)
protected Record	convertObjectWithNoConverter(Record source)
org.springframework.core.convert.converter.Converter<Record,Record>	getDefaultConverter()
Map<String,Collection<FilterRecordConverter>>	getFilterTypeConverterMap()
Statistics	getStatistics()
RecordDefinition	getTargetRecordDefinition(String typePath)
RecordDefinitionFactory	getTargetRecordDefinitionFactory()
Map<String,org.springframework.core.convert.converter.Converter<Record,Record>>	getTypeConverterMap()
protected void	postRun(Channel<Record> in, Channel<Record> out)
protected void	preRun(Channel<Record> in, Channel<Record> out)
protected void	process(Channel<Record> in, Channel<Record> out, Record source)
void	setDefaultConverter(org.springframework.core.convert.converter.Converter<Record,Record> defaultConverter)
void	setSimpleMapping(Map<Object,Map<String,Object>> simpleMapping)
void	setStatistics(Statistics statistics)
void	setTargetRecordDefinitionFactory(RecordDefinitionFactory targetRecordDefinitionFactory)
void	setTypeConverterMap(Map<String,org.springframework.core.convert.converter.Converter<Record,Record>> typeConverterMap)
void	setTypeFilterConverterMap(Map<String,Collection<FilterRecordConverter>> typeConverterMap)

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

run

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

RecordConverterProcess

public RecordConverterProcess()

Method Detail

addTypeConverter

public void addTypeConverter(String typePath,
                    org.springframework.core.convert.converter.Converter<Record,Record> converter)

addTypeFilterConverter

public void addTypeFilterConverter(String typePath,
                          FilterRecordConverter filterConverter)

convert

protected Record convert(Record source)

convertObjectWithNoConverter

protected Record convertObjectWithNoConverter(Record source)

getDefaultConverter

public org.springframework.core.convert.converter.Converter<Record,Record> getDefaultConverter()

getFilterTypeConverterMap

public Map<String,Collection<FilterRecordConverter>> getFilterTypeConverterMap()

getStatistics

public Statistics getStatistics()

getTargetRecordDefinition

public RecordDefinition getTargetRecordDefinition(String typePath)

getTargetRecordDefinitionFactory

public RecordDefinitionFactory getTargetRecordDefinitionFactory()

getTypeConverterMap

public Map<String,org.springframework.core.convert.converter.Converter<Record,Record>> getTypeConverterMap()

postRun

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

Overrides:

postRun in class BaseInOutProcess<Record,Record>

preRun

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

Overrides:

preRun in class BaseInOutProcess<Record,Record>

process

protected void process(Channel<Record> in,
           Channel<Record> out,
           Record source)

Overrides:

process in class BaseInOutProcess<Record,Record>

setDefaultConverter

public void setDefaultConverter(org.springframework.core.convert.converter.Converter<Record,Record> defaultConverter)

setSimpleMapping

public void setSimpleMapping(Map<Object,Map<String,Object>> simpleMapping)

setStatistics

public void setStatistics(Statistics statistics)

setTargetRecordDefinitionFactory

public void setTargetRecordDefinitionFactory(RecordDefinitionFactory targetRecordDefinitionFactory)

setTypeConverterMap

public void setTypeConverterMap(Map<String,org.springframework.core.convert.converter.Converter<Record,Record>> typeConverterMap)

setTypeFilterConverterMap

public void setTypeFilterConverterMap(Map<String,Collection<FilterRecordConverter>> typeConverterMap)