com.revolsys.gis.parallel

Class WriterProcess

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

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

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

com.revolsys.gis.parallel.WriterProcess

All Implemented Interfaces:

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

public class WriterProcess
extends BaseInProcess<Record>

Constructor Summary

Constructors

Constructor and Description
WriterProcess()
WriterProcess(Channel<Record> in, Writer<Record> writer)
WriterProcess(Writer<Record> writer)
WriterProcess(Writer<Record> writer, int inBufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
Writer<Record>	getWriter()
protected void	postRun(Channel<Record> in)
protected void	process(Channel<Record> in, Record record)
void	setWriter(Writer<Record> writer)

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

preRun, run

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

WriterProcess

public WriterProcess()

WriterProcess

public WriterProcess(Channel<Record> in,
             Writer<Record> writer)

WriterProcess

public WriterProcess(Writer<Record> writer)

WriterProcess

public WriterProcess(Writer<Record> writer,
             int inBufferSize)

Method Detail

getWriter

public Writer<Record> getWriter()

Returns:

the writer

postRun

protected void postRun(Channel<Record> in)

Overrides:

postRun in class BaseInProcess<Record>

process

protected void process(Channel<Record> in,
           Record record)

Overrides:

process in class BaseInProcess<Record>

setWriter

public void setWriter(Writer<Record> writer)