Package | Description |
---|---|
com.pervasive.datarush.ports.record |
Provides implementations of port objects related to the flow of record sets
between operators.
|
Modifier and Type | Method and Description |
---|---|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.hashed(List<String> keys)
Returns a distribution that distributes based on a hashcode of
the named key fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.hashed(String... keys)
Returns a distribution that distributes based on a hashcode of
the named key fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.keyed(PartitioningFunction basePartitionFunction,
List<String> keys)
Returns a distribution that distributes based on the given function
of the named key fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.keyed(PartitioningFunction basePartitionFunction,
String... keys)
Returns a distribution that distributes based on the given function
of the named key fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.localKeyed(PartitioningFunction basePartitionFunction,
List<String> keys)
For advanced use only; this redistributes per-JVM but not across the cluster.
|
static KeyDrivenDataDistribution |
MetadataUtil.negotiate(DataDistribution distribution,
String... keys)
Negotiates the required data distribution with the specified distribution
using the given grouping fields.
|
static KeyDrivenDataDistribution |
MetadataUtil.negotiateGrouping(MetadataCalculationContext ctx,
RecordPort port,
SortKey... keys)
Negotiates the required data distribution on the specified port
using the given grouping fields with sort ordering.
|
static KeyDrivenDataDistribution |
MetadataUtil.negotiateGrouping(MetadataCalculationContext ctx,
RecordPort port,
String... keys)
Negotiates the required data ordering and distribution on the specified port
using the given grouping fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.ranges(List<RecordToken> boundaries)
Returns a distribution that distributes based on specified range boundaries
|
Copyright © 2016 Actian Corporation. All rights reserved.