public interface PartitioningFunction
Modifier and Type | Interface and Description |
---|---|
static interface |
PartitioningFunction.Evaluator
Computes partition assignments for each row if input
|
Modifier and Type | Method and Description |
---|---|
PartitioningFunction.Evaluator |
getEvaluator(PartitioningFunctionContext ctx)
Create an Evaluator bound to the specified context.
|
boolean |
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 |
isFunctionOfInput()
Returns true iff, given two identical rows of input, this function will
return the same value.
|
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.
|
void |
validateForType(RecordTokenType type)
Performs validation of the specified input type
|
PartitioningFunction.Evaluator getEvaluator(PartitioningFunctionContext ctx)
ctx
- the partitioning contextvoid validateForType(RecordTokenType type)
type
- the input typeboolean isFunctionOfInput()
boolean isEquivalentPartitioning(PartitioningFunction other)
isFunctionOfInput()
, this function must
return false if isFunctionOfInput()
returns false.other
- the other functionPartitioningFunction remapFieldReferences(Map<String,String> oldToNewMapping)
oldToNewMapping
- a mapping from old names to new names. If a name is not present in the
given mapping, it will remain as-is.Copyright © 2024 Actian Corporation. All rights reserved.