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 ofLogicalGraph
used byIterativeOperator
'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 byCompositeOperator
's.interface
DeferredCompositionContext
Composition context passed toDeferredCompositeOperator.compose(DeferredCompositionContext)
.Classes in com.pervasive.datarush.operators that implement OperatorComposable Modifier and Type Class Description class
OpenComposite
A composite operator that can be externally composed.class
OpenModelSink<T>
A model sink that can be externally composed.class
OpenModelSource<T>
A model source that can be externally composed.class
OpenMultiModelSink<T>
A model sink that can be externally composed.class
OpenMultiModelSource<T>
A model source that can be externally composed.class
OpenMultiRecordSink
A record sink that can be externally composed.class
OpenMultiRecordSource
A record source that can be externally composed.class
OpenRecordSink
A record sink that can be externally composed.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)
-