public class BeamJavaUdfCalcRule extends BeamCalcSplittingRule
BeamCalcSplittingRule
to replace Calc
with BeamCalcRel
.
Equivalent to BeamCalcRule
but with limits to supported types and operators.
This class is intended only for testing purposes. See BeamZetaSqlCalcSplittingRule
.
Modifier and Type | Field and Description |
---|---|
static BeamJavaUdfCalcRule |
INSTANCE |
Modifier and Type | Method and Description |
---|---|
protected CalcRelSplitter.RelType[] |
getRelTypes() |
matches, onMatch
any, convert, convert, convertList, convertOperand, convertOperand, equals, equals, getOperand, getOperands, getOutConvention, getOutTrait, hashCode, none, operand, operand, operand, operand, operand, operandJ, operandJ, some, toString, unordered
public static final BeamJavaUdfCalcRule INSTANCE
protected CalcRelSplitter.RelType[] getRelTypes()
getRelTypes
in class BeamCalcSplittingRule