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.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDeferredRecordOperator
Convenient base class for
DeferredCompositeOperator 's that are
also RecordPipelineOperator 's. |
Modifier and Type | Method and Description |
---|---|
DeferredCompositeOperator |
OperatorProxies.DeferredCompositeOperatorProxy.getTarget() |
Modifier and Type | Method and 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.
|
Modifier and Type | Class and 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.
|
Modifier and Type | Class and Description |
---|---|
class |
UnionAll
Provides a union of two data sources.
|
Modifier and Type | Class and Description |
---|---|
class |
MergeModel<T>
This operator is uses to force a merge of a partitioned model into a single model.
|
Modifier and Type | Class and 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.
|
Modifier and Type | Class and Description |
---|---|
class |
Sort
Sorts the input data.
|
Copyright © 2020 Actian Corporation. All rights reserved.