Uses of Class
com.pervasive.datarush.operators.DeferredCompositeOperator
Packages that use DeferredCompositeOperator
Package
Description
Provides classes and interfaces for developing dataflow operators.
Provides operators for reading and writing DataRush staging datasets.
Provides operators for joining together two data sets into a single one.
Provides operators for handling models.
Provides operators for partitioning and unpartitioning flows of data.
Provides operators for sorting and manipulating sorted
flows.
-
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operatorsModifier and TypeClassDescriptionclassConvenient base class forDeferredCompositeOperator's that are alsoRecordPipelineOperator's.Methods in com.pervasive.datarush.operators that return DeferredCompositeOperatorMethods in com.pervasive.datarush.operators with parameters of type DeferredCompositeOperatorModifier and TypeMethodDescriptionOperatorProxies.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.stagingModifier and TypeClassDescriptionfinal classForces staging of record ports.classForceStaging<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 -
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators.model
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operators.modelModifier and TypeClassDescriptionfinal classMergeModel<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.partitionModifier and TypeClassDescriptionfinal classForces parallel streams of data to be gathered into a single non-parallel stream.final classForces 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 -
Uses of DeferredCompositeOperator in com.pervasive.datarush.operators.testutils
Subclasses of DeferredCompositeOperator in com.pervasive.datarush.operators.testutilsModifier and TypeClassDescriptionfinal classA record source sink throws an error either at composition time or execution time.final classA record source that throws an error either at composition time or execution time.final classFor tests that wish to simulate a partitioned read.