org.apache.hadoop.hive.ql.parse

Class UpdateDeleteSemanticAnalyzer

java.lang.Object

org.apache.hadoop.hive.ql.parse.BaseSemanticAnalyzer

org.apache.hadoop.hive.ql.parse.SemanticAnalyzer

org.apache.hadoop.hive.ql.parse.UpdateDeleteSemanticAnalyzer

public class UpdateDeleteSemanticAnalyzer
extends SemanticAnalyzer

A subclass of the SemanticAnalyzer that just handles update, delete and merge statements. It works by rewriting the updates and deletes into insert statements (since they are actually inserts) and then doing some patch up to make them work as updates and deletes instead.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.parse.SemanticAnalyzer

SemanticAnalyzer.GenericUDAFInfo, SemanticAnalyzer.MaterializationRebuildMode, SemanticAnalyzer.PlannerContextFactory

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.parse.BaseSemanticAnalyzer

BaseSemanticAnalyzer.AnalyzeRewriteContext, BaseSemanticAnalyzer.TableSpec

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.parse.SemanticAnalyzer

analyzeRewrite, createVwDesc, defaultJoinMerge, disableJoinMerge, DUMMY_DATABASE, DUMMY_TABLE, materializedViewUpdateDesc, mvRebuildDbName, mvRebuildMode, mvRebuildName, noscan, opParseCtx, resultSchema, SUBQUERY_TAG_1, SUBQUERY_TAG_2, tableMask, topOps, unparseTranslator, VALUES_TMP_TABLE_NAME_PREFIX, viewSelect, viewsExpanded

Fields inherited from class org.apache.hadoop.hive.ql.parse.BaseSemanticAnalyzer

acidFileSinks, 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

Method Summary

Modifier and Type	Method and Description
void	analyzeInternal(ASTNode tree)
static boolean	isAcidExport(ASTNode tree) Exporting an Acid table is more complicated than a flat table.

Methods inherited from class org.apache.hadoop.hive.ql.parse.SemanticAnalyzer

addPartitionColsToInsert, analyzeCreateView, checkAcidTxnManager, deleting, determineSprayKeys, doPhase1, doPhase1QBExpr, doPhase1QBExpr, genAllExprNodeDesc, genAllExprNodeDesc, generateErrorMessage, genExprNodeDesc, genExprNodeDesc, genExprNodeDesc, genExprNodeDesc, genExprNodeDesc, genFileSinkPlan, genPartValueString, genPlan, genPlan, genSelectDIAST, getAliasId, getAllInputs, getAllOutputs, getAllRootTasks, getColumnInternalName, getDummyTable, getFullTableNameForSQL, getGenericUDAFEvaluator, getGenericUDAFInfo, getGroupingSets, getGroupingSetsForCube, getGroupingSetsForRollup, getHintsFromQB, getHintsFromQB, getInvalidQueryMaterializationReason, getLoadFileWork, getMaterializationMetadata, getMetaData, getMetaData, getOpContext, getParseContext, getQB, getResultSchema, getTableObjectByName, groupByDescModeToUDAFMode, handleInsertStatementSpec, init, initParseCtx, initPhase1Ctx, isConstantParameterInAggregationParameters, isValidQueryMaterialization, parseSelect, processNoScanCommand, processPositionAlias, putOpInsertMap, raiseWrongType, replaceDefaultKeywordForMerge, reset, rewriteASTWithMaskAndFilter, rewriteGroupingFunctionAST, rewriteQueryWithQualifiedNames, saveViewDefinition, setAST, setBit, setInvalidQueryMaterializationReason, setLoadFileWork, setQB, unsetBit, updating, validate

Methods inherited from class org.apache.hadoop.hive.ql.parse.BaseSemanticAnalyzer

analyze, analyzeDDLSkewedValues, analyzeSkewedTablDDLColNames, analyzeStoredAdDirs, charSetString, constructListBucketingCtx, createFetchTask, createHiveDB, escapeSQLString, getAcidDdlDesc, getAcidFileSinks, getAutoCommitValue, getCacheUsage, getColumnAccessInfo, getColumnNames, getColumnNamesOrder, getColumns, getColumns, getColumns, getDatabase, getDatabase, getDb, getDbTableNamePair, getDotName, getFetchTask, getIdToTableNameMap, getInputs, getLineageInfo, getOutputs, getPartition, getPartitions, getQualifiedTableName, getQueryProperties, getQueryState, getRootTasks, getSkewedValueFromASTNode, getSkewedValuesFromASTNode, getTable, getTable, getTable, getTable, getTable, getTableAccessInfo, getTxnMgr, getTypeStringFromAST, getUnescapedName, getUnescapedName, getUnescapedUnqualifiedTableName, getUpdateColumnAccessInfo, hasEnabledOrValidatedConstraints, hasTransactionalInQuery, initCtx, isValidPrefixSpec, processCheckConstraints, processDefaultConstraints, processForeignKeys, processNotNullConstraints, processPrimaryKeys, processPrimaryKeys, processUniqueConstraints, processUniqueConstraints, readProps, setCacheUsage, setColumnAccessInfo, setFetchTask, setLineageInfo, setTableAccessInfo, setUpdateColumnAccessInfo, skipAuthorization, stripIdentifierQuotes, stripQuotes, toMessage, toReadEntity, toReadEntity, toReadEntity, toWriteEntity, toWriteEntity, toWriteEntity, tryQualifyPath, unescapeIdentifier, unescapeSQLString, validateCheckConstraint, validatePartColumnType, validatePartSpec

Methods inherited from class java.lang.Object

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

Method Detail

analyzeInternal

public void analyzeInternal(ASTNode tree)
                     throws SemanticException

Overrides:

analyzeInternal in class SemanticAnalyzer

Throws:

SemanticException

isAcidExport

public static boolean isAcidExport(ASTNode tree)
                            throws SemanticException

Exporting an Acid table is more complicated than a flat table. It may contains delete events, which can only be interpreted properly withing the context of the table/metastore where they were generated. It may also contain insert events that belong to transactions that aborted where the same constraints apply. In order to make the export artifact free of these constraints, the export does a insert into tmpTable select * from to filter/apply the events in current context and then export the tmpTable. This export artifact can now be imported into any table on any cluster (subject to schema checks etc). See analyzeAcidExport(ASTNode)

Parameters:

tree - Export statement

Returns:

true if exporting an Acid table.

Throws:

SemanticException