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 classAbstractDeferredRecordOperatorConvenient base class forDeferredCompositeOperator's that are alsoRecordPipelineOperator's.Methods in com.pervasive.datarush.operators that return DeferredCompositeOperator Modifier and Type Method Description DeferredCompositeOperatorOperatorProxies.DeferredCompositeOperatorProxy. getTarget()Methods in com.pervasive.datarush.operators with parameters of type DeferredCompositeOperator Modifier and Type Method Description static OperatorProxies.DeferredCompositeOperatorProxyOperatorProxies. 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 classForceRecordStagingForces 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 Modifier and Type Class Description classUnionAllProvides 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 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.partition Modifier and Type Class Description classGatherHintForces parallel streams of data to be gathered into a single non-parallel stream.classPartitionHintForces 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 classSortSorts 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 classErrorSinkA record source sink throws an error either at composition time or execution time.classErrorSourceA record source that throws an error either at composition time or execution time.classSimulatePartitionsFor tests that wish to simulate a partitioned read.
-