Uses of Class
com.revolsys.parallel.channel.Channel

Packages that use Channel

Package	Description
com.revolsys.gis.algorithm.index
com.revolsys.gis.cs.parallel
com.revolsys.gis.graph.process
com.revolsys.gis.graph.visitor
com.revolsys.gis.parallel
com.revolsys.gis.tin
com.revolsys.parallel.channel
com.revolsys.parallel.process
com.revolsys.transaction

Uses of Channel in com.revolsys.gis.algorithm.index

Methods in com.revolsys.gis.algorithm.index with parameters of type Channel

Modifier and Type	Method and Description
void	PointRecordMap.write(Channel<Record> out)

Uses of Channel in com.revolsys.gis.cs.parallel

Methods in com.revolsys.gis.cs.parallel with parameters of type Channel

Modifier and Type	Method and Description
protected void	GeometryProjection.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	GeometryProjection.process(Channel<Record> in, Channel<Record> out, Record object)

Uses of Channel in com.revolsys.gis.graph.process

Methods in com.revolsys.gis.graph.process with parameters of type Channel

Modifier and Type	Method and Description
protected void	GraphProcessor.postRun(Channel<Record> in, Channel<Record> out)
protected void	GraphProcessor.postRun(Channel<Record> in, Channel<Record> out)
protected void	GraphProcessor.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	GraphProcessor.process(Channel<Record> in, Channel<Record> out, Record object)

Uses of Channel in com.revolsys.gis.graph.visitor

Methods in com.revolsys.gis.graph.visitor with parameters of type Channel

Modifier and Type	Method and Description
static <T> void	ChannelOutEdgeVisitor.write(Graph<T> graph, Channel<T> out)
static <T> void	ChannelOutEdgeVisitor.write(Graph<T> graph, Filter<T> filter, Channel<T> out)

Constructors in com.revolsys.gis.graph.visitor with parameters of type Channel

Constructor and Description
ChannelOutEdgeVisitor(Channel<T> out)

Uses of Channel in com.revolsys.gis.parallel

Methods in com.revolsys.gis.parallel that return Channel

Modifier and Type	Method and Description
Channel<Record>	CreateObjectsWithinDistanceOfGeometry.getGeometryIn()
Channel<Record>	SynchronizationProcess.getIn()
Channel<Record>	OrderedEqualCompareProcessor.getOtherIn()
Channel<Record>	AbstractMergeProcess.getOtherIn()

Methods in com.revolsys.gis.parallel with parameters of type Channel

Modifier and Type	Method and Description
protected void	WriterProcess.postRun(Channel<Record> in)
protected void	ScriptExecutorProcess.postRun(Channel<Record> in)
protected void	StatisticsProcess.postRun(Channel<Record> in, Channel<Record> out)
protected void	StatisticsProcess.postRun(Channel<Record> in, Channel<Record> out)
protected void	SplitGeometryProcess.postRun(Channel<Record> in, Channel<Record> out)
protected void	SplitGeometryProcess.postRun(Channel<Record> in, Channel<Record> out)
protected void	SortByType.postRun(Channel<Record> in, Channel<Record> out)
protected void	SortByType.postRun(Channel<Record> in, Channel<Record> out)
protected void	Sort.postRun(Channel<Record> in, Channel<Record> out)
protected void	Sort.postRun(Channel<Record> in, Channel<Record> out)
protected void	RecordConverterProcess.postRun(Channel<Record> in, Channel<Record> out)
protected void	RecordConverterProcess.postRun(Channel<Record> in, Channel<Record> out)
protected void	StatisticsProcess.preRun(Channel<Record> in, Channel<Record> out)
protected void	StatisticsProcess.preRun(Channel<Record> in, Channel<Record> out)
protected void	SplitGeometryProcess.preRun(Channel<Record> in, Channel<Record> out)
protected void	SplitGeometryProcess.preRun(Channel<Record> in, Channel<Record> out)
protected void	RecordConverterProcess.preRun(Channel<Record> in, Channel<Record> out)
protected void	RecordConverterProcess.preRun(Channel<Record> in, Channel<Record> out)
protected void	CreateObjectsWithinDistanceOfGeometry.preRun(Channel<Record> in, Channel<Record> out)
protected void	CreateObjectsWithinDistanceOfGeometry.preRun(Channel<Record> in, Channel<Record> out)
protected void	ValidateGeometryRange.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	ValidateGeometryRange.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	StatisticsProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	StatisticsProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	SplitGeometryProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	SplitGeometryProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	SortByType.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	SortByType.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	Sort.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	Sort.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	RecordValidationProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	RecordValidationProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	RecordConverterProcess.process(Channel<Record> in, Channel<Record> out, Record source)
protected void	RecordConverterProcess.process(Channel<Record> in, Channel<Record> out, Record source)
protected void	OutsideBoundaryInOutProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	OutsideBoundaryInOutProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	GeometryBufferProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	GeometryBufferProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	ExcludeSavedObjectsInOutProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	ExcludeSavedObjectsInOutProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	CreateObjectsWithinDistanceOfGeometry.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	CreateObjectsWithinDistanceOfGeometry.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	CopyProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	CopyProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	ConverterProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	ConverterProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	ClipGeometryProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	ClipGeometryProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	WriterProcess.process(Channel<Record> in, Record record)
protected void	ScriptExecutorProcess.process(Channel<Record> in, Record object)
protected void	RecordStoreUpdateProcess.process(Channel<Record> in, Record object) Process each object from the channel
protected boolean	StatisticsMultipleFilterProcess.processFilter(Record object, Filter<Record> filter, Channel<Record> filterOut)
protected void	CompareProcessor.processObjects(RecordDefinition recordDefinition, Channel<Record> out)
protected abstract void	AbstractMergeProcess.processObjects(RecordDefinition currentType, Channel<Record> out)
protected Record	OrderedEqualCompareProcessor.readObject(Channel<Record> channel)
protected void	ReaderProcess.run(Channel<Record> out)
protected void	OrderedEqualCompareProcessor.run(Channel<Record> in)
protected void	SynchronizationProcess.run(Channel<Record> in, Channel<Record> out)
protected void	SynchronizationProcess.run(Channel<Record> in, Channel<Record> out)
protected void	AddDefaultValuesProcess.run(Channel<Record> in, Channel<Record> out)
protected void	AddDefaultValuesProcess.run(Channel<Record> in, Channel<Record> out)
protected void	AbstractMergeProcess.run(Channel<Record> in, Channel<Record> out)
protected void	AbstractMergeProcess.run(Channel<Record> in, Channel<Record> out)
protected void	IterableProcess.run(Channel<T> out)
void	CreateObjectsWithinDistanceOfGeometry.setGeometryIn(Channel<Record> geometryIn)
void	OrderedEqualCompareProcessor.setOtherIn(Channel<Record> in)
void	AbstractMergeProcess.setOtherIn(Channel<Record> in)
protected void	StatisticsRecordIterableProcess.write(Channel<Record> out, Record record)
protected void	IterableProcess.write(Channel<T> out, T object)

Constructors in com.revolsys.gis.parallel with parameters of type Channel

Constructor and Description
IterableProcess(Channel<T> out, Iterable<T> iterable)
ReaderProcess(Channel<Record> out, RecordIterator reader)
WriterProcess(Channel<Record> in, Writer<Record> writer)

Uses of Channel in com.revolsys.gis.tin

Methods in com.revolsys.gis.tin that return Channel

Modifier and Type	Method and Description
Channel<Record>	TinProcess.getTinIn()

Methods in com.revolsys.gis.tin with parameters of type Channel

Modifier and Type	Method and Description
protected void	TinProcess.postRun(Channel<Record> in, Channel<Record> out)
protected void	TinProcess.postRun(Channel<Record> in, Channel<Record> out)
protected void	TinProcess.process(Channel<Record> in, Channel<Record> out, Record object)
protected void	TinProcess.process(Channel<Record> in, Channel<Record> out, Record object)
void	TinProcess.setTinIn(Channel<Record> tinIn)

Uses of Channel in com.revolsys.parallel.channel

Methods in com.revolsys.parallel.channel that return Channel

Modifier and Type	Method and Description
Channel<T>	SetBeanChannelProperty.getChannel()

Methods in com.revolsys.parallel.channel with parameters of type Channel

Modifier and Type	Method and Description
void	SetBeanChannelProperty.setChannel(Channel<T> channel)

Uses of Channel in com.revolsys.parallel.process

Methods in com.revolsys.parallel.process that return Channel

Modifier and Type	Method and Description
Channel<T>	InProcess.getIn()
Channel<T>	AbstractInProcess.getIn()
Channel<I>	AbstractInOutProcess.getIn()
Channel<T>	OutProcess.getOut()
Channel<T>	AbstractOutProcess.getOut()
Channel<O>	AbstractInOutProcess.getOut()

Methods in com.revolsys.parallel.process that return types with arguments of type Channel

Modifier and Type	Method and Description
List<Channel<Runnable>>	RunnableChannelExecutor.getChannels()
Map<Filter<T>,Channel<T>>	MultipleFilterProcess.getFilters()

Methods in com.revolsys.parallel.process with parameters of type Channel

Modifier and Type	Method and Description
protected void	BaseInOutProcess.postRun(Channel<I> in, Channel<O> out)
protected void	BaseInOutProcess.postRun(Channel<I> in, Channel<O> out)
protected void	BaseInProcess.postRun(Channel<T> in)
protected void	BaseInOutProcess.preRun(Channel<I> in, Channel<O> out)
protected void	BaseInOutProcess.preRun(Channel<I> in, Channel<O> out)
protected void	BaseInProcess.preRun(Channel<T> in)
protected void	MultipleFilterProcess.preRun(Channel<T> in, Channel<T> out)
protected void	MultipleFilterProcess.preRun(Channel<T> in, Channel<T> out)
protected void	BaseInOutProcess.process(Channel<I> in, Channel<O> out, I object)
protected void	BaseInOutProcess.process(Channel<I> in, Channel<O> out, I object)
protected void	MultipleFilterProcess.process(Channel<T> in, Channel<T> out, T object)
protected void	MultipleFilterProcess.process(Channel<T> in, Channel<T> out, T object)
protected void	FilterProcess.process(Channel<T> in, Channel<T> out, T object)
protected void	FilterProcess.process(Channel<T> in, Channel<T> out, T object)
protected void	BlackHole.process(Channel<T> in, T object) Process the object.
protected void	BaseInProcess.process(Channel<T> in, T object)
protected boolean	MultipleFilterProcess.processFilter(T object, Filter<T> filter, Channel<T> filterOut)
protected void	BaseInOutProcess.run(Channel<I> in, Channel<O> out)
protected void	BaseInOutProcess.run(Channel<I> in, Channel<O> out)
protected abstract void	AbstractInOutProcess.run(Channel<I> in, Channel<O> out)
protected abstract void	AbstractInOutProcess.run(Channel<I> in, Channel<O> out)
protected void	Delta.run(Channel<T> in)
protected void	BaseInProcess.run(Channel<T> in)
protected abstract void	AbstractOutProcess.run(Channel<T> out)
protected abstract void	AbstractInProcess.run(Channel<T> in)
void	AbstractInOutProcess.setIn(Channel<I> in)
void	InProcess.setIn(Channel<T> in)
void	AbstractInProcess.setIn(Channel<T> in)
void	AbstractInOutProcess.setOut(Channel<O> out)
void	OutProcess.setOut(Channel<T> out)
void	AbstractOutProcess.setOut(Channel<T> out)

Method parameters in com.revolsys.parallel.process with type arguments of type Channel

Modifier and Type	Method and Description
void	RunnableChannelExecutor.setChannels(List<Channel<Runnable>> channels)
void	MultipleFilterProcess.setFilters(Map<Filter<T>,Channel<T>> filters)

Constructors in com.revolsys.parallel.process with parameters of type Channel

Constructor and Description
AbstractInOutProcess(Channel<I> in, Channel<O> out)
AbstractInOutProcess(Channel<I> in, Channel<O> out)
AbstractInProcess(Channel<T> in)
AbstractOutProcess(Channel<T> out)
BaseInProcess(Channel<T> in)

Uses of Channel in com.revolsys.transaction

Methods in com.revolsys.transaction with parameters of type Channel

Modifier and Type	Method and Description
static <V> void	SendToChannelAfterCommit.send(Channel<V> channel, V value)

Constructors in com.revolsys.transaction with parameters of type Channel

Constructor and Description
SendToChannelAfterCommit(Channel<T> channel, T object)