public class DDLSemanticAnalyzer extends BaseSemanticAnalyzer
BaseSemanticAnalyzer.AnalyzeRewriteContext, BaseSemanticAnalyzer.TableSpecacidFileSinks, cacheUsage, cContext, columnAccessInfo, conf, console, ctx, db, fetchTask, HIVE_COLUMN_NULLS_FIRST, HIVE_COLUMN_NULLS_LAST, HIVE_COLUMN_ORDER_ASC, HIVE_COLUMN_ORDER_DESC, idToTableNameMap, inputs, linfo, outputs, queryProperties, queryState, rootTasks, STATIC_LOG, tableAccessInfo, transactionalInQuery, txnManager, updateColumnAccessInfo| Constructor and Description |
|---|
DDLSemanticAnalyzer(QueryState queryState) |
DDLSemanticAnalyzer(QueryState queryState,
Hive db) |
| Modifier and Type | Method and Description |
|---|---|
void |
analyzeInternal(ASTNode input) |
DDLDesc.DDLDescWithWriteId |
getAcidDdlDesc() |
static HashMap<String,String> |
getPartSpec(ASTNode partspec) |
static String |
getTypeName(ASTNode node) |
static HashMap<String,String> |
getValidatedPartSpec(Table table,
ASTNode astNode,
HiveConf conf,
boolean shouldBeFull) |
static boolean |
isFullSpec(Table table,
Map<String,String> partSpec) |
static ExprNodeGenericFuncDesc |
makeBinaryPredicate(String fn,
ExprNodeDesc left,
ExprNodeDesc right) |
static ExprNodeGenericFuncDesc |
makeUnaryPredicate(String fn,
ExprNodeDesc arg) |
analyze, analyzeDDLSkewedValues, analyzeSkewedTablDDLColNames, analyzeStoredAdDirs, charSetString, constructListBucketingCtx, createFetchTask, createHiveDB, escapeSQLString, getAcidFileSinks, getAllInputs, getAllOutputs, getAllRootTasks, getAutoCommitValue, getCacheUsage, getColumnAccessInfo, getColumnNames, getColumnNamesOrder, getColumns, getColumns, getColumns, getDatabase, getDatabase, getDb, getDbTableNamePair, getDotName, getFetchTask, getIdToTableNameMap, getInputs, getLineageInfo, getOutputs, getPartition, getPartitions, getQualifiedTableName, getQueryProperties, getQueryState, getResultSchema, getRootTasks, getSkewedValueFromASTNode, getSkewedValuesFromASTNode, getTable, getTable, getTable, getTable, getTable, getTableAccessInfo, getTxnMgr, getTypeStringFromAST, getUnescapedName, getUnescapedName, getUnescapedUnqualifiedTableName, getUpdateColumnAccessInfo, hasEnabledOrValidatedConstraints, hasTransactionalInQuery, init, initCtx, isValidPrefixSpec, processCheckConstraints, processDefaultConstraints, processForeignKeys, processNotNullConstraints, processPrimaryKeys, processPrimaryKeys, processUniqueConstraints, processUniqueConstraints, readProps, reset, setCacheUsage, setColumnAccessInfo, setFetchTask, setLineageInfo, setTableAccessInfo, setUpdateColumnAccessInfo, skipAuthorization, stripIdentifierQuotes, stripQuotes, toMessage, toReadEntity, toReadEntity, toReadEntity, toWriteEntity, toWriteEntity, toWriteEntity, tryQualifyPath, unescapeIdentifier, unescapeSQLString, validate, validateCheckConstraint, validatePartColumnType, validatePartSpecpublic DDLSemanticAnalyzer(QueryState queryState) throws SemanticException
SemanticExceptionpublic DDLSemanticAnalyzer(QueryState queryState, Hive db) throws SemanticException
SemanticExceptionpublic static String getTypeName(ASTNode node) throws SemanticException
SemanticExceptionpublic void analyzeInternal(ASTNode input) throws SemanticException
analyzeInternal in class BaseSemanticAnalyzerSemanticExceptionpublic DDLDesc.DDLDescWithWriteId getAcidDdlDesc()
getAcidDdlDesc in class BaseSemanticAnalyzerpublic static HashMap<String,String> getPartSpec(ASTNode partspec) throws SemanticException
SemanticExceptionpublic static HashMap<String,String> getValidatedPartSpec(Table table, ASTNode astNode, HiveConf conf, boolean shouldBeFull) throws SemanticException
SemanticExceptionpublic static ExprNodeGenericFuncDesc makeBinaryPredicate(String fn, ExprNodeDesc left, ExprNodeDesc right) throws SemanticException
SemanticExceptionpublic static ExprNodeGenericFuncDesc makeUnaryPredicate(String fn, ExprNodeDesc arg) throws SemanticException
SemanticExceptionCopyright © 2019 The Apache Software Foundation. All Rights Reserved.