Uses of Class
com.pervasive.datarush.operators.DeferredCompositeOperator
-
Packages that use DeferredCompositeOperator Package Description com.pervasive.datarush.operators Provides classes and interfaces for developing dataflow operators.com.pervasive.datarush.operators.io.staging Provides operators for reading and writing DataRush staging datasets.com.pervasive.datarush.operators.join Provides operators for joining together two data sets into a single one.com.pervasive.datarush.operators.model Provides operators for handling models.com.pervasive.datarush.operators.partition Provides operators for partitioning and unpartitioning flows of data.com.pervasive.datarush.operators.sort Provides operators for sorting and manipulating sorted flows.com.pervasive.datarush.operators.testutils -
-
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operators Modifier and Type Class Description class
AbstractDeferredRecordOperator
Convenient base class forDeferredCompositeOperator
's that are alsoRecordPipelineOperator
's.Methods in com.pervasive.datarush.operators that return DeferredCompositeOperator Modifier and Type Method Description DeferredCompositeOperator
OperatorProxies.DeferredCompositeOperatorProxy. getTarget()
Methods in com.pervasive.datarush.operators with parameters of type DeferredCompositeOperator Modifier and Type Method Description static OperatorProxies.DeferredCompositeOperatorProxy
OperatorProxies. proxy(DeferredCompositeOperator op)
Public only as a matter of implementation; not intended for external use Creates a proxy to the given operator that allows the framework to access its protected methods. -
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators.io.staging
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operators.io.staging Modifier and Type Class Description class
ForceRecordStaging
Forces staging of record ports.class
ForceStaging<P extends LogicalPort>
Forces the operators on the input and output sides to execute sequentially, instead of concurrently. -
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators.join
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operators.join Modifier and Type Class Description class
UnionAll
Provides a union of two data sources. -
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators.model
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operators.model Modifier and Type Class Description class
MergeModel<T>
This operator is uses to force a merge of a partitioned model into a single model. -
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators.partition
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operators.partition Modifier and Type Class Description class
GatherHint
Forces parallel streams of data to be gathered into a single non-parallel stream.class
PartitionHint
Forces the input data to be partitioned into parallel streams of data for subsequent parallel operations. -
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators.sort
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operators.sort Modifier and Type Class Description class
Sort
Sorts the input data. -
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators.testutils
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operators.testutils Modifier and Type Class Description class
ErrorSink
A record source sink throws an error either at composition time or execution time.class
ErrorSource
A record source that throws an error either at composition time or execution time.class
SimulatePartitions
For tests that wish to simulate a partitioned read.
-