Package | Description |
---|---|
org.apache.calcite.sql |
This package is needed because the constructor of SqlTypeNameSpec is package scope,
we should merge this package into org.apache.flink.sql.parser.type when CALCITE-3360
is resolved.
|
org.apache.calcite.sql.validate | |
org.apache.calcite.sql2rel | |
org.apache.flink.table.planner.functions.sql | |
org.apache.flink.table.planner.functions.sql.internal | |
org.apache.flink.table.planner.functions.utils |
Modifier and Type | Class and Description |
---|---|
class |
org.apache.calcite.sql.SqlAggFunction |
Modifier and Type | Class and Description |
---|---|
class |
org.apache.calcite.sql.validate.SqlUserDefinedAggFunction |
class |
org.apache.calcite.sql.validate.SqlUserDefinedFunction |
class |
org.apache.calcite.sql.validate.SqlUserDefinedTableFunction |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.type.RelDataType |
SqlValidatorImpl.deriveConstructorType(org.apache.calcite.sql.validate.SqlValidatorScope scope,
org.apache.calcite.sql.SqlCall call,
SqlFunction unresolvedConstructor,
SqlFunction resolvedConstructor,
List<org.apache.calcite.rel.type.RelDataType> argTypes) |
org.apache.calcite.runtime.CalciteException |
SqlValidatorImpl.handleUnresolvedFunction(org.apache.calcite.sql.SqlCall call,
SqlFunction unresolvedFunction,
List<org.apache.calcite.rel.type.RelDataType> argTypes,
List<String> argNames) |
void |
SqlValidatorImpl.validateColumnListParams(SqlFunction function,
List<org.apache.calcite.rel.type.RelDataType> argTypes,
List<org.apache.calcite.sql.SqlNode> operands) |
Constructor and Description |
---|
Impl(SqlFunction f) |
Modifier and Type | Class and Description |
---|---|
class |
CalciteSqlFunction
This is a simple override class for Calcite's
SqlFunction which
provide CalciteSqlFunction.isDeterministic() as a constructor parameter to simplify
construct a new SqlFunction in FlinkSqlOperatorTable . |
class |
ProctimeMaterializeSqlFunction
Function that materializes a processing time attribute.
|
class |
SqlFirstLastValueAggFunction
FIRST_VALUE and LAST_VALUE aggregate functions
return the first or the last value in a list of values that are input to the
function. |
class |
SqlListAggFunction
LISTAGG aggregate function returns the concatenation of
a list of values that are input to the function. |
class |
SqlThrowExceptionFunction
Function used to throw an exception, only used internally.
|
class |
StreamRecordTimestampSqlFunction
Function to access the timestamp of a StreamRecord.
|
Modifier and Type | Field and Description |
---|---|
static SqlFunction |
FlinkSqlOperatorTable.ABS |
static SqlFunction |
FlinkSqlOperatorTable.ACOS |
static SqlFunction |
FlinkSqlOperatorTable.ASCII |
static SqlFunction |
FlinkSqlOperatorTable.ASIN |
static SqlFunction |
FlinkSqlOperatorTable.ATAN |
static SqlFunction |
FlinkSqlOperatorTable.ATAN2 |
static SqlFunction |
FlinkSqlOperatorTable.BIN |
static SqlFunction |
FlinkSqlOperatorTable.CAST |
static SqlFunction |
FlinkSqlOperatorTable.CEIL |
static SqlFunction |
FlinkSqlOperatorTable.CHAR_LENGTH |
static SqlFunction |
FlinkSqlOperatorTable.CHARACTER_LENGTH |
static SqlFunction |
FlinkSqlOperatorTable.CHR |
static SqlFunction |
FlinkSqlOperatorTable.CLASSIFIER |
static SqlFunction |
FlinkSqlOperatorTable.COALESCE |
static SqlFunction |
FlinkSqlOperatorTable.CONCAT_FUNCTION
Function for concat strings, it is same with
FlinkSqlOperatorTable.CONCAT , but this is a function. |
static SqlFunction |
FlinkSqlOperatorTable.CONCAT_WS
Function for concat strings with a separator.
|
static SqlFunction |
FlinkSqlOperatorTable.CONVERT_TZ |
static SqlFunction |
FlinkSqlOperatorTable.COS |
static SqlFunction |
FlinkSqlOperatorTable.COSH |
static SqlFunction |
FlinkSqlOperatorTable.COT |
static SqlFunction |
FlinkSqlOperatorTable.CURRENT_DATE |
static SqlFunction |
FlinkSqlOperatorTable.CURRENT_TIME |
static SqlFunction |
FlinkSqlOperatorTable.CURRENT_TIMESTAMP |
static SqlFunction |
FlinkSqlOperatorTable.DATE_FORMAT |
static SqlFunction |
FlinkSqlOperatorTable.DAYOFMONTH |
static SqlFunction |
FlinkSqlOperatorTable.DAYOFWEEK |
static SqlFunction |
FlinkSqlOperatorTable.DAYOFYEAR |
static SqlFunction |
FlinkSqlOperatorTable.DECODE |
static SqlFunction |
FlinkSqlOperatorTable.DEGREES |
static SqlFunction |
FlinkSqlOperatorTable.E
Function to access the constant value of E.
|
static SqlFunction |
FlinkSqlOperatorTable.ENCODE |
static SqlFunction |
FlinkSqlOperatorTable.EXP |
static SqlFunction |
FlinkSqlOperatorTable.FIRST |
static SqlFunction |
FlinkSqlOperatorTable.FLOOR |
static SqlFunction |
FlinkSqlOperatorTable.FROM_BASE64 |
static SqlFunction |
FlinkSqlOperatorTable.FROM_UNIXTIME |
static SqlFunction |
FlinkSqlOperatorTable.GROUP_ID |
static SqlFunction |
FlinkSqlOperatorTable.GROUPING |
static SqlFunction |
FlinkSqlOperatorTable.GROUPING_ID |
static SqlFunction |
FlinkSqlOperatorTable.HASH_CODE |
static SqlFunction |
FlinkSqlOperatorTable.HEX |
static SqlFunction |
FlinkSqlOperatorTable.HOUR |
static SqlFunction |
FlinkSqlOperatorTable.IF |
static SqlFunction |
FlinkSqlOperatorTable.INITCAP |
static SqlFunction |
FlinkSqlOperatorTable.INSTR |
static SqlFunction |
FlinkSqlOperatorTable.IS_ALPHA |
static SqlFunction |
FlinkSqlOperatorTable.IS_DECIMAL |
static SqlFunction |
FlinkSqlOperatorTable.IS_DIGIT |
static SqlFunction |
FlinkSqlOperatorTable.LAST |
static SqlFunction |
FlinkSqlOperatorTable.LEFT |
static SqlFunction |
FlinkSqlOperatorTable.LN |
static SqlFunction |
FlinkSqlOperatorTable.LOCALTIME |
static SqlFunction |
FlinkSqlOperatorTable.LOCALTIMESTAMP |
static SqlFunction |
FlinkSqlOperatorTable.LOCATE |
static SqlFunction |
FlinkSqlOperatorTable.LOG |
static SqlFunction |
FlinkSqlOperatorTable.LOG10 |
static SqlFunction |
FlinkSqlOperatorTable.LOG2 |
static SqlFunction |
FlinkSqlOperatorTable.LOWER |
static SqlFunction |
FlinkSqlOperatorTable.LPAD |
static SqlFunction |
FlinkSqlOperatorTable.LTRIM |
static SqlFunction |
FlinkSqlOperatorTable.MATCH_PROCTIME
Function used to access a processing time attribute from MATCH_RECOGNIZE.
|
static SqlFunction |
FlinkSqlOperatorTable.MATCH_ROWTIME
Function used to access a event time attribute from MATCH_RECOGNIZE.
|
static SqlFunction |
FlinkSqlOperatorTable.MD5 |
static SqlFunction |
FlinkSqlOperatorTable.MINUTE |
static SqlFunction |
FlinkSqlOperatorTable.MOD |
static SqlFunction |
FlinkSqlOperatorTable.MONTH |
static SqlFunction |
FlinkSqlOperatorTable.NEXT |
static SqlFunction |
FlinkSqlOperatorTable.NOW |
static SqlFunction |
FlinkSqlOperatorTable.NULLIF |
static SqlFunction |
FlinkSqlOperatorTable.OVERLAY |
static SqlFunction |
FlinkSqlOperatorTable.PARSE_URL |
static SqlFunction |
FlinkSqlOperatorTable.PI |
static SqlFunction |
FlinkSqlOperatorTable.PI_FUNCTION
Function to access the constant value of PI.
|
static SqlFunction |
FlinkSqlOperatorTable.POSITION |
static SqlFunction |
FlinkSqlOperatorTable.POWER |
static SqlFunction |
FlinkSqlOperatorTable.PREV |
static SqlFunction |
FlinkSqlOperatorTable.PRINT |
static SqlFunction |
FlinkSqlOperatorTable.PROCTIME
Function used to access a processing time attribute.
|
static SqlFunction |
FlinkSqlOperatorTable.PROCTIME_MATERIALIZE
Function used to materialize a processing time attribute.
|
static SqlFunction |
FlinkSqlOperatorTable.QUARTER |
static SqlFunction |
FlinkSqlOperatorTable.RADIANS |
static SqlFunction |
FlinkSqlOperatorTable.RAND |
static SqlFunction |
FlinkSqlOperatorTable.RAND_INTEGER |
static SqlFunction |
FlinkSqlOperatorTable.REGEXP |
static SqlFunction |
FlinkSqlOperatorTable.REGEXP_EXTRACT |
static SqlFunction |
FlinkSqlOperatorTable.REGEXP_REPLACE |
static SqlFunction |
FlinkSqlOperatorTable.REPEAT |
static SqlFunction |
FlinkSqlOperatorTable.REPLACE |
static SqlFunction |
FlinkSqlOperatorTable.REVERSE |
static SqlFunction |
FlinkSqlOperatorTable.RIGHT |
static SqlFunction |
FlinkSqlOperatorTable.ROUND |
static SqlFunction |
FlinkSqlOperatorTable.RPAD |
static SqlFunction |
FlinkSqlOperatorTable.RTRIM |
static SqlFunction |
FlinkSqlOperatorTable.SECOND |
static SqlFunction |
FlinkSqlOperatorTable.SHA1 |
static SqlFunction |
FlinkSqlOperatorTable.SHA2 |
static SqlFunction |
FlinkSqlOperatorTable.SHA224 |
static SqlFunction |
FlinkSqlOperatorTable.SHA256 |
static SqlFunction |
FlinkSqlOperatorTable.SHA384 |
static SqlFunction |
FlinkSqlOperatorTable.SHA512 |
static SqlFunction |
FlinkSqlOperatorTable.SIGN |
static SqlFunction |
FlinkSqlOperatorTable.SIN |
static SqlFunction |
FlinkSqlOperatorTable.SINH |
static SqlFunction |
FlinkSqlOperatorTable.SPLIT_INDEX |
static SqlFunction |
FlinkSqlOperatorTable.SQRT |
static SqlFunction |
FlinkSqlOperatorTable.STR_TO_MAP |
static SqlFunction |
FlinkSqlOperatorTable.STREAMRECORD_TIMESTAMP
Function to access the timestamp of a StreamRecord.
|
static SqlFunction |
FlinkSqlOperatorTable.SUBSTR |
static SqlFunction |
FlinkSqlOperatorTable.SUBSTRING |
static SqlFunction |
FlinkSqlOperatorTable.TAN |
static SqlFunction |
FlinkSqlOperatorTable.TANH |
static SqlFunction |
FlinkSqlOperatorTable.TIMESTAMP_ADD |
static SqlFunction |
FlinkSqlOperatorTable.TIMESTAMP_DIFF |
static SqlFunction |
FlinkSqlOperatorTable.TO_BASE64 |
static SqlFunction |
FlinkSqlOperatorTable.TO_DATE |
static SqlFunction |
FlinkSqlOperatorTable.TO_TIMESTAMP |
static SqlFunction |
FlinkSqlOperatorTable.TRIM |
static SqlFunction |
FlinkSqlOperatorTable.TRUNCATE |
static SqlFunction |
FlinkSqlOperatorTable.UNIX_TIMESTAMP |
static SqlFunction |
FlinkSqlOperatorTable.UPPER |
static SqlFunction |
FlinkSqlOperatorTable.UUID |
static SqlFunction |
FlinkSqlOperatorTable.WEEK |
static SqlFunction |
FlinkSqlOperatorTable.YEAR |
Modifier and Type | Class and Description |
---|---|
class |
SqlAuxiliaryGroupAggFunction
An internal [[SqlAggFunction]] to represents auxiliary group keys
which will not be computed as key and does not also affect the correctness of the final result.
|
Modifier and Type | Class and Description |
---|---|
class |
org.apache.flink.table.planner.functions.utils.AggSqlFunction |
class |
HiveAggSqlFunction
Deprecated.
TODO hack code, its logical should be integrated to AggSqlFunction
|
class |
HiveScalarSqlFunction
Deprecated.
TODO hack code, its logical should be integrated to ScalarSqlFunction
|
class |
HiveTableSqlFunction
Deprecated.
TODO hack code, its logical should be integrated to TableSqlFunction
|
class |
org.apache.flink.table.planner.functions.utils.ScalarSqlFunction |
class |
org.apache.flink.table.planner.functions.utils.TableSqlFunction |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.