Uses of Interface
com.pervasive.datarush.ports.record.PartitioningFunction

Packages that use PartitioningFunction

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

Uses of PartitioningFunction in com.pervasive.datarush.hbase

Classes in com.pervasive.datarush.hbase that implement PartitioningFunction

Modifier and Type	Class	Description
class	HBasePartitioningFunction	A partitioning function that partitions records of data based on a HBase table.

Methods in com.pervasive.datarush.hbase that return PartitioningFunction

Modifier and Type	Method	Description
PartitioningFunction	HBasePartitioningFunction.remapFieldReferences(Map<String,String> oldToNewMapping)

Methods in com.pervasive.datarush.hbase with parameters of type PartitioningFunction

Modifier and Type	Method	Description
boolean	HBasePartitioningFunction.isEquivalentPartitioning(PartitioningFunction other)

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

Classes in com.pervasive.datarush.ports.record that implement PartitioningFunction

Modifier and Type	Class	Description
class	HashPartitioningFunction	A default hash partitioning function
class	RangePartitioningFunction	A partitioning function that partitions records of data based on specified ranges.

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

Modifier and Type	Method	Description
PartitioningFunction	KeyDrivenDataDistribution.getBasePartitionFunction()	Returns the base partitioning function.
protected PartitioningFunction	BalancedDistribution.getPartitioningFunction()
protected PartitioningFunction	KeyDrivenDataDistribution.getPartitioningFunction()
protected abstract PartitioningFunction	PartialStaticDataDistribution.getPartitioningFunction()	Subclasses must override this method to provide the partitioning function to be used
protected PartitioningFunction	UnspecifiedPartialDistribution.getPartitioningFunction()
PartitioningFunction	HashPartitioningFunction.remapFieldReferences(Map<String,String> oldToNewMapping)
PartitioningFunction	PartitioningFunction.remapFieldReferences(Map<String,String> oldToNewMapping)	Creates a new function, equivalent to the given function, but with all field references renamed according to the given mapping.

Methods in com.pervasive.datarush.ports.record with parameters of type PartitioningFunction

Modifier and Type	Method	Description
boolean	HashPartitioningFunction.isEquivalentPartitioning(PartitioningFunction other)
boolean	PartitioningFunction.isEquivalentPartitioning(PartitioningFunction other)	Returns true iff, given a single row of input, this function is guaranteed to produce the same partitioning as the other function.
boolean	RangePartitioningFunction.isEquivalentPartitioning(PartitioningFunction other)
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.keyed(PartitioningFunction basePartitionFunction, List<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.