com.pervasive.datarush.ports.record

Interface PartitioningFunctionContext

public interface PartitioningFunctionContext

Contextual information for PartitioningFunction's. Clients should not implement this interface.

Method Summary

Modifier and Type	Method and Description
RecordValued	getInput() Returns the data to be partitioned
NodeAllocationPlan	getNodeAllocation() Returns the node allocation.
int	getTargetPartitionCount() Returns the number of target partitions.

Method Detail

getNodeAllocation

NodeAllocationPlan getNodeAllocation()

Returns the node allocation. For use by partitioners that require host information when making partition assignment decisions. Note that this is the full node allocation. Partitioners may choose to call NodeAllocationPlan.subPlan(int), passing in getTargetPartitionCount()

Returns:

the node allocation

getInput

RecordValued getInput()

Returns the data to be partitioned

Returns:

the data to be partitioned

getTargetPartitionCount

int getTargetPartitionCount()

Returns the number of target partitions.

Returns:

the number of target partitions.