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

Class FlinkCurrentRowTimestampFunction

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.FlinkCurrentRowTimestampFunction

@Internal
public class FlinkCurrentRowTimestampFunction
extends org.apache.calcite.sql.fun.SqlAbstractTimeFunction

The function CURRENT_ROW_TIMESTAMP() in Flink which supports configuring the return type and the precision of return type.

Field Summary

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

kind, MDX_PRECEDENCE, NL

Constructor Summary

Constructors

Constructor and Description
FlinkCurrentRowTimestampFunction(String functionName, org.apache.calcite.sql.type.SqlTypeName returnTypeName, 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)
boolean	isDeterministic()
boolean	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

Constructor Detail

FlinkCurrentRowTimestampFunction

public FlinkCurrentRowTimestampFunction(String functionName,
                                        org.apache.calcite.sql.type.SqlTypeName returnTypeName,
                                        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

isDynamicFunction

public boolean isDynamicFunction()

Overrides:

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

isDeterministic

public boolean isDeterministic()

Overrides:

isDeterministic in class org.apache.calcite.sql.SqlOperator

equals

public boolean equals(@Nullable Object obj)

Overrides:

equals in class org.apache.calcite.sql.SqlOperator

hashCode

public int hashCode()

Overrides:

hashCode in class org.apache.calcite.sql.SqlOperator