Package | Description |
---|---|
com.pervasive.datarush.ports.record |
Provides implementations of port objects related to the flow of record sets
between operators.
|
Modifier and Type | Class and Description |
---|---|
class |
BalancedDistribution
Used to redistribute the data in a roughly balanced fashion.
|
class |
DynamicRangeDataDistribution
A distribution where data is range-partitioned by a selected array of keys.
|
class |
KeyDrivenDataDistribution
DataDistribution based on a set of keys from the input data.
|
class |
PartialDynamicDataDistribution
Base class for all distributions whose partitioning parameters are based on the data.
|
class |
PartialStaticDataDistribution
Base class for all distributions whose partitioning parameters are specified statically.
|
class |
UnspecifiedPartialDistribution
The default data distribution; if unspecified an operator will receive data in the same
distribution as the upstream operator.
|
Modifier and Type | Method and Description |
---|---|
PartialDataDistribution |
KeyDrivenDataDistribution.remap(FieldRemapping mapping)
Applies the given field remapping to this distribution, changing names as required.
|
PartialDataDistribution |
DynamicRangeDataDistribution.remap(FieldRemapping mapping)
Applies the given field remapping to this mapping, changing names as required.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
UnspecifiedPartialDistribution.requiresRepartitionFrom(PartialDataDistribution source) |
protected abstract boolean |
PartialStaticDataDistribution.requiresRepartitionFrom(PartialDataDistribution source)
Subclasses must override this method to declare whether a repartition is required given the source
distribution.
|
protected boolean |
KeyDrivenDataDistribution.requiresRepartitionFrom(PartialDataDistribution source) |
protected boolean |
BalancedDistribution.requiresRepartitionFrom(PartialDataDistribution source) |
Copyright © 2019 Actian Corporation. All rights reserved.