Uses of Interface
com.pervasive.datarush.operators.OperatorComposable

Packages that use OperatorComposable

Package	Description
com.pervasive.datarush.graphs	Provides classes and interfaces for the construction of executable dataflow graphs.
com.pervasive.datarush.operators	Provides classes and interfaces for developing dataflow operators.

Uses of OperatorComposable in com.pervasive.datarush.graphs

Subinterfaces of OperatorComposable in com.pervasive.datarush.graphs

Modifier and Type	Interface	Description
interface	LogicalGraph	Represents a logical graph which is intended to be executed.
interface	LogicalSubgraph	Extension of LogicalGraph used by IterativeOperator's.

Uses of OperatorComposable in com.pervasive.datarush.operators

Subinterfaces of OperatorComposable in com.pervasive.datarush.operators

Modifier and Type	Interface	Description
interface	CompositionContext	Composition context used by CompositeOperator's.
interface	DeferredCompositionContext	Composition context passed to DeferredCompositeOperator.compose(DeferredCompositionContext).

Classes in com.pervasive.datarush.operators that implement OperatorComposable

Modifier and Type	Class	Description
final class	OpenComposite	A composite operator that can be externally composed.
final class	OpenModelSink<T>	A model sink that can be externally composed.
final class	OpenModelSource<T>	A model source that can be externally composed.
final class	OpenMultiModelSink<T>	A model sink that can be externally composed.
final class	OpenMultiModelSource<T>	A model source that can be externally composed.
final class	OpenMultiRecordSink	A record sink that can be externally composed.
final class	OpenMultiRecordSource	A record source that can be externally composed.
final class	OpenRecordSink	A record sink that can be externally composed.
final class	OpenRecordSource	A record source that can be externally composed.

Methods in com.pervasive.datarush.operators with parameters of type OperatorComposable

Modifier and Type	Method	Description
DumpPartitions	OperatorTestHelper.distributedOutput(OperatorComposable graph, RecordPort port, boolean sort)
void	CompositionIterator.finalComposition(OperatorComposable ctx)	Called after execute is called.
DumpPartitions	OperatorTestHelper.localOutput(OperatorComposable graph, RecordPort port, boolean sort)