| Package | Description |
|---|---|
| org.apache.flink.sql.parser.dql | |
| org.apache.flink.sql.parser.impl | |
| org.apache.flink.sql.parser.utils |
| Constructor and Description |
|---|
SqlShowDatabases(org.apache.calcite.sql.parser.SqlParserPos pos,
String preposition,
org.apache.calcite.sql.SqlIdentifier catalogName,
String likeType,
org.apache.calcite.sql.SqlCharStringLiteral likeLiteral,
boolean notLike) |
| Modifier and Type | Method and Description |
|---|---|
ParseException |
FlinkSqlParserImpl.generateParseException() |
| Modifier and Type | Method and Description |
|---|---|
void |
FlinkSqlParserImpl.AddArg(List<org.apache.calcite.sql.SqlNode> list,
org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext) |
void |
FlinkSqlParserImpl.AddArg0(List<org.apache.calcite.sql.SqlNode> list,
org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext) |
void |
FlinkSqlParserImpl.AddColumnType(List<org.apache.calcite.sql.SqlNode> list) |
void |
FlinkSqlParserImpl.AddCompoundIdentifierType(List<org.apache.calcite.sql.SqlNode> list,
List<org.apache.calcite.sql.SqlNode> extendList)
Parses a compound identifier with optional type.
|
void |
FlinkSqlParserImpl.AddCompoundIdentifierTypes(List<org.apache.calcite.sql.SqlNode> list,
List<org.apache.calcite.sql.SqlNode> extendList)
Parses a comma-separated list of compound identifiers.
|
void |
FlinkSqlParserImpl.AddExpression(List<org.apache.calcite.sql.SqlNode> list,
org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
As
FlinkSqlParserImpl.Expression(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext) but appends to a list. |
void |
FlinkSqlParserImpl.AddExpression2b(List<Object> list,
org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext) |
void |
FlinkSqlParserImpl.AddExpressions(List<org.apache.calcite.sql.SqlNode> list,
org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a list of expressions separated by commas,
appending expressions to a given list.
|
void |
FlinkSqlParserImpl.AddFieldNameType(List<org.apache.calcite.sql.SqlIdentifier> fieldNames,
List<org.apache.calcite.sql.SqlDataTypeSpec> fieldTypes) |
void |
FlinkSqlParserImpl.AddFieldNameTypes(List<org.apache.calcite.sql.SqlIdentifier> fieldNames,
List<org.apache.calcite.sql.SqlDataTypeSpec> fieldTypes)
Parse a "name1 type1 [NULL | NOT NULL], name2 type2 [NULL | NOT NULL] ..." list,
the field type default is not nullable.
|
void |
FlinkSqlParserImpl.AddGroupingElement(List<org.apache.calcite.sql.SqlNode> list) |
void |
FlinkSqlParserImpl.AddHint(List<org.apache.calcite.sql.SqlNode> hints) |
void |
FlinkSqlParserImpl.AddIdentifierSegment(List<String> names,
List<org.apache.calcite.sql.parser.SqlParserPos> positions)
Parses one segment of an identifier that may be composite.
|
void |
FlinkSqlParserImpl.AddKeyValueOption(List<org.apache.calcite.sql.SqlNode> list)
Parses an option with format key=val whose key is a simple identifier or string literal
and value is a string literal.
|
void |
FlinkSqlParserImpl.AddMeasureColumn(List<org.apache.calcite.sql.SqlNode> list) |
void |
FlinkSqlParserImpl.AddOptionValue(List<org.apache.calcite.sql.SqlNode> list)
Parses an option value (either a string or a numeric) and adds to a list.
|
void |
FlinkSqlParserImpl.AddOrderItem(List<org.apache.calcite.sql.SqlNode> list)
Parses one item in an ORDER BY clause, and adds it to a list.
|
void |
FlinkSqlParserImpl.AddOrModifyColumn(SqlAlterTable.AlterTableContext context)
Parses
ADD/MODIFY column_name column_data_type [...]. |
void |
FlinkSqlParserImpl.AddPivotAgg(List<org.apache.calcite.sql.SqlNode> list) |
void |
FlinkSqlParserImpl.AddPivotValue(List<org.apache.calcite.sql.SqlNode> list) |
void |
FlinkSqlParserImpl.AddRowConstructor(List<org.apache.calcite.sql.SqlNode> list)
Parses a row constructor and adds it to a list.
|
void |
FlinkSqlParserImpl.AddSelectItem(List<org.apache.calcite.sql.SqlNode> list)
Parses one item in a select list.
|
void |
FlinkSqlParserImpl.AddSetOpQuery(List<Object> list,
org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a set operator (e.g.
|
void |
FlinkSqlParserImpl.AddSetOpQueryOrExpr(List<Object> list,
org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a set operator (e.g.
|
void |
FlinkSqlParserImpl.AddSimpleIdentifiers(List<org.apache.calcite.sql.SqlNode> list)
Parses a comma-separated list of simple identifiers.
|
void |
FlinkSqlParserImpl.AddSubsetDefinition(List<org.apache.calcite.sql.SqlNode> list) |
void |
FlinkSqlParserImpl.AddTableIdentifierSegment(List<String> names,
List<org.apache.calcite.sql.parser.SqlParserPos> positions)
As
FlinkSqlParserImpl.AddIdentifierSegment(java.util.List<java.lang.String>, java.util.List<org.apache.calcite.sql.parser.SqlParserPos>) but part of a table name (for example,
following FROM, INSERT or UPDATE). |
void |
FlinkSqlParserImpl.AddUnpivotValue(List<org.apache.calcite.sql.SqlNode> list) |
void |
FlinkSqlParserImpl.AddWindowSpec(List<org.apache.calcite.sql.SqlNode> list) |
void |
FlinkSqlParserImpl.AddWithItem(List<org.apache.calcite.sql.SqlWithItem> list) |
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.AllOrDistinct() |
void |
FlinkSqlParserImpl.AlterTableAddOrModify(SqlAlterTable.AlterTableContext context)
Parses
ALTER TABLE table_name ADD/MODIFY [...]. |
void |
FlinkSqlParserImpl.AlterTableAddPartition(SqlAddPartitions.AlterTableAddPartitionContext context)
Parses
ALTER TABLE table_name ADD [IF NOT EXISTS] PARTITION partition_spec [PARTITION partition_spec][...]. |
void |
FlinkSqlParserImpl.AlterTableDropPartitions(SqlDropPartitions.AlterTableDropPartitionsContext context)
Parses
ALTER TABLE table_name DROP [IF EXISTS] PARTITION partition_spec[, PARTITION partition_spec, ...]. |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.ArrayConstructor()
Parses an ARRAY constructor
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.AtomicRowExpression()
Parses an atomic row expression.
|
org.apache.calcite.sql.SqlBinaryOperator |
FlinkSqlParserImpl.BinaryMultisetOperator()
Parses a binary multiset operator.
|
org.apache.calcite.sql.SqlBinaryOperator |
FlinkSqlParserImpl.BinaryQueryOperator()
Parses a binary query operator like UNION.
|
org.apache.calcite.sql.SqlBinaryOperator |
FlinkSqlParserImpl.BinaryRowOperator()
Parses a binary row operator like AND.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.BuiltinFunctionCall()
Parses a call to a builtin function with special syntax.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.CaseExpression() |
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.CharacterTypeName(org.apache.calcite.sql.parser.Span s)
Parse character types: char, varchar.
|
org.apache.calcite.sql.SqlCollation |
FlinkSqlParserImpl.CollateClause()
Parses a COLLATE clause
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.CollectionsTypeName(org.apache.calcite.sql.SqlTypeNameSpec elementTypeName)
Parse a collection type name, the input element type name may
also be a collection type.
|
SqlTableConstraint |
FlinkSqlParserImpl.ColumnConstraint(org.apache.calcite.sql.SqlIdentifier column)
Parses a column constraint for CREATE TABLE.
|
org.apache.calcite.sql.SqlKind |
FlinkSqlParserImpl.comp()
Parses a comparison operator inside a SOME / ALL predicate.
|
org.apache.calcite.sql.SqlIdentifier |
FlinkSqlParserImpl.CompoundIdentifier()
Parses a compound identifier.
|
org.apache.calcite.sql.SqlIdentifier |
FlinkSqlParserImpl.CompoundTableIdentifier()
Parses a compound identifier in the FROM clause.
|
SqlTableColumn |
FlinkSqlParserImpl.ComputedColumn(SqlCreateTable.TableCreationContext context)
Parses
column_name AS expr [COMMENT 'comment']. |
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.ConstraintEnforcement() |
org.apache.calcite.sql.SqlIdentifier |
FlinkSqlParserImpl.ConstraintName() |
org.apache.calcite.sql.SqlIdentifier |
FlinkSqlParserImpl.ContextVariable() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.CreateSetSemanticsTableIfNeeded(org.apache.calcite.sql.parser.Span s,
org.apache.calcite.sql.SqlNode e,
org.apache.calcite.sql.SqlNodeList partitionList,
org.apache.calcite.sql.SqlNodeList orderList) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.CursorExpression(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a CURSOR(query) expression.
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.CustomizedCollectionsTypeName() |
org.apache.calcite.sql.SqlDataTypeSpec |
FlinkSqlParserImpl.DataType() |
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.DateTimeLiteral()
Parses a date/time literal.
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.DateTimeTypeName()
Parse datetime types: date, time, timestamp.
|
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.Day() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Default() |
org.apache.calcite.sql.SqlDynamicParam |
FlinkSqlParserImpl.DynamicParam()
Parses a dynamic parameter marker.
|
org.apache.calcite.sql.SqlExplain.Depth |
FlinkSqlParserImpl.ExplainDepth()
Parses WITH TYPE | WITH IMPLEMENTATION | WITHOUT IMPLEMENTATION modifier for
EXPLAIN PLAN.
|
org.apache.calcite.sql.SqlExplainLevel |
FlinkSqlParserImpl.ExplainDetailLevel()
Parses INCLUDING ALL ATTRIBUTES modifier for EXPLAIN PLAN.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.ExplicitTable(org.apache.calcite.sql.parser.SqlParserPos pos)
Parses an explicit TABLE t reference.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Expression(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a row expression or a parenthesized expression of any kind.
|
List<Object> |
FlinkSqlParserImpl.Expression2(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a binary row expression, or a parenthesized expression of any
kind.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Expression3(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a unary row expression, or a parenthesized expression of any
kind.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.ExpressionCommaList(org.apache.calcite.sql.parser.Span s,
org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a list of expressions separated by commas.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.ExprOrJoinOrOrderedQuery(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Syntactical Descriptions *
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.ExtendedCollectionsTypeName(org.apache.calcite.sql.SqlTypeNameSpec elementTypeName,
boolean elementNullable)
Parse a collection type name, the input element type name may
also be a collection type.
|
org.apache.calcite.sql.SqlDataTypeSpec |
FlinkSqlParserImpl.ExtendedDataType()
Different with
FlinkSqlParserImpl.DataType(), we support a [ NULL | NOT NULL ] suffix syntax for both the
collection element data type and the data type itself. |
void |
FlinkSqlParserImpl.ExtendedFieldNameTypeCommaList(List<org.apache.calcite.sql.SqlIdentifier> fieldNames,
List<org.apache.calcite.sql.SqlDataTypeSpec> fieldTypes,
List<org.apache.calcite.sql.SqlCharStringLiteral> comments)
Parse a "name1 type1 [ NULL | NOT NULL] [ comment ]
[, name2 type2 [ NULL | NOT NULL] [ comment ] ]* ..." list.
|
void |
FlinkSqlParserImpl.ExtendedPartitionSpecCommaList(org.apache.calcite.sql.SqlNodeList list)
Parses a partition specifications statement,
e.g.
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.ExtendedSqlBasicTypeName()
A sql type name extended basic data type, it has a counterpart basic
sql type name but always represents as a special alias compared with the standard name.
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.ExtendedSqlRowTypeName()
Parse Row type, we support both Row(name1 type1, name2 type2)
and Row<name1 type1, name2 type2>.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.ExtendedTableRef()
Allows parser to be extended with new types of table references.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.ExtendList() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.ExtendTable(org.apache.calcite.sql.SqlNode tableRef)
Wraps a table reference in a call to EXTEND if an optional "EXTEND" clause
is present.
|
void |
FlinkSqlParserImpl.FetchClause(org.apache.calcite.sql.SqlNode[] offsetFetch)
Parses a FETCH clause in an ORDER BY expression.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.FloorCeilOptions(org.apache.calcite.sql.parser.Span s,
boolean floorFlag) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.FromClause()
Parses the FROM clause for a SELECT.
|
org.apache.calcite.sql.SqlIdentifier |
FlinkSqlParserImpl.FunctionName()
Parses the name of a function (either a compound identifier or
a reserved word which can be used as a function name).
|
List<org.apache.calcite.sql.SqlNode> |
FlinkSqlParserImpl.FunctionParameterList(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses function parameter lists including DISTINCT keyword recognition,
DEFAULT, and named argument assignment.
|
protected org.apache.calcite.sql.parser.SqlParserPos |
FlinkSqlParserImpl.getPos() |
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.GroupBy()
Parses a GROUP BY clause for SELECT.
|
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.GroupByWindowingCall()
Parses a call to a grouping function inside the GROUP BY clause,
for example
TUMBLE(rowtime, INTERVAL '1' MINUTE). |
List<org.apache.calcite.sql.SqlNode> |
FlinkSqlParserImpl.GroupingElementList() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Having()
Parses a HAVING clause for SELECT.
|
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.Hour() |
String |
FlinkSqlParserImpl.Identifier()
Parses a simple identifier as a String.
|
boolean |
FlinkSqlParserImpl.IfExistsOpt()
Parses a "IF EXISTS" option, default is false.
|
boolean |
FlinkSqlParserImpl.IfNotExistsOpt()
Parses a "IF NOT EXISTS" option, default is false.
|
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.IntervalLiteral()
Parses an interval literal.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.IntervalLiteralOrExpression()
Parses an interval literal (e.g.
|
org.apache.calcite.sql.SqlIntervalQualifier |
FlinkSqlParserImpl.IntervalQualifier() |
org.apache.calcite.sql.SqlIntervalQualifier |
FlinkSqlParserImpl.IntervalQualifierStart()
Interval qualifier without 'TO unit'.
|
int |
FlinkSqlParserImpl.IntLiteral() |
org.apache.calcite.sql.SqlNumericLiteral |
FlinkSqlParserImpl.IntoBuckets(org.apache.calcite.sql.parser.SqlParserPos startPos) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.JdbcFunctionCall()
Parses a function call expression with JDBC syntax.
|
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.JdbcOdbcDataType() |
org.apache.calcite.sql.SqlJdbcDataTypeName |
FlinkSqlParserImpl.JdbcOdbcDataTypeName() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Join() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.JoinTable(org.apache.calcite.sql.SqlNode e)
Matches "LEFT JOIN t ON
|
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.JoinType() |
List<org.apache.calcite.sql.SqlNode> |
FlinkSqlParserImpl.JsonApiCommonSyntax() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.JsonArrayAggFunctionCall() |
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.JsonArrayAggOrderByClause() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.JsonArrayFunctionCall() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.JsonConstructorNullClause() |
org.apache.calcite.sql.SqlJsonExistsErrorBehavior |
FlinkSqlParserImpl.JsonExistsErrorBehavior() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.JsonExistsFunctionCall() |
void |
FlinkSqlParserImpl.JsonInputClause() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.JsonName() |
List<org.apache.calcite.sql.SqlNode> |
FlinkSqlParserImpl.JsonNameAndValue() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.JsonObjectAggFunctionCall() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.JsonObjectFunctionCall() |
org.apache.calcite.sql.SqlDataTypeSpec |
FlinkSqlParserImpl.JsonOutputClause() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.JsonPathSpec() |
List<org.apache.calcite.sql.SqlNode> |
FlinkSqlParserImpl.JsonQueryEmptyOrErrorBehavior() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.JsonQueryFunctionCall() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.JsonQueryWrapperBehavior() |
org.apache.calcite.sql.SqlJsonEncoding |
FlinkSqlParserImpl.JsonRepresentation() |
org.apache.calcite.sql.SqlDataTypeSpec |
FlinkSqlParserImpl.JsonReturningClause() |
List<org.apache.calcite.sql.SqlNode> |
FlinkSqlParserImpl.JsonValueEmptyOrErrorBehavior() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.JsonValueFunctionCall() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.LeafQuery(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a leaf in a query expression (SELECT, VALUES or TABLE).
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.LeafQueryOrExpr(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses either a row expression, a leaf query expression, or
a parenthesized expression of any kind.
|
void |
FlinkSqlParserImpl.LimitClause(org.apache.calcite.sql.parser.Span s,
org.apache.calcite.sql.SqlNode[] offsetFetch)
Parses a LIMIT clause in an ORDER BY expression.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Literal()
Parses a literal expression, allowing continued string literals.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.LiteralOrIntervalExpression()
Parses a literal or an interval expression.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.MapConstructor()
Parses a MAP constructor
|
org.apache.calcite.sql.SqlMatchRecognize |
FlinkSqlParserImpl.MatchRecognize(org.apache.calcite.sql.SqlNode tableRef)
Parses a MATCH_RECOGNIZE clause following a table expression.
|
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.MatchRecognizeCallWithModifier() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.MatchRecognizeFunctionCall() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.MatchRecognizeNavigationLogical() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.MatchRecognizeNavigationPhysical() |
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.MeasureColumnCommaList(org.apache.calcite.sql.parser.Span s) |
SqlTableColumn |
FlinkSqlParserImpl.MetadataColumn(SqlCreateTable.TableCreationContext context,
org.apache.calcite.sql.SqlIdentifier name,
org.apache.calcite.sql.SqlDataTypeSpec type)
Parses
column_name column_data_type METADATA [FROM 'alias_name'] [VIRTUAL] [COMMENT 'comment']. |
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.Minute() |
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.Month() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.MultisetConstructor()
Parses a MULTISET constructor
|
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.NamedCall() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.NamedFunctionCall()
Parses a call to a named function (could be a builtin with regular
syntax, or else a UDF).
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.NamedRoutineCall(org.apache.calcite.sql.SqlFunctionCategory routineType,
org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext) |
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.Natural() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.NewSpecification()
Parses a NEW UDT(...) expression.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.NonIntervalLiteral()
Parses a literal that is not an interval literal.
|
String |
FlinkSqlParserImpl.NonReservedJdbcFunctionName()
Parses the name of a JDBC function that is a token but is not reserved.
|
String |
FlinkSqlParserImpl.NonReservedKeyWord()
Parses a non-reserved keyword for use as an identifier.
|
void |
FlinkSqlParserImpl.NonReservedKeyWord0of3() |
void |
FlinkSqlParserImpl.NonReservedKeyWord1of3() |
void |
FlinkSqlParserImpl.NonReservedKeyWord2of3() |
boolean |
FlinkSqlParserImpl.NotNullOpt()
Parses NOT NULL and returns false, or parses nothing and returns true.
|
boolean |
FlinkSqlParserImpl.NullableOptDefaultFalse()
Parse a nullable option, default is false.
|
boolean |
FlinkSqlParserImpl.NullableOptDefaultTrue()
Parse a nullable option, default is true.
|
org.apache.calcite.util.Pair<org.apache.calcite.sql.parser.SqlParserPos,org.apache.calcite.sql.SqlOperator> |
FlinkSqlParserImpl.NullTreatment() |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.nullTreatment(org.apache.calcite.sql.SqlCall arg) |
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.NumericLiteral()
Parses a numeric literal (can be signed)
|
void |
FlinkSqlParserImpl.OffsetClause(org.apache.calcite.sql.parser.Span s,
org.apache.calcite.sql.SqlNode[] offsetFetch)
Parses an OFFSET clause in an ORDER BY expression.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.OrderBy(boolean accept)
Parses an ORDER BY clause.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.OrderByLimitOpt(org.apache.calcite.sql.SqlNode e)
Reads optional "ORDER BY", "LIMIT", "OFFSET", "FETCH" following a query,
e. |
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.OrderByOfSetSemanticsTable() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.OrderedQueryOrExpr(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses either a row expression or a query expression with an optional
ORDER BY.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Over(org.apache.calcite.sql.SqlNode tableRef)
Wraps a table reference in a call to OVER if an optional "OVER" clause
is present (if the dialect supports OVER for table expressions).
|
org.apache.calcite.util.Pair<org.apache.calcite.sql.SqlNodeList,org.apache.calcite.sql.SqlNodeList> |
FlinkSqlParserImpl.ParenthesizedCompoundIdentifierList()
List of compound identifiers in parentheses.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.ParenthesizedExpression(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a parenthesized query or single row expression.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.ParenthesizedKeyValueOptionCommaList() |
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.ParenthesizedLiteralOptionCommaList()
Parses a literal list separated by comma.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.ParenthesizedQueryOrCommaList(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses a parenthesized query or comma-list of row expressions.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.ParenthesizedQueryOrCommaListWithDefault(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
As ParenthesizedQueryOrCommaList, but allows DEFAULT
in place of any of the expressions.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.ParenthesizedSimpleIdentifierList()
List of simple identifiers in parentheses.
|
void |
FlinkSqlParserImpl.ParseExplainDetail(Set<String> explainDetails) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.PartitionedByAndOrderBy(org.apache.calcite.sql.SqlNode e) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.PartitionedQueryOrQueryOrExpr(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext) |
void |
FlinkSqlParserImpl.PartitionSpecCommaList(org.apache.calcite.sql.SqlNodeList list)
Parses a partition specifications statement,
e.g. insert into tbl1 partition(col1='val1', col2='val2') select col3 from tbl.
|
SqlPartitionSpecProperty |
FlinkSqlParserImpl.PartitionSpecProperty()
Parses a partition key/value,
e.g. p or p = '10'.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.PatternDefinition() |
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.PatternDefinitionCommaList(org.apache.calcite.sql.parser.Span s) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.PatternExpression() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.PatternFactor() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.PatternPrimary() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.PatternTerm() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.PeriodConstructor()
Parses a PERIOD constructor
|
org.apache.calcite.sql.SqlOperator |
FlinkSqlParserImpl.periodOperator() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Pivot(org.apache.calcite.sql.SqlNode tableRef)
Parses a PIVOT clause following a table expression.
|
org.apache.calcite.sql.SqlPostfixOperator |
FlinkSqlParserImpl.PostfixRowOperator()
Parses a postfix row operator like IS NOT NULL.
|
int |
FlinkSqlParserImpl.PrecisionOpt() |
org.apache.calcite.sql.SqlPrefixOperator |
FlinkSqlParserImpl.PrefixRowOperator()
Parses a prefix row operator like NOT.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.Properties()
Parse properties such as ('k' = 'v').
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.PropertyKeys()
Parse a table option key list.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Query(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.QueryOrExpr(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses either a row expression or a query expression without ORDER BY.
|
SqlTableColumn |
FlinkSqlParserImpl.RegularColumn(SqlCreateTable.TableCreationContext context,
org.apache.calcite.sql.SqlIdentifier name,
org.apache.calcite.sql.SqlDataTypeSpec type)
Parses
column_name column_data_type [constraint] [COMMENT 'comment']. |
org.apache.calcite.sql.SqlIdentifier |
FlinkSqlParserImpl.ReservedFunctionName()
Parses a reserved word which is used as the name of a function.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.RichSqlInsert()
Parses an INSERT statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.RowConstructor()
Parses a row constructor in the context of a VALUES expression.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.RowExpressionExtension()
Parses a row expression extension, it can be either an identifier,
or a call to a named function.
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.RowTypeName()
Parse Row type with format: Row(name1 type1, name2 type2).
|
String |
FlinkSqlParserImpl.Scope() |
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.Second() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SelectExpression()
Parses one unaliased expression in a select list.
|
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.SequenceExpression() |
org.apache.calcite.sql.SqlIdentifier |
FlinkSqlParserImpl.SimpleIdentifier()
Parses a simple identifier as an SqlIdentifier.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.SimpleIdentifierCommaListWithPosition()
Parses a comma-separated list of simple identifiers with position.
|
org.apache.calcite.sql.SqlIdentifier |
FlinkSqlParserImpl.SimpleIdentifierFromStringLiteral()
Parses a character literal as an SqlIdentifier.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.SimpleIdentifierOrList()
List of simple identifiers in parentheses or one simple identifier.
|
String |
FlinkSqlParserImpl.SimpleStringLiteral()
Parses a character literal.
|
org.apache.calcite.sql.SqlSnapshot |
FlinkSqlParserImpl.Snapshot(org.apache.calcite.sql.SqlNode tableRef)
Parses a FOR SYSTEM_TIME clause following a table expression.
|
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.SpecialLiteral()
Parse a special literal keyword
|
SqlAddJar |
FlinkSqlParserImpl.SqlAddJar()
Parses an ADD JAR statement.
|
org.apache.calcite.sql.SqlAlter |
FlinkSqlParserImpl.SqlAlter()
Parses an expression for setting or resetting an option in SQL, such as QUOTED_IDENTIFIERS,
or explain plan level (physical/logical).
|
SqlAlterCatalog |
FlinkSqlParserImpl.SqlAlterCatalog()
Parses an alter catalog statement.
|
SqlAlterDatabase |
FlinkSqlParserImpl.SqlAlterDatabase() |
SqlAlterFunction |
FlinkSqlParserImpl.SqlAlterFunction() |
SqlAlterMaterializedTable |
FlinkSqlParserImpl.SqlAlterMaterializedTable()
Parses alter materialized table.
|
SqlAlterModel |
FlinkSqlParserImpl.SqlAlterModel()
ALTER MODEL [IF EXISTS] modelName SET (property_key = property_val, ...)
|
SqlAlterTable |
FlinkSqlParserImpl.SqlAlterTable() |
SqlAlterView |
FlinkSqlParserImpl.SqlAlterView() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlAnalyzeTable()
Parses an ANALYZE TABLE statement.
|
SqlBeginStatementSet |
FlinkSqlParserImpl.SqlBeginStatementSet()
Parse a start statement set statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlCompileAndExecutePlan()
Parses a compile plan statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlCompilePlan()
Parses a compile plan statement.
|
org.apache.calcite.sql.SqlCreate |
FlinkSqlParserImpl.SqlCreate()
Parses a CREATE statement.
|
org.apache.calcite.sql.SqlCreate |
FlinkSqlParserImpl.SqlCreateCatalog(org.apache.calcite.sql.parser.Span s,
boolean replace)
Parses a create catalog statement.
|
org.apache.calcite.sql.SqlCreate |
FlinkSqlParserImpl.SqlCreateDatabase(org.apache.calcite.sql.parser.Span s,
boolean replace)
Parses a create database statement.
|
org.apache.calcite.sql.SqlCreate |
FlinkSqlParserImpl.SqlCreateExtended(org.apache.calcite.sql.parser.Span s,
boolean replace) |
org.apache.calcite.sql.SqlCreate |
FlinkSqlParserImpl.SqlCreateFunction(org.apache.calcite.sql.parser.Span s,
boolean replace,
boolean isTemporary) |
org.apache.calcite.sql.SqlCreate |
FlinkSqlParserImpl.SqlCreateMaterializedTable(org.apache.calcite.sql.parser.Span s,
boolean replace,
boolean isTemporary)
Parses a CREATE MATERIALIZED TABLE statement.
|
org.apache.calcite.sql.SqlCreate |
FlinkSqlParserImpl.SqlCreateModel(org.apache.calcite.sql.parser.Span s,
boolean isTemporary)
CREATE MODEL [IF NOT EXIST] modelName
[INPUT(col1 type1, col2 type2, ...)]
|
org.apache.calcite.sql.SqlCreate |
FlinkSqlParserImpl.SqlCreateTable(org.apache.calcite.sql.parser.Span s,
boolean replace,
boolean isTemporary) |
org.apache.calcite.sql.SqlCreate |
FlinkSqlParserImpl.SqlCreateView(org.apache.calcite.sql.parser.Span s,
boolean replace,
boolean isTemporary)
Parses a create view or temporary view statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlDelete()
Parses a DELETE statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlDescribe()
Parses a DESCRIBE statement.
|
SqlDescribeCatalog |
FlinkSqlParserImpl.SqlDescribeCatalog()
Parse a "DESCRIBE CATALOG" metadata query command
|
SqlDescribeDatabase |
FlinkSqlParserImpl.SqlDescribeDatabase() |
SqlDescribeJob |
FlinkSqlParserImpl.SqlDescribeJob()
Parse a "DESCRIBE JOB" statement:
DESCRIBE | DESC JOB
|
SqlDistribution |
FlinkSqlParserImpl.SqlDistribution(org.apache.calcite.sql.parser.SqlParserPos startPos) |
org.apache.calcite.sql.SqlDrop |
FlinkSqlParserImpl.SqlDrop()
Parses a DROP statement.
|
org.apache.calcite.sql.SqlDrop |
FlinkSqlParserImpl.SqlDropCatalog(org.apache.calcite.sql.parser.Span s,
boolean replace) |
org.apache.calcite.sql.SqlDrop |
FlinkSqlParserImpl.SqlDropDatabase(org.apache.calcite.sql.parser.Span s,
boolean replace) |
org.apache.calcite.sql.SqlDrop |
FlinkSqlParserImpl.SqlDropExtended(org.apache.calcite.sql.parser.Span s,
boolean replace) |
org.apache.calcite.sql.SqlDrop |
FlinkSqlParserImpl.SqlDropFunction(org.apache.calcite.sql.parser.Span s,
boolean replace,
boolean isTemporary) |
org.apache.calcite.sql.SqlDrop |
FlinkSqlParserImpl.SqlDropMaterializedTable(org.apache.calcite.sql.parser.Span s,
boolean replace,
boolean isTemporary)
Parses a DROP MATERIALIZED TABLE statement.
|
org.apache.calcite.sql.SqlDrop |
FlinkSqlParserImpl.SqlDropModel(org.apache.calcite.sql.parser.Span s,
boolean isTemporary)
DROP MODEL [IF EXIST] modelName
|
org.apache.calcite.sql.SqlDrop |
FlinkSqlParserImpl.SqlDropTable(org.apache.calcite.sql.parser.Span s,
boolean replace,
boolean isTemporary) |
org.apache.calcite.sql.SqlDrop |
FlinkSqlParserImpl.SqlDropView(org.apache.calcite.sql.parser.Span s,
boolean replace,
boolean isTemporary) |
SqlEndStatementSet |
FlinkSqlParserImpl.SqlEndStatementSet()
Parse a end statement set statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlExecute()
Parses an execute statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlExecutePlan()
Parses an execute plan statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlExplain()
Parses an EXPLAIN PLAN statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlExpressionEof()
Parses a SQL expression (such as might occur in a WHERE clause) followed by
the end-of-file symbol.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlInsert()
Parses an INSERT statement.
|
void |
FlinkSqlParserImpl.SqlInsertKeywords(List<org.apache.calcite.sql.SqlLiteral> keywords) |
SqlLoadModule |
FlinkSqlParserImpl.SqlLoadModule()
Parses a load module statement.
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.SqlMapTypeName()
Parses a SQL map type, e.g.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlMerge()
Parses a MERGE statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlProcedureCall()
Parses a CALL statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlQueryEof()
Parses a query (SELECT, UNION, INTERSECT, EXCEPT, VALUES, TABLE) followed by
the end-of-file symbol.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlQueryOrDml()
Parses a query (SELECT or VALUES)
or DML statement (INSERT, UPDATE, DELETE, MERGE).
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.SqlRawTypeName()
Parses a SQL raw type such as
RAW('org.my.Class', 'sW3Djsds...'). |
SqlRemoveJar |
FlinkSqlParserImpl.SqlRemoveJar()
Parses a remove jar statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlReplaceTable()
Parser a REPLACE TABLE AS statement
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlReset()
Parses a RESET statement:
RESET ['key'];
|
SqlResource |
FlinkSqlParserImpl.SqlResourceInfo()
Parse resource type and path.
|
SqlRichDescribeModel |
FlinkSqlParserImpl.SqlRichDescribeModel()
DESCRIBE | DESC MODEL [ EXTENDED] [[catalogName.] dataBasesName].modelName sql call.
|
SqlRichDescribeTable |
FlinkSqlParserImpl.SqlRichDescribeTable()
DESCRIBE | DESC [ EXTENDED] [[catalogName.] dataBasesName].tableName sql call.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlRichExplain()
Parses an explain module statement.
|
org.apache.calcite.sql.SqlSelect |
FlinkSqlParserImpl.SqlSelect()
Parses a leaf SELECT expression without ORDER BY.
|
void |
FlinkSqlParserImpl.SqlSelectKeywords(List<org.apache.calcite.sql.SqlLiteral> keywords) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlSet() |
org.apache.calcite.sql.SqlSetOption |
FlinkSqlParserImpl.SqlSetOption(org.apache.calcite.sql.parser.Span s,
String scope)
Parses "SET <NAME> = VALUE" or "RESET <NAME>", without a leading
"ALTER <SCOPE>".
|
SqlShowCatalogs |
FlinkSqlParserImpl.SqlShowCatalogs()
Parse a "Show Catalogs" metadata query command.
|
SqlShowColumns |
FlinkSqlParserImpl.SqlShowColumns()
SHOW COLUMNS FROM [[catalog.] database.]sqlIdentifier sql call.
|
SqlShowCreate |
FlinkSqlParserImpl.SqlShowCreate()
Parse a "Show Create Table" query and "Show Create View" and "Show Create Catalog" query commands.
|
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.SqlShowCurrentCatalogOrDatabase() |
SqlShowDatabases |
FlinkSqlParserImpl.SqlShowDatabases()
Parse a "Show DATABASES" metadata query command.
|
SqlShowFunctions |
FlinkSqlParserImpl.SqlShowFunctions()
Parses a show functions statement.
|
SqlShowJars |
FlinkSqlParserImpl.SqlShowJars()
Parses a show jars statement.
|
SqlShowJobs |
FlinkSqlParserImpl.SqlShowJobs()
Parse a "SHOW JOBS" statement.
|
SqlShowModels |
FlinkSqlParserImpl.SqlShowModels()
SHOW MODELS [FROM [catalog.] database] sql call.
|
SqlShowModules |
FlinkSqlParserImpl.SqlShowModules()
Parses a show modules statement.
|
SqlShowPartitions |
FlinkSqlParserImpl.SqlShowPartitions()
SHOW PARTITIONS table_name [PARTITION partition_spec];
|
SqlShowProcedures |
FlinkSqlParserImpl.SqlShowProcedures()
Parses a show functions statement.
|
SqlShowTables |
FlinkSqlParserImpl.SqlShowTables()
Parses a show tables statement.
|
SqlShowViews |
FlinkSqlParserImpl.SqlShowViews()
Parse a "Show Views" metadata query command.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlStatementSet()
Parse a statement set.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlStmt()
Parses an SQL statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlStmtEof()
Parses an SQL statement followed by the end-of-file symbol.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.SqlStmtList()
Parses a list of SQL statements separated by semicolon.
|
SqlStopJob |
FlinkSqlParserImpl.SqlStopJob()
Parses a STOP JOB statement:
STOP JOB
|
SqlTableLike |
FlinkSqlParserImpl.SqlTableLike(org.apache.calcite.sql.parser.SqlParserPos startPos) |
SqlTableLike.SqlTableLikeOption |
FlinkSqlParserImpl.SqlTableLikeOption() |
SqlTruncateTable |
FlinkSqlParserImpl.SqlTruncateTable()
Parses a TRUNCATE TABLE statement.
|
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.SqlTypeName(org.apache.calcite.sql.parser.Span s) |
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.SqlTypeName1(org.apache.calcite.sql.parser.Span s) |
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.SqlTypeName2(org.apache.calcite.sql.parser.Span s) |
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.SqlTypeName3(org.apache.calcite.sql.parser.Span s) |
SqlUnloadModule |
FlinkSqlParserImpl.SqlUnloadModule()
Parses an unload module statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.SqlUpdate()
Parses an UPDATE statement.
|
SqlUseCatalog |
FlinkSqlParserImpl.SqlUseCatalog() |
SqlUseDatabase |
FlinkSqlParserImpl.SqlUseDatabase() |
SqlUseModules |
FlinkSqlParserImpl.SqlUseModules()
Parses an use modules statement.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.StandardFloorCeilOptions(org.apache.calcite.sql.parser.Span s,
boolean floorFlag) |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.StringAggFunctionCall()
Parses a call to the STRING_AGG aggregate function (or to an aggregate
function with similar syntax: ARRAY_AGG, ARRAY_CONCAT_AGG, GROUP_CONCAT).
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.StringLiteral()
Parses a string literal.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.SubsetDefinitionCommaList(org.apache.calcite.sql.parser.Span s) |
org.apache.calcite.sql.SqlIdentifier |
FlinkSqlParserImpl.TableApiIdentifier()
Those methods should not be used in SQL.
|
void |
FlinkSqlParserImpl.TableApiIdentifierSegment(List<String> names,
List<org.apache.calcite.sql.parser.SqlParserPos> positions) |
void |
FlinkSqlParserImpl.TableColumn(SqlCreateTable.TableCreationContext context) |
SqlTableConstraint |
FlinkSqlParserImpl.TableConstraint()
Parses a table constraint for CREATE TABLE.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableConstructor()
Parses a VALUES leaf query expression.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableFunctionCall() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableHints(org.apache.calcite.sql.SqlIdentifier tableName)
Parses hints following a table reference,
and returns the wrapped table reference.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableOption() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableOverOpt()
Allows an OVER clause following a table expression as an extension to
standard SQL syntax.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableParam()
Table parameter of a table function.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableRef()
Parses a table reference in a FROM clause, not lateral unless LATERAL
is explicitly specified.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableRef1(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableRef2(boolean lateral)
Parses a table reference in a FROM clause.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TableRef3(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext,
boolean lateral) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Tablesample(org.apache.calcite.sql.SqlNode tableRef) |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.TimestampAddFunctionCall()
Parses a call to TIMESTAMPADD.
|
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.TimestampDiffFunctionCall()
Parses a call to TIMESTAMPDIFF.
|
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.TimestampInterval() |
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.TimeUnit()
Parses time unit for CEIL and FLOOR functions.
|
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.TimeUnitForExtract()
Parses time unit for the EXTRACT function.
|
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.TimeUnitIdentifier()
Parses a simple identifier as a TimeUnit.
|
boolean |
FlinkSqlParserImpl.TimeZoneOpt()
Parse a time zone suffix for DateTime types.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.TryCastFunctionCall()
Parses a TRY_CAST invocation.
|
SqlTableColumn |
FlinkSqlParserImpl.TypedColumn(SqlCreateTable.TableCreationContext context)
Parses
column_name column_data_type [...]. |
org.apache.calcite.sql.SqlTypeNameSpec |
FlinkSqlParserImpl.TypeName() |
org.apache.calcite.sql.SqlLiteral |
FlinkSqlParserImpl.UniqueSpec() |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Unpivot(org.apache.calcite.sql.SqlNode tableRef)
Parses an UNPIVOT clause following a table expression.
|
List<org.apache.calcite.sql.SqlNode> |
FlinkSqlParserImpl.UnquantifiedFunctionParameterList(org.apache.calcite.sql.parser.SqlAbstractParserImpl.ExprContext exprContext)
Parses function parameter lists.
|
int |
FlinkSqlParserImpl.UnsignedIntLiteral() |
org.apache.calcite.sql.SqlNumericLiteral |
FlinkSqlParserImpl.UnsignedNumericLiteral()
Parses a unsigned numeric literal
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.UnsignedNumericLiteralOrParam()
Numeric literal or parameter; used in LIMIT, OFFSET and FETCH clauses.
|
void |
FlinkSqlParserImpl.UnusedExtension()
Defines a production which can never be accepted by the parser.
|
void |
FlinkSqlParserImpl.Watermark(SqlCreateTable.TableCreationContext context) |
org.apache.calcite.sql.SqlUpdate |
FlinkSqlParserImpl.WhenMatchedClause(org.apache.calcite.sql.SqlNode table,
org.apache.calcite.sql.SqlIdentifier alias) |
org.apache.calcite.sql.SqlInsert |
FlinkSqlParserImpl.WhenNotMatchedClause(org.apache.calcite.sql.SqlNode table) |
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.Where()
Parses a WHERE clause for SELECT, DELETE, and UPDATE.
|
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.Window()
Parses a WINDOW clause for SELECT.
|
org.apache.calcite.sql.SqlNode |
FlinkSqlParserImpl.WindowRange() |
org.apache.calcite.sql.SqlWindow |
FlinkSqlParserImpl.WindowSpecification()
Parses a window specification.
|
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.withinDistinct(org.apache.calcite.sql.SqlNode arg) |
org.apache.calcite.sql.SqlCall |
FlinkSqlParserImpl.withinGroup(org.apache.calcite.sql.SqlNode arg) |
org.apache.calcite.sql.SqlNodeList |
FlinkSqlParserImpl.WithList() |
org.apache.calcite.avatica.util.TimeUnit |
FlinkSqlParserImpl.Year() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.bucketCountMustBePositiveInteger() |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.createFunctionUsingJar(String language) |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.createSystemFunctionOnlySupportTemporary() |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.createTemporaryMaterializedTableUnsupported() |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.dropTemporaryMaterializedTableUnsupported() |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.explainDetailIsDuplicate() |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.multipleWatermarksUnsupported() |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.overwriteIsOnlyUsedWithInsert() |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.replaceMaterializedTableUnsupported() |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.unsupportedFreshnessType() |
org.apache.calcite.runtime.Resources.ExInst<ParseException> |
ParserResource.withDrainOnlyUsedWithSavepoint() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.