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.
|
Modifier and Type | Class and Description |
---|---|
class |
HBasePartitioningFunction
A partitioning function that partitions records of data based on a HBase table.
|
Modifier and Type | Method and Description |
---|---|
PartitioningFunction |
HBasePartitioningFunction.remapFieldReferences(Map<String,String> oldToNewMapping) |
Modifier and Type | Method and Description |
---|---|
boolean |
HBasePartitioningFunction.isEquivalentPartitioning(PartitioningFunction other) |
Modifier and Type | Class and Description |
---|---|
class |
HashPartitioningFunction
A default hash partitioning function
|
class |
RangePartitioningFunction
A partitioning function that partitions records of data based on specified ranges.
|
Modifier and Type | Method and Description |
---|---|
PartitioningFunction |
KeyDrivenDataDistribution.getBasePartitionFunction()
Returns the base partitioning function.
|
protected PartitioningFunction |
UnspecifiedPartialDistribution.getPartitioningFunction() |
protected abstract PartitioningFunction |
PartialStaticDataDistribution.getPartitioningFunction()
Subclasses must override this method to provide the partitioning function to be used
|
protected PartitioningFunction |
KeyDrivenDataDistribution.getPartitioningFunction() |
protected PartitioningFunction |
BalancedDistribution.getPartitioningFunction() |
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.
|
PartitioningFunction |
HashPartitioningFunction.remapFieldReferences(Map<String,String> oldToNewMapping) |
Modifier and Type | Method and Description |
---|---|
boolean |
RangePartitioningFunction.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 |
HashPartitioningFunction.isEquivalentPartitioning(PartitioningFunction other) |
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.
|
Copyright © 2021 Actian Corporation. All rights reserved.