public class AlterTableAddPartitionAnalyzer extends AbstractAlterTableAnalyzer
BaseSemanticAnalyzer.AnalyzeRewriteContext, BaseSemanticAnalyzer.TableSpec
acidFileSinks, cacheUsage, cContext, columnAccessInfo, conf, console, ctx, db, fetchTask, idToTableNameMap, inputs, linfo, LOG, outputs, prepareQuery, queryProperties, queryState, rootTasks, STATIC_LOG, tableAccessInfo, transactionalInQuery, txnManager, updateColumnAccessInfo
Constructor and Description |
---|
AlterTableAddPartitionAnalyzer(QueryState queryState) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
allowLocation() |
protected void |
analyzeCommand(TableName tableName,
Map<String,String> partitionSpec,
ASTNode command) |
protected boolean |
expectView() |
protected void |
postProcess(TableName tableName,
Table table,
AlterTableAddPartitionDesc desc,
Task<DDLWork> ddlTask)
Add partition for Transactional tables needs to add (copy/rename) the data so that it lands
in a delta_x_x/ folder in the partition dir.
|
analyzeInternal, setAcidDdlDesc
addInputsOutputsAlterTable, getAcidDdlDesc, setAcidDdlDesc, validateAlterTableType
addPropertyReadEntry, analyze, analyzeStoredAdDirs, charSetString, checkColumnName, constructListBucketingCtx, createFetchTask, createHiveDB, endAnalysis, escapeSQLString, executeUnparseTranlations, findTabRefIdxs, getAcidAnalyzeTable, getAcidFileSinks, getAllInputs, getAllOutputs, getAllRootTasks, getAutoCommitValue, getCacheUsage, getCboInfo, getColumnAccessInfo, getColumnNames, getColumnNamesOrder, getColumns, getColumns, getColumns, getCtx, getDatabase, getDatabase, getDataConnector, getDataConnector, getDb, getDbTableNamePair, getFetchTask, getIdToTableNameMap, getInputs, getLineageInfo, getOutputs, getParseContext, getPartitionSpecs, getPartSpec, getProps, getQualifiedTableName, getQualifiedTableName, getQueryProperties, getQueryState, getResultSchema, getRootTasks, getSimpleTableNameBase, getTable, getTable, getTable, getTable, getTable, getTable, getTableAccessInfo, getTableAlias, getTxnMgr, getTypeStringFromAST, getUnescapedName, getUnescapedName, getUnescapedUnqualifiedTableName, getUpdateColumnAccessInfo, getValidatedPartSpec, hasTransactionalInQuery, init, initCtx, isPrepareQuery, isValidPrefixSpec, raiseWrongType, readProps, reset, setAutoCommitValue, setCacheUsage, setColumnAccessInfo, setFetchTask, setLineageInfo, setTableAccessInfo, setUpdateColumnAccessInfo, skipAuthorization, startAnalysis, stripQuotes, toReadEntity, toReadEntity, toReadEntity, toWriteEntity, toWriteEntity, toWriteEntity, tryQualifyPath, unescapeIdentifier, unescapeSQLString, validate, validatePartColumnType, validatePartSpec, validateUnsupportedPartitionClause
public AlterTableAddPartitionAnalyzer(QueryState queryState) throws SemanticException
SemanticException
protected boolean expectView()
protected boolean allowLocation()
protected void postProcess(TableName tableName, Table table, AlterTableAddPartitionDesc desc, Task<DDLWork> ddlTask) throws SemanticException
SemanticException
protected void analyzeCommand(TableName tableName, Map<String,String> partitionSpec, ASTNode command) throws SemanticException
analyzeCommand
in class AbstractAlterTableAnalyzer
SemanticException
Copyright © 2022 The Apache Software Foundation. All rights reserved.