Uses of Class
com.pervasive.datarush.ports.record.KeyDrivenDataDistribution

Packages that use KeyDrivenDataDistribution

Package	Description
com.pervasive.datarush.ports.record	Provides implementations of port objects related to the flow of record sets between operators.

Uses of KeyDrivenDataDistribution in com.pervasive.datarush.ports.record

Methods in com.pervasive.datarush.ports.record that return KeyDrivenDataDistribution

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