Package com.alibaba.druid.sql.dialect.spark.parser

Class SparkStatementParser

java.lang.Object

com.alibaba.druid.sql.parser.SQLParser

com.alibaba.druid.sql.parser.SQLStatementParser

com.alibaba.druid.sql.dialect.hive.parser.HiveStatementParser

com.alibaba.druid.sql.dialect.spark.parser.SparkStatementParser

Direct Known Subclasses:

DatabricksStatementParser

public class SparkStatementParser
extends HiveStatementParser

Version:

$Id: AntsparkStateMentParser.java, v 0.1 2018年09月14日 15:07 peiheng.qph Exp $

Author:

peiheng.qph

Field Summary

Fields inherited from class com.alibaba.druid.sql.parser.SQLStatementParser

currentDate, expectedNextToken, exprParser, insertColumnsCache, now, parseCompleteValues, parseValuesSize, repository, selectListCache

Fields inherited from class com.alibaba.druid.sql.parser.SQLParser

dbType, lexer

Constructor Summary

Constructors

Constructor	Description
SparkStatementParser(Lexer lexer)
SparkStatementParser(SQLExprParser sqlExprParser)
SparkStatementParser(String sql)

Method Summary

Modifier and Type	Method	Description
protected void	alterTableUnset(SQLAlterTableStatement stmt)
SQLCreateTableParser	getSQLCreateTableParser()
SparkCacheTableStatement	parseCache()
SQLStatement	parseCreateScan()
boolean	parseStatementListDialect(List<SQLStatement> statementList)

Methods inherited from class com.alibaba.druid.sql.dialect.hive.parser.HiveStatementParser

alterDatabase, alterSchema, alterTableAfterNameRest, alterTableSetRest, createSQLSelectParser, getExprParser, parseAdd, parseAlterTableAddColumnBefore, parseCreateFunction, parseCreateIndex, parseCreateSchema, parseCreateTable, parseCreateTableSupportSchema, parseExport, parseImport, parseInsert, parseLoad

Methods inherited from class com.alibaba.druid.sql.parser.SQLStatementParser

alterEvent, alterFullText, alterIndex, alterMaterialized, alterProcedure, alterResourceGroup, alterRest, alterSequence, alterTable, alterTableAdd, alterTableAddConstraint, alterTableAddIndex, alterTableAddPartition, alterTableAddRest, alterTableAddRestSpecific, alterTableAfterName, alterTableAlterComma, alterTableBefore, alterTableChangeOwner, alterTableMerge, alterTableOwner, alterTableSet, alterTableSetSerdeProperties, alterTableSetTblProperties, alterTableSorted, alterTableSpace, alterTableTruncate, alterTableWith, alterUser, alterView, createOptionSkip, createResource, createSQLAlterTableStatement, createSQLSelectParser, createTableRest, createUpdateStatement, createViewAs, getParseValuesSize, getRepository, getSelectListCache, isKeepComments, isParseCompleteValues, mergeBeforeName, parameters, parseAlter, parseAlterColumn, parseAlterDrop, parseAlterDropRest, parseAlterFunction, parseAlterTableAddClusteringKey, parseAlterTableAddColumn, parseAlterTableAddColumn, parseAlterTableDropPartition, parseAlterTableDropSubpartition, parseAlterTableRename, parseAlterTableReplaceColumn, parseAnalyze, parseAssignItems, parseAssignItems, parseBlock, parseCall, parseCase, parseClone, parseClose, parseComment, parseCommit, parseCompute, parseContinue, parseCopy, parseCreate, parseCreateDatabase, parseCreateDbLink, parseCreateEvent, parseCreateExternalCatalog, parseCreateMaterializedView, parseCreateMaterializedViewRest, parseCreateModel, parseCreateOutline, parseCreatePackage, parseCreateProcedure, parseCreateRole, parseCreateSequence, parseCreateServer, parseCreateSynonym, parseCreateTableGroup, parseCreateTableSpace, parseCreateTrigger, parseCreateType, parseCreateUser, parseCreateView, parseCreateViewAfterName, parseCreateViewAtDataType, parseDeclare, parseDeleteStatement, parseDescribe, parseDrop, parseDropCatalog, parseDropDatabaseOrSchema, parseDropEvent, parseDropFunction, parseDropIndex, parseDropLogFileGroup, parseDropMaterializedView, parseDropOfflineModel, parseDropOutline, parseDropProcedure, parseDropResource, parseDropRole, parseDropSchema, parseDropSequence, parseDropServer, parseDropTable, parseDropTableGroup, parseDropTablespace, parseDropTrigger, parseDropUser, parseDropView, parseDump, parseEnd, parseErrorLoggingClause, parseException, parseExecute, parseExplain, parseExplainFormatPartition, parseExplainFormatType, parseFetch, parseFlashback, parseFor, parseFullTextType, parseGrant, parseHints, parseHiveCreateFunction, parseHiveInsert, parseHiveInsertStmt, parseIf, parseIfElse, parseInsert0, parseInsert0, parseInsert0Hints, parseInsertColumns, parseInsertOverwrite, parseKill, parseLeave, parseList, parseLoop, parseMerge, parseMergeWhen, parseMsck, parseOpen, parseOptimize, parsePartitionRef, parsePrivilege, parsePurge, parseRefresh, parseReleaseSavePoint, parseRename, parseRepeat, parseReset, parseReturn, parseRevoke, parseRollback, parserParameters, parseSavePoint, parseSelect, parseSet, parseShow, parseShowColumns, parseShowCreateTable, parseShowDatabases, parseShowMaterializedView, parseShowTableGroups, parseShowTables, parseShowVariants, parseStart, parseStatement, parseStatement0, parseStatementList, parseStatementList, parseStatementList, parseStatementList, parseStatementList, parseTruncate, parseUpdateSet, parseUpdateSetComma, parseUpdateStatement, parseUpdateStatementPartition, parseUpsert, parseUse, parseUser, parseValueClause, parseValueClause, parseValueClause, parseValueClauseNative, parseWhile, parseWhoami, parseWith, parseWithQuery, parseWithQuerySkip, setKeepComments, setParseCompleteValues, setParseValuesSize, setRepository, setSelectListCache

Methods inherited from class com.alibaba.druid.sql.parser.SQLParser

accept, acceptIdentifier, acceptIdentifier, acceptInteger, alias, as, config, dialectFeatureEnabled, getDbType, getLexer, getTimeZone, identifierEquals, isEnabled, match, newCreateStatement, printError, setErrorEndPos, setTimeZone, tableAlias, tableAlias

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SparkStatementParser

public SparkStatementParser(String sql)

SparkStatementParser

public SparkStatementParser(Lexer lexer)

SparkStatementParser

public SparkStatementParser(SQLExprParser sqlExprParser)

Method Details

getSQLCreateTableParser

public SQLCreateTableParser getSQLCreateTableParser()

Overrides:

getSQLCreateTableParser in class HiveStatementParser

alterTableUnset

protected void alterTableUnset(SQLAlterTableStatement stmt)

Overrides:

alterTableUnset in class SQLStatementParser

parseCreateScan

public SQLStatement parseCreateScan()

Overrides:

parseCreateScan in class SQLStatementParser

parseCache

public SparkCacheTableStatement parseCache()

Overrides:

parseCache in class SQLStatementParser

parseStatementListDialect

public boolean parseStatementListDialect(List<SQLStatement> statementList)

Overrides:

parseStatementListDialect in class HiveStatementParser