public class DDLSemanticAnalyzer extends BaseSemanticAnalyzer
BaseSemanticAnalyzer.AnalyzeRewriteContext, BaseSemanticAnalyzer.TableSpec
acidFileSinks, acidInQuery, 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, updateColumnAccessInfo
Constructor and Description |
---|
DDLSemanticAnalyzer(QueryState queryState) |
DDLSemanticAnalyzer(QueryState queryState,
Hive db) |
Modifier and Type | Method and Description |
---|---|
void |
analyzeInternal(ASTNode input) |
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, 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, getTypeStringFromAST, getUnescapedName, getUnescapedName, getUnescapedUnqualifiedTableName, getUpdateColumnAccessInfo, hasAcidInQuery, init, initCtx, isValidPrefixSpec, processForeignKeys, processPrimaryKeys, readProps, reset, setColumnAccessInfo, setFetchTask, setLineageInfo, setTableAccessInfo, setUpdateColumnAccessInfo, skipAuthorization, stripIdentifierQuotes, stripQuotes, toMessage, toReadEntity, toReadEntity, toReadEntity, toWriteEntity, toWriteEntity, toWriteEntity, tryQualifyPath, unescapeIdentifier, unescapeSQLString, validate, validatePartColumnType, validatePartSpec
public DDLSemanticAnalyzer(QueryState queryState) throws SemanticException
SemanticException
public DDLSemanticAnalyzer(QueryState queryState, Hive db) throws SemanticException
SemanticException
public static String getTypeName(ASTNode node) throws SemanticException
SemanticException
public void analyzeInternal(ASTNode input) throws SemanticException
analyzeInternal
in class BaseSemanticAnalyzer
SemanticException
public static HashMap<String,String> getPartSpec(ASTNode partspec) throws SemanticException
SemanticException
public static HashMap<String,String> getValidatedPartSpec(Table table, ASTNode astNode, HiveConf conf, boolean shouldBeFull) throws SemanticException
SemanticException
public static ExprNodeGenericFuncDesc makeBinaryPredicate(String fn, ExprNodeDesc left, ExprNodeDesc right) throws SemanticException
SemanticException
public static ExprNodeGenericFuncDesc makeUnaryPredicate(String fn, ExprNodeDesc arg) throws SemanticException
SemanticException
Copyright © 2021 The Apache Software Foundation. All rights reserved.