- java.lang.Object
-
- com.pervasive.datarush.ports.record.HashPartitioningFunction
-
- All Implemented Interfaces:
PartitioningFunction
public final class HashPartitioningFunction extends Object implements PartitioningFunction
A default hash partitioning function
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface com.pervasive.datarush.ports.record.PartitioningFunction
PartitioningFunction.Evaluator
-
-
Field Summary
Fields Modifier and Type Field Description static HashPartitioningFunctionINSTANCEThe single instance of this class
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description PartitioningFunction.EvaluatorgetEvaluator(PartitioningFunctionContext ctx)Create an Evaluator bound to the specified context.booleanisEquivalentPartitioning(PartitioningFunction other)Returns true iff, given a single row of input, this function is guaranteed to produce the same partitioning as the other function.booleanisFunctionOfInput()Returns true iff, given two identical rows of input, this function will return the same value.PartitioningFunctionremapFieldReferences(Map<String,String> oldToNewMapping)Creates a new function, equivalent to the given function, but with all field references renamed according to the given mapping.voidvalidateForType(RecordTokenType type)Performs validation of the specified input type
-
-
-
Field Detail
-
INSTANCE
public static HashPartitioningFunction INSTANCE
The single instance of this class
-
-
Method Detail
-
getEvaluator
public PartitioningFunction.Evaluator getEvaluator(PartitioningFunctionContext ctx)
Description copied from interface:PartitioningFunctionCreate an Evaluator bound to the specified context.- Specified by:
getEvaluatorin interfacePartitioningFunction- Parameters:
ctx- the partitioning context- Returns:
- an Evaluator bound to the specified context.
-
validateForType
public void validateForType(RecordTokenType type)
Description copied from interface:PartitioningFunctionPerforms validation of the specified input type- Specified by:
validateForTypein interfacePartitioningFunction- Parameters:
type- the input type
-
isEquivalentPartitioning
public boolean isEquivalentPartitioning(PartitioningFunction other)
Description copied from interface:PartitioningFunctionReturns true iff, given a single row of input, this function is guaranteed to produce the same partitioning as the other function. A return of true thus implies the following:- both functions are deterministic
- both function are stateless (not sensitive to previous values read or to input ordering)
In addition, in order to be consistent withPartitioningFunction.isFunctionOfInput(), this function must return false ifPartitioningFunction.isFunctionOfInput()returns false.- Specified by:
isEquivalentPartitioningin interfacePartitioningFunction- Parameters:
other- the other function- Returns:
- whether this function produces the same results as the other function.
-
isFunctionOfInput
public boolean isFunctionOfInput()
Description copied from interface:PartitioningFunctionReturns true iff, given two identical rows of input, this function will return the same value. A return of true thus implies :- the function is deterministic
- the function is stateless (not sensitive to previous values read or to input ordering)
- Specified by:
isFunctionOfInputin interfacePartitioningFunction- Returns:
- whether this function is a stateless, deterministic function of input
-
remapFieldReferences
public PartitioningFunction remapFieldReferences(Map<String,String> oldToNewMapping)
Description copied from interface:PartitioningFunctionCreates a new function, equivalent to the given function, but with all field references renamed according to the given mapping.- Specified by:
remapFieldReferencesin interfacePartitioningFunction- Parameters:
oldToNewMapping- a mapping from old names to new names. If a name is not present in the given mapping, it will remain as-is.- Returns:
- a new function with all field reference renamed appropriately
-
-