Package nz.org.riskscape.engine.sched

Class LopsidedJoinAdapter<T>

java.lang.Object

nz.org.riskscape.engine.sched.LopsidedJoinAdapter<T>

public class LopsidedJoinAdapter<T>
extends Object

Wraps a LopsidedJoiner to present its methods as a Sink and a FlatProjector so that we don't need custom WorkerTask implementations to execute them in a pipeline.

Constructor Summary

Constructors

Constructor	Description
LopsidedJoinAdapter(nz.org.riskscape.engine.join.LopsidedJoiner<T> joiner)

Method Summary

Modifier and Type	Method	Description
nz.org.riskscape.engine.projection.FlatProjector	newFlatProjector()
nz.org.riskscape.engine.pipeline.SinkConstructor	newSinkConstructor()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LopsidedJoinAdapter

public LopsidedJoinAdapter(nz.org.riskscape.engine.join.LopsidedJoiner<T> joiner)

Method Details

newSinkConstructor

public nz.org.riskscape.engine.pipeline.SinkConstructor newSinkConstructor()

newFlatProjector

public nz.org.riskscape.engine.projection.FlatProjector newFlatProjector()