com.revolsys.parallel.process

Class FilterProcess<T>

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

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

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

StatisticsFilterProcess

public class FilterProcess<T>
extends BaseInOutProcess<T,T>

Constructor Summary

Constructors

Constructor and Description
FilterProcess()

Method Summary

Methods

Modifier and Type	Method and Description
Filter<T>	getFilter()
boolean	isInvert()
protected void	postAccept(T object)
protected void	postReject(T object)
protected void	process(Channel<T> in, Channel<T> out, T object)
void	setFilter(Filter<T> filter)
void	setInvert(boolean invert)

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

postRun, preRun, 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

FilterProcess

public FilterProcess()

Method Detail

getFilter

public Filter<T> getFilter()

isInvert

public boolean isInvert()

postAccept

protected void postAccept(T object)

postReject

protected void postReject(T object)

process

protected void process(Channel<T> in,
           Channel<T> out,
           T object)

Overrides:

process in class BaseInOutProcess<T,T>

setFilter

public void setFilter(Filter<T> filter)

setInvert

public void setInvert(boolean invert)