public class ImportSemanticAnalyzer 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, LOG, outputs, queryProperties, queryState, rootTasks, STATIC_LOG, tableAccessInfo, updateColumnAccessInfo
Constructor and Description |
---|
ImportSemanticAnalyzer(QueryState queryState) |
Modifier and Type | Method and Description |
---|---|
void |
analyzeInternal(ASTNode ast) |
boolean |
existsTable() |
static boolean |
prepareImport(boolean isLocationSet,
boolean isExternalSet,
boolean isPartSpecSet,
boolean waitOnPrecursor,
String parsedLocation,
String parsedTableName,
String parsedDbName,
LinkedHashMap<String,String> parsedPartSpec,
String fromLocn,
EximUtil.SemanticAnalyzerWrapperContext x,
Map<String,Long> dbsUpdated,
Map<String,Long> tablesUpdated) |
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 ImportSemanticAnalyzer(QueryState queryState) throws SemanticException
SemanticException
public boolean existsTable()
public void analyzeInternal(ASTNode ast) throws SemanticException
analyzeInternal
in class BaseSemanticAnalyzer
SemanticException
public static boolean prepareImport(boolean isLocationSet, boolean isExternalSet, boolean isPartSpecSet, boolean waitOnPrecursor, String parsedLocation, String parsedTableName, String parsedDbName, LinkedHashMap<String,String> parsedPartSpec, String fromLocn, EximUtil.SemanticAnalyzerWrapperContext x, Map<String,Long> dbsUpdated, Map<String,Long> tablesUpdated) throws IOException, MetaException, HiveException, URISyntaxException
Copyright © 2021 The Apache Software Foundation. All rights reserved.