public class ExportSemanticAnalyzer 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 |
---|
ExportSemanticAnalyzer(QueryState queryState) |
Modifier and Type | Method and Description |
---|---|
void |
analyzeInternal(ASTNode ast) |
static void |
prepareExport(ASTNode ast,
URI toURI,
BaseSemanticAnalyzer.TableSpec ts,
ReplicationSpec replicationSpec,
Hive db,
HiveConf conf,
Context ctx,
List<Task<? extends Serializable>> rootTasks,
HashSet<ReadEntity> inputs,
HashSet<WriteEntity> outputs,
org.slf4j.Logger LOG) |
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 ExportSemanticAnalyzer(QueryState queryState) throws SemanticException
SemanticException
public void analyzeInternal(ASTNode ast) throws SemanticException
analyzeInternal
in class BaseSemanticAnalyzer
SemanticException
public static void prepareExport(ASTNode ast, URI toURI, BaseSemanticAnalyzer.TableSpec ts, ReplicationSpec replicationSpec, Hive db, HiveConf conf, Context ctx, List<Task<? extends Serializable>> rootTasks, HashSet<ReadEntity> inputs, HashSet<WriteEntity> outputs, org.slf4j.Logger LOG) throws SemanticException
SemanticException
Copyright © 2021 The Apache Software Foundation. All rights reserved.