org.apache.flink.table.planner.functions.sql

Class FlinkTimestampWithPrecisionDynamicFunction

java.lang.Object

org.apache.calcite.sql.SqlOperator

org.apache.calcite.sql.SqlFunction

org.apache.calcite.sql.fun.SqlAbstractTimeFunction

org.apache.flink.table.planner.functions.sql.FlinkTimestampDynamicFunction

org.apache.flink.table.planner.functions.sql.FlinkTimestampWithPrecisionDynamicFunction

@Internal
public class FlinkTimestampWithPrecisionDynamicFunction
extends FlinkTimestampDynamicFunction

Function that used to define SQL time function like LOCALTIMESTAMP, CURRENT_TIMESTAMP, NOW() in Flink, the function support configuring the return type and the * precision of return type.

Field Summary

Fields

Modifier and Type	Field and Description
static String	NOW function name for 'NOW()'.

Fields inherited from class org.apache.flink.table.planner.functions.sql.FlinkTimestampDynamicFunction

isBatchMode

Fields inherited from class org.apache.calcite.sql.SqlOperator

kind, MDX_PRECEDENCE, NL

Constructor Summary

Constructors

Constructor and Description
FlinkTimestampWithPrecisionDynamicFunction(String name, org.apache.calcite.sql.type.SqlTypeName typeName, boolean isBatchMode, int precision)

Method Summary

Modifier and Type	Method and Description
boolean	equals(@Nullable Object obj)
int	hashCode()
org.apache.calcite.rel.type.RelDataType	inferReturnType(org.apache.calcite.sql.SqlOperatorBinding opBinding)

Methods inherited from class org.apache.flink.table.planner.functions.sql.FlinkTimestampDynamicFunction

isDeterministic, isDynamicFunction

Methods inherited from class org.apache.calcite.sql.fun.SqlAbstractTimeFunction

getMonotonicity, getSyntax

Methods inherited from class org.apache.calcite.sql.SqlFunction

deriveType, getFunctionType, getNameAsId, getParamNames, getParamTypes, getSqlIdentifier, isQuantifierAllowed, unparse, validateCall, validateQuantifier

Methods inherited from class org.apache.calcite.sql.SqlOperator

acceptCall, acceptCall, adjustType, allowsFraming, argumentMustBeScalar, checkOperandCount, checkOperandTypes, constructArgNameList, constructArgTypeList, constructOperandList, createCall, createCall, createCall, createCall, createCall, createCall, createCall, getAllowedSignatures, getAllowedSignatures, getKind, getLeftPrec, getMonotonicity, getName, getOperandCountRange, getOperandTypeChecker, getOperandTypeInference, getReturnTypeInference, getRightPrec, getSignatureTemplate, getStrongPolicyInference, inferReturnType, isAggregator, isGroup, isGroupAuxiliary, isName, isSymmetrical, leftPrec, not, preValidateCall, requiresDecimalExpansion, requiresOrder, requiresOver, reverse, rewriteCall, rightPrec, toString, unparseListClause, unparseListClause, validateOperands, validRexOperands

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

NOW

public static final String NOW

function name for 'NOW()'.

See Also:

Constant Field Values

Constructor Detail

FlinkTimestampWithPrecisionDynamicFunction

public FlinkTimestampWithPrecisionDynamicFunction(String name,
                                                  org.apache.calcite.sql.type.SqlTypeName typeName,
                                                  boolean isBatchMode,
                                                  int precision)

Method Detail

inferReturnType

public org.apache.calcite.rel.type.RelDataType inferReturnType(org.apache.calcite.sql.SqlOperatorBinding opBinding)

Overrides:

inferReturnType in class org.apache.calcite.sql.fun.SqlAbstractTimeFunction

equals

public boolean equals(@Nullable Object obj)

Overrides:

equals in class FlinkTimestampDynamicFunction

hashCode

public int hashCode()

Overrides:

hashCode in class FlinkTimestampDynamicFunction