Package org.apache.flink.sql.parser.ddl
Class SqlCreateModelAs
- java.lang.Object
-
- org.apache.calcite.sql.SqlNode
-
- org.apache.calcite.sql.SqlCall
-
- org.apache.calcite.sql.SqlDdl
-
- org.apache.calcite.sql.SqlCreate
-
- org.apache.flink.sql.parser.ddl.SqlCreateModel
-
- org.apache.flink.sql.parser.ddl.SqlCreateModelAs
-
- All Implemented Interfaces:
Cloneable
,ExtendedSqlNode
public class SqlCreateModelAs extends SqlCreateModel
SqlNode
to describe the CREATE MODEL AS syntax. The CTAS would create a pipeline to compute the result of the given query and use the data to train the model.Example:
CREATE MODEL my_model WITH (name=value, [name=value]*) ) AS SELECT col1, col2, label FROM base_table;
-
-
Field Summary
Fields Modifier and Type Field Description static org.apache.calcite.sql.SqlSpecialOperator
OPERATOR
-
Constructor Summary
Constructors Constructor Description SqlCreateModelAs(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier modelName, org.apache.calcite.sql.SqlCharStringLiteral comment, org.apache.calcite.sql.SqlNodeList inputColumnList, org.apache.calcite.sql.SqlNodeList outputColumnList, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlNode asQuery, boolean isTemporary, boolean ifNotExists)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.calcite.sql.SqlNode
getAsQuery()
List<org.apache.calcite.sql.SqlNode>
getOperandList()
org.apache.calcite.sql.SqlOperator
getOperator()
void
unparse(org.apache.calcite.sql.SqlWriter writer, int leftPrec, int rightPrec)
void
validate()
-
Methods inherited from class org.apache.flink.sql.parser.ddl.SqlCreateModel
fullModelName, getComment, getInputColumnList, getModelName, getOutputColumnList, getPropertyList, isIfNotExists, isTemporary
-
Methods inherited from class org.apache.calcite.sql.SqlCall
accept, clone, equalsDeep, findValidOptions, getCallSignature, getFunctionQuantifier, getKind, getMonotonicity, isCountStar, isExpanded, operand, operandCount, setOperand, validate
-
-
-
-
Constructor Detail
-
SqlCreateModelAs
public SqlCreateModelAs(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier modelName, org.apache.calcite.sql.SqlCharStringLiteral comment, org.apache.calcite.sql.SqlNodeList inputColumnList, org.apache.calcite.sql.SqlNodeList outputColumnList, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlNode asQuery, boolean isTemporary, boolean ifNotExists)
-
-
Method Detail
-
getOperator
@Nonnull public org.apache.calcite.sql.SqlOperator getOperator()
- Overrides:
getOperator
in classSqlCreateModel
-
getOperandList
@Nonnull public List<org.apache.calcite.sql.SqlNode> getOperandList()
- Overrides:
getOperandList
in classSqlCreateModel
-
validate
public void validate() throws SqlValidateException
- Specified by:
validate
in interfaceExtendedSqlNode
- Overrides:
validate
in classSqlCreateModel
- Throws:
SqlValidateException
-
getAsQuery
public org.apache.calcite.sql.SqlNode getAsQuery()
-
unparse
public void unparse(org.apache.calcite.sql.SqlWriter writer, int leftPrec, int rightPrec)
- Overrides:
unparse
in classSqlCreateModel
-
-