Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.repl | |
org.apache.hadoop.hive.ql.exec.repl.bootstrap | |
org.apache.hadoop.hive.ql.io.merge | |
org.apache.hadoop.hive.ql.io.rcfile.truncate | |
org.apache.hadoop.hive.ql.optimizer.spark | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.plan | |
org.apache.hadoop.hive.ql.plan.ptf |
Modifier and Type | Class and Description |
---|---|
class |
MaterializedViewDesc |
Modifier and Type | Method and Description |
---|---|
T |
Operator.getConf() |
Modifier and Type | Class and Description |
---|---|
class |
ReplDumpWork |
class |
ReplStateLogWork
ReplStateLogWork
|
Modifier and Type | Class and Description |
---|---|
class |
ReplLoadWork |
Modifier and Type | Class and Description |
---|---|
class |
MergeFileWork |
Modifier and Type | Method and Description |
---|---|
String |
MergeFileWork.getMergeLevel() |
String |
MergeFileWork.getSourceTableInputFormat() |
Modifier and Type | Class and Description |
---|---|
class |
ColumnTruncateWork |
Modifier and Type | Class and Description |
---|---|
class |
SparkPartitionPruningSinkDesc |
Modifier and Type | Method and Description |
---|---|
String |
SparkPartitionPruningSinkDesc.displayTargetColumns() |
org.apache.hadoop.fs.Path |
SparkPartitionPruningSinkDesc.getPath() |
Modifier and Type | Class and Description |
---|---|
class |
AlterTablePartMergeFilesDesc |
class |
PreInsertTableDesc |
Modifier and Type | Method and Description |
---|---|
HashMap<String,String> |
AlterTablePartMergeFilesDesc.getPartSpec() |
Double |
SplitSample.getPercent() |
Integer |
SplitSample.getRowCount() |
int |
SplitSample.getSeedNum() |
String |
AlterTablePartMergeFilesDesc.getTableName() |
Long |
SplitSample.getTotalLength() |
Modifier and Type | Class and Description |
---|---|
class |
AlterDatabaseDesc
AlterDatabaseDesc.
|
class |
AlterMaterializedViewDesc
AlterMaterializedViewDesc.
|
class |
AlterResourcePlanDesc |
class |
AlterTableDesc
AlterTableDesc.
|
class |
AlterWMTriggerDesc |
class |
AppMasterEventDesc |
class |
ArchiveWork
ArchiveWork.
|
class |
CollectDesc
CollectDesc.
|
class |
ColumnStatsUpdateWork
ColumnStatsUpdateWork implementation.
|
class |
CommonMergeJoinDesc |
class |
ConditionalWork
ConditionalWork.
|
class |
CopyWork
CopyWork.
|
class |
CreateDatabaseDesc
CreateDatabaseDesc.
|
class |
CreateFunctionDesc
CreateFunctionDesc.
|
class |
CreateMacroDesc
CreateMacroDesc.
|
class |
CreateOrAlterWMMappingDesc |
class |
CreateOrAlterWMPoolDesc |
class |
CreateOrDropTriggerToPoolMappingDesc |
class |
CreateResourcePlanDesc |
class |
CreateTableDesc
CreateTableDesc.
|
class |
CreateTableLikeDesc
CreateTableLikeDesc.
|
class |
CreateViewDesc
CreateViewDesc.
|
class |
CreateWMTriggerDesc |
class |
DemuxDesc
Demux operator descriptor implementation.
|
class |
DependencyCollectionWork
DependencyCollectionWork
|
class |
DescDatabaseDesc
DescDatabaseDesc.
|
class |
DescFunctionDesc
DescFunctionDesc.
|
class |
DescTableDesc
DescTableDesc.
|
class |
DropDatabaseDesc
DropDatabaseDesc.
|
class |
DropFunctionDesc
DropFunctionDesc.
|
class |
DropMacroDesc
DropMacroDesc.
|
class |
DropResourcePlanDesc |
class |
DropTableDesc
DropTableDesc.
|
class |
DropWMMappingDesc |
class |
DropWMTriggerDesc |
class |
DummyStoreDesc
Dummy Store Desc.
|
class |
DynamicPruningEventDesc |
class |
ExplosionDesc
ExplosionDesc.
|
class |
ExportWork |
class |
FetchWork
FetchWork.
|
class |
FileSinkDesc
FileSinkDesc.
|
class |
FilterDesc
FilterDesc.
|
class |
ForwardDesc
ForwardDesc.
|
class |
GrantDesc |
class |
GrantRevokeRoleDDL |
class |
GroupByDesc
GroupByDesc.
|
class |
HashTableDummyDesc
HashTable Dummy Descriptor implementation.
|
class |
HashTableSinkDesc
Map Join operator Descriptor implementation.
|
class |
InsertCommitHookDesc |
class |
JoinDesc
Join operator Descriptor implementation.
|
class |
KillQueryDesc
Descriptor for killing queries.
|
class |
LateralViewForwardDesc
LateralViewForwardDesc.
|
class |
LateralViewJoinDesc
LateralViewJoinDesc.
|
class |
LimitDesc
LimitDesc.
|
class |
ListSinkDesc
description for ListSinkOperator, just for explain result.
|
class |
LockDatabaseDesc
LockDatabaseDesc.
|
class |
LockTableDesc
LockTableDesc.
|
class |
MapJoinDesc
Map Join operator Descriptor implementation.
|
class |
MapredLocalWork
MapredLocalWork.
|
class |
MapredWork
MapredWork.
|
class |
MoveWork
MoveWork.
|
class |
MuxDesc
Mux operator descriptor implementation..
|
class |
OrcFileMergeDesc
ORC fast file merge operator descriptor.
|
class |
PartitionDesc
PartitionDesc.
|
class |
PrincipalDesc |
class |
PrivilegeDesc |
class |
PrivilegeObjectDesc |
class |
PTFDesc |
class |
RCFileMergeDesc
Descriptor for Fast file merge RC file operator.
|
class |
ReduceSinkDesc
ReduceSinkDesc.
|
class |
ReloadFunctionDesc |
class |
ReplCopyWork
Marker work for Replication - behaves similar to CopyWork, but maps to ReplCopyTask,
which will have mechanics to list the files in source to write to the destination,
instead of copying them, if specified, falling back to copying if needed.
|
class |
ReplTxnWork
ReplTxnTask.
|
class |
RevokeDesc |
class |
RoleDDLDesc |
class |
ScriptDesc
ScriptDesc.
|
class |
SelectDesc
SelectDesc.
|
class |
ShowCreateDatabaseDesc
ShowCreateDatabaseDesc.
|
class |
ShowCreateTableDesc
ShowCreateTableDesc.
|
class |
ShowDatabasesDesc
ShowDatabasesDesc.
|
class |
ShowFunctionsDesc
ShowFunctionsDesc.
|
class |
ShowGrantDesc |
class |
ShowLocksDesc
ShowLocksDesc.
|
class |
ShowPartitionsDesc
ShowPartitionsDesc.
|
class |
ShowResourcePlanDesc |
class |
ShowTablesDesc
ShowTablesDesc.
|
class |
ShowTableStatusDesc
ShowTableStatusDesc.
|
class |
ShowTblPropertiesDesc
ShowTblPropertiesDesc.
|
class |
SMBJoinDesc |
class |
SparkEdgeProperty |
class |
SparkHashTableSinkDesc
Map Join operator Descriptor implementation.
|
class |
SparkWork
This class encapsulates all the work objects that can be executed
in a single Spark job.
|
class |
StatsWork
Stats Work, may include basic stats work and column stats desc
|
class |
SwitchDatabaseDesc
SwitchDatabaseDesc.
|
class |
TableScanDesc
Table Scan Descriptor Currently, data is only read from a base source as part
of map-reduce framework.
|
class |
TezWork
TezWork.
|
class |
TruncateTableDesc
Truncates managed table or partition
|
class |
UDTFDesc
All member variables should have a setters and getters of the form get
|
class |
UnionDesc
unionDesc is a empty class currently.
|
class |
UnlockDatabaseDesc
UnlockDatabaseDesc.
|
class |
UnlockTableDesc
UnlockTableDesc.
|
Modifier and Type | Method and Description |
---|---|
String |
DynamicPruningEventDesc.displayTargetColumn() |
boolean |
BaseWork.BaseExplainVectorization.enabled() |
boolean |
FetchWork.FetchExplainVectorization.enabled() |
List<String> |
MapWork.MapExplainVectorization.enabledConditionsMet() |
List<String> |
FetchWork.FetchExplainVectorization.enabledConditionsNotMet() |
List<String> |
MapWork.MapExplainVectorization.enabledConditionsNotMet() |
String |
SelectDesc.explainNoCompute() |
AbortTxnsDesc |
DDLWork.getAbortTxnsDesc() |
AddPartitionDesc |
DDLWork.getAddPartitionDesc() |
String |
BasicStatsWork.getAggKey() |
List<String> |
GroupByDesc.GroupByOperatorExplainVectorization.getAggregators() |
List<String> |
GroupByDesc.getAggregatorStrings() |
String |
TableScanDesc.getAlias() |
Map<String,Map<String,List<String>>> |
BucketMapJoinContext.getAliasBucketBaseFileNameMapping() |
Map<String,Map<String,List<String>>> |
BucketMapJoinContext.getAliasBucketFileNameMapping() |
LinkedHashMap<String,FetchWork> |
MapredLocalWork.getAliasToFetchWork() |
LinkedHashMap<String,Operator<? extends OperatorDesc>> |
MapredLocalWork.getAliasToWork() |
Set<Operator<? extends OperatorDesc>> |
MapWork.getAllRootOperators() |
AlterMaterializedViewDesc |
DDLWork.getAlterMaterializedViewDesc() |
String |
AlterTableDesc.getAlterTableTypeString() |
AlterTableDesc |
DDLWork.getAlterTblDesc() |
AppMasterEventDesc.AppMasterEventOperatorExplainVectorization |
AppMasterEventDesc.getAppMasterEventVectorization() |
String |
PartitionDesc.getBaseFileName() |
List<BaseWork> |
MergeJoinWork.getBaseWorkList() |
BasicStatsNoJobWork |
StatsWork.getBasicStatsNoJobWork() |
BasicStatsWork |
StatsWork.getBasicStatsWork() |
String |
MapJoinDesc.MapJoinOperatorExplainVectorization.getBigTableKeyColumnNums() |
List<String> |
MapJoinDesc.MapJoinOperatorExplainVectorization.getBigTableKeyExpressions() |
List<String> |
MapJoinDesc.MapJoinOperatorExplainVectorization.getBigTableOuterKey() |
String |
MapJoinDesc.MapJoinOperatorExplainVectorization.getBigTableRetainedColumnNums() |
String |
MapJoinDesc.MapJoinOperatorExplainVectorization.getBigTableValueColumnNums() |
List<String> |
MapJoinDesc.MapJoinOperatorExplainVectorization.getBigTableValueExpressions() |
List<String> |
CreateTableDesc.getBucketCols() |
String |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization.getBucketColumnNums() |
Map<String,List<BucketingSortingCtx.BucketCol>> |
MapWork.getBucketedColsByDirectory() |
Map<String,Integer> |
BucketMapJoinContext.getBucketFileNameMapping() |
boolean |
GroupByDesc.getBucketGroup() |
BucketMapJoinContext |
MapredLocalWork.getBucketMapjoinContextExplain() |
String |
CreateFunctionDesc.getClassName() |
String |
OperatorExplainVectorization.getClassName() |
String |
SelectDesc.getColListString() |
String |
CreateTableDesc.getCollItemDelim() |
List<String> |
ColumnStatsDesc.getColName() |
List<String> |
CreateTableDesc.getColsString() |
ColumnStatsDesc |
StatsWork.getColStats() |
List<String> |
ColumnStatsDesc.getColType() |
Map<String,String> |
AbstractOperatorDesc.getColumnExprMapForExplain() |
Map<String,String> |
JoinDesc.getColumnExprMapForExplain() |
List<Integer> |
TruncateTableDesc.getColumnIndexes() |
List<String> |
TableScanDesc.getColumnNamesForExplain() |
List<String> |
PrivilegeDesc.getColumns() |
String |
CreateTableDesc.getComment() |
String |
CreateViewDesc.getComment() |
String |
CreateDatabaseDesc.getComment() |
boolean |
FileSinkDesc.getCompressed() |
List<JoinCondDesc> |
JoinDesc.getCondsList() |
String |
ShowConfDesc.getConfName() |
String |
AlterTableDesc.getConstraintName() |
String |
CreateResourcePlanDesc.getCopyFromName() |
CreateResourcePlanDesc |
DDLWork.getCreateResourcePlanDesc() |
CreateTableDesc |
DDLWork.getCreateTblDesc() |
CreateTableLikeDesc |
DDLWork.getCreateTblLikeDesc() |
CreateViewDesc |
DDLWork.getCreateViewDesc() |
String |
TezWork.getDagId() |
String |
DescDatabaseDesc.getDatabaseName() |
String |
AlterDatabaseDesc.getDatabaseName() |
String |
ShowCreateDatabaseDesc.getDatabaseName() |
String |
UnlockDatabaseDesc.getDatabaseName() |
String |
DropDatabaseDesc.getDatabaseName() |
String |
SwitchDatabaseDesc.getDatabaseName() |
String |
TableScanDesc.getDatabaseName() |
String |
LockDatabaseDesc.getDatabaseName() |
Map<String,String> |
AlterDatabaseDesc.getDatabaseProperties() |
int |
BaseWork.BaseExplainVectorization.RowBatchContextExplainVectorization.getDataColumnCount() |
String |
BaseWork.BaseExplainVectorization.RowBatchContextExplainVectorization.getDataColumnNums() |
List<String> |
BaseWork.BaseExplainVectorization.RowBatchContextExplainVectorization.getDataColumns() |
String |
ShowTableStatusDesc.getDbName() |
String |
TableDesc.getDbName() |
String |
ShowTablesDesc.getDbName() |
String |
CreateTableLikeDesc.getDefaultInputFormat() |
String |
CreateTableLikeDesc.getDefaultOutputFormat() |
Map<String,String> |
CreateTableLikeDesc.getDefaultSerdeProps() |
String |
CreateTableLikeDesc.getDefaultSerName() |
Map<org.apache.hadoop.hive.ql.plan.SparkWork.ComparableName,List<SparkWork.Dependency>> |
SparkWork.getDependencyMap() |
Map<String,List<TezWork.Dependency>> |
TezWork.getDependencyMap() |
DescFunctionDesc |
DDLWork.getDescFunctionDesc() |
DescTableDesc |
DDLWork.getDescTblDesc() |
int |
FileSinkDesc.getDestTableId() |
org.apache.hadoop.fs.Path |
FileSinkDesc.getDirName() |
String |
FileSinkDesc.getDpSortStateString() |
DropTableDesc |
DDLWork.getDropTblDesc() |
List<String> |
ReduceWork.ReduceExplainVectorization.getEnableConditionsMet() |
List<String> |
ReduceWork.ReduceExplainVectorization.getEnableConditionsNotMet() |
String |
PTFDesc.PTFOperatorExplainVectorization.getEvaluatorClasses() |
String |
ReduceWork.getExecutionMode() |
String |
MapWork.getExecutionMode() |
String |
ExprNodeDesc.getExprStringForExplain() |
String |
CreateTableDesc.getFieldDelim() |
String |
CreateTableDesc.getFieldEscape() |
FileSinkDesc.FileSinkOperatorExplainVectorization |
FileSinkDesc.getFileSinkVectorization() |
String |
TableScanDesc.getFilterExprString() |
Map<Integer,String> |
HashTableSinkDesc.getFilterMapString() |
Map<Integer,String> |
JoinDesc.getFilterMapString() |
Map<String,String> |
JoinDesc.getFiltersStringMap()
Get the string representation of filters.
|
FilterDesc.FilterOperatorExplainVectorization |
FilterDesc.getFilterVectorization() |
org.apache.hadoop.fs.Path |
CopyWork.getFromPathExplain() |
org.apache.hadoop.fs.Path[] |
CopyWork.getFromPathsExplain() |
List<PTFInputDef> |
PTFDesc.getFuncDefExplain() |
String |
PTFDesc.PTFOperatorExplainVectorization.getFunctionInputExpressions() |
String |
CreateFunctionDesc.getFunctionName() |
String |
DropFunctionDesc.getFunctionName() |
String |
PTFDesc.PTFOperatorExplainVectorization.getFunctionNames() |
boolean |
GrantRevokeRoleDDL.getGrant() |
String |
GroupByDesc.GroupByOperatorExplainVectorization.getGroupByMode() |
GroupByDesc.GroupByOperatorExplainVectorization |
GroupByDesc.getGroupByVectorization() |
boolean |
JoinDesc.getHandleSkewJoin() |
SparkHashTableSinkDesc.SparkHashTableSinkOperatorExplainVectorization |
SparkHashTableSinkDesc.getHashTableSinkVectorization() |
PrivilegeObjectDesc |
ShowGrantDesc.getHiveObj() |
boolean |
DropDatabaseDesc.getIfExists() |
boolean |
CreateTableDesc.getIfNotExists() |
boolean |
CreateViewDesc.getIfNotExists() |
boolean |
CreateDatabaseDesc.getIfNotExists() |
boolean |
CreateTableLikeDesc.getIfNotExists() |
String |
TableScanDesc.getIncludedBucketExplain() |
String |
TableDesc.getInputFileFormatClassName() |
String |
PartitionDesc.getInputFileFormatClassName() |
String |
CreateTableDesc.getInputFormat() |
String |
AlterTableDesc.getInputFormat() |
String |
MapWork.MapExplainVectorization.getInputFormatSupport() |
String |
AppMasterEventDesc.getInputName() |
InsertCommitHookDesc |
DDLWork.getInsertCommitHookDesc() |
boolean |
CreateViewDesc.getIsAlterViewAs() |
boolean |
LoadFileDesc.getIsDfsDir() |
boolean |
LoadMultiFilesDesc.getIsDfsDir() |
boolean |
FilterDesc.getIsSamplingPred() |
Map<String,String> |
TableDesc.getJobProperties() |
String |
JoinCondDesc.getJoinCondString() |
String |
ReduceSinkDesc.getKeyColString() |
String |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization.getKeyColumnNums() |
String |
MapJoinDesc.getKeyCountsExplainDesc() |
List<String> |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization.getKeyExpression() |
String |
PTFDesc.PTFOperatorExplainVectorization.getKeyInputColumns() |
List<String> |
GroupByDesc.GroupByOperatorExplainVectorization.getKeysExpression() |
Map<String,String> |
MapJoinDesc.getKeysString() |
Map<String,String> |
HashTableSinkDesc.getKeysString() |
Map<String,String> |
JoinDesc.getKeysString() |
String |
GroupByDesc.getKeyString() |
KillQueryDesc |
DDLWork.getKillQueryDesc() |
String |
CreateTableLikeDesc.getLikeTableName() |
int |
LimitDesc.getLimit() |
int |
FetchWork.getLimit() |
LimitDesc.LimitOperatorExplainVectorization |
LimitDesc.getLimitVectorization() |
String |
CreateTableDesc.getLineDelim() |
String |
MapWork.getLlapIoDescString() |
String |
PTFDesc.getLlInfoExplain() |
LoadFileDesc |
MoveWork.getLoadFileWork() |
LoadMultiFilesDesc |
MoveWork.getLoadMultiFilesWork() |
LoadTableDesc |
MoveWork.getLoadTableWork() |
String |
CreateTableDesc.getLocation() |
String |
AlterDatabaseDesc.getLocation() |
String |
CreateTableLikeDesc.getLocation() |
String |
AddPartitionDesc.getLocationForExplain() |
String |
CreateDatabaseDesc.getLocationUri() |
LockTableDesc |
DDLWork.getLockTblDesc() |
String |
DropMacroDesc.getMacroName() |
String |
CreateMacroDesc.getMacroName() |
BaseWork |
MergeJoinWork.getMainWork() |
FetchWork.FetchExplainVectorization |
FetchWork.getMapExplainVectorization() |
MapWork.MapExplainVectorization |
MapWork.getMapExplainVectorization() |
MapJoinDesc.MapJoinOperatorExplainVectorization |
MapJoinDesc.getMapJoinVectorization() |
String |
CreateTableDesc.getMapKeyDelim() |
WMMapping |
CreateOrAlterWMMappingDesc.getMapping() |
WMMapping |
DropWMMappingDesc.getMapping() |
MapredLocalWork |
BaseWork.getMapRedLocalWork() |
MapWork |
MapredWork.getMapWork() |
String |
AlterMaterializedViewDesc.getMaterializedViewName() |
String |
GroupByDesc.getModeString() |
String |
RoleDDLDesc.getName() |
String |
SparkWork.getName() |
String |
SparkWork.Dependency.getName() |
String |
PrincipalDesc.getName() |
String |
TezWork.getName() |
String |
TezWork.Dependency.getName() |
String |
UnionWork.getName() |
String |
CreateDatabaseDesc.getName() |
String |
DescFunctionDesc.getName() |
HashMap<String,SplitSample> |
MapWork.getNameToSplitSample() |
boolean |
OperatorExplainVectorization.getNative() |
List<String> |
MapJoinDesc.MapJoinOperatorExplainVectorization.getNativeConditionsMet() |
List<String> |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization.getNativeConditionsMet() |
List<String> |
MapJoinDesc.MapJoinOperatorExplainVectorization.getNativeConditionsNotMet() |
List<String> |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization.getNativeConditionsNotMet() |
List<String> |
MapJoinDesc.MapJoinOperatorExplainVectorization.getNativeNotSupportedKeyTypes() |
String |
BaseWork.BaseExplainVectorization.RowBatchContextExplainVectorization.getNeededVirtualColumns() |
boolean |
ReduceWork.getNeedsTagging() |
List<String> |
AlterTableDesc.getNewColsString() |
String |
AlterTableDesc.getNewName() |
String |
PTFDesc.PTFOperatorExplainVectorization.getNonKeyInputColumns() |
String |
ReduceSinkDesc.getNullOrder()
Returns the null order in the key columns.
|
String |
JoinDesc.getNullSafeString() |
Integer |
CreateTableDesc.getNumBucketsExplain() |
int |
FileSinkDesc.getNumFiles() |
String |
SparkWork.Dependency.getNumPartitions() |
String |
PrivilegeObjectDesc.getObject() |
Integer |
LimitDesc.getOffset()
not to print the offset if it is 0 we need to turn null.
|
String |
AlterTableDesc.getOldName() |
RoleDDLDesc.RoleOperation |
RoleDDLDesc.getOperation() |
Map<String,String> |
TableScanDesc.getOpProps() |
String |
AlterMaterializedViewDesc.getOpString() |
String |
ReduceSinkDesc.getOrder()
Returns the sort order of the key columns.
|
String |
PTFDesc.PTFOperatorExplainVectorization.getOrderExpressions() |
ArrayList<String> |
GroupByDesc.getOutputColumnNames() |
List<String> |
SelectDesc.getOutputColumnNames() |
List<String> |
TableScanDesc.getOutputColumnNames() |
List<String> |
JoinDesc.getOutputColumnNames() |
String |
PTFDesc.PTFOperatorExplainVectorization.getOutputColumns() |
String |
TableDesc.getOutputFileFormatClassName() |
String |
PartitionDesc.getOutputFileFormatClassName() |
String |
CreateTableDesc.getOutputFormat() |
String |
AlterTableDesc.getOutputFormat() |
ArrayList<String> |
LateralViewJoinDesc.getOutputInternalColNames() |
String |
ReduceSinkDesc.getOutputName() |
String |
PTFDesc.PTFOperatorExplainVectorization.getOutputTypes() |
PrincipalDesc |
AlterDatabaseDesc.getOwnerPrincipal() |
PrincipalDesc |
AlterTableDesc.getOwnerPrincipal() |
Map<Integer,String> |
MapJoinDesc.getParentToInput() |
String |
ReduceSinkDesc.getParitionColsString() |
List<String> |
CreateTableDesc.getPartColsString() |
List<String> |
CreateViewDesc.getPartColsString() |
ArrayList<PartitionDesc> |
FetchWork.getPartDescOrderedByPartDir()
Get Partition descriptors in sorted (ascending) order of partition directory
|
int |
BaseWork.BaseExplainVectorization.RowBatchContextExplainVectorization.getPartitionColumnCount() |
String |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization.getPartitionColumnNums() |
List<String> |
BaseWork.BaseExplainVectorization.RowBatchContextExplainVectorization.getPartitionColumns() |
String |
PTFDesc.PTFOperatorExplainVectorization.getPartitionExpressions() |
Map<String,String> |
LoadTableDesc.getPartitionSpec() |
String |
DynamicPruningEventDesc.getPartKeyString() |
HashMap<String,String> |
ShowLocksDesc.getPartSpec() |
Map<String,String> |
DescTableDesc.getPartSpec() |
Map<String,String> |
TruncateTableDesc.getPartSpec() |
HashMap<String,String> |
ShowTableStatusDesc.getPartSpec() |
LinkedHashMap<String,String> |
PartitionDesc.getPartSpec() |
Map<String,String> |
ShowPartitionsDesc.getPartSpec() |
HashMap<String,String> |
PrivilegeObjectDesc.getPartSpec() |
String |
AddPartitionDesc.getPartSpecStringForExplain() |
LinkedHashMap<org.apache.hadoop.fs.Path,ArrayList<String>> |
MapWork.getPathToAliases() |
LinkedHashMap<org.apache.hadoop.fs.Path,PartitionDesc> |
MapWork.getPathToPartitionInfo() |
String |
ShowTableStatusDesc.getPattern() |
String |
ShowColumnsDesc.getPattern() |
String |
ShowDatabasesDesc.getPattern() |
String |
ShowFunctionsDesc.getPattern() |
String |
ShowTablesDesc.getPattern() |
Object |
CreateOrAlterWMPoolDesc.getPool() |
String |
CreateOrAlterWMPoolDesc.getPoolPath() |
String |
CreateOrDropTriggerToPoolMappingDesc.getPoolPathForExplain() |
int |
MapJoinDesc.getPosBigTable() |
int |
HashTableSinkDesc.getPosBigTable() |
String |
FilterDesc.FilterOperatorExplainVectorization.getPredicateExpression() |
String |
FilterDesc.getPredicateString(boolean postProcess) |
PreInsertTableDesc |
DDLWork.getPreInsertTableDesc() |
List<PrincipalDesc> |
GrantRevokeRoleDDL.getPrincipalDesc() |
PrincipalDesc |
ShowGrantDesc.getPrincipalDesc() |
List<PrincipalDesc> |
GrantDesc.getPrincipals() |
Privilege |
PrivilegeDesc.getPrivilege() |
List<PrivilegeDesc> |
GrantDesc.getPrivileges() |
PrivilegeObjectDesc |
GrantDesc.getPrivilegeSubjectDesc() |
String |
GroupByDesc.GroupByOperatorExplainVectorization.getProcessingMode() |
String |
MapJoinDesc.MapJoinOperatorExplainVectorization.getProjectedOutputColumnNums() |
String |
GroupByDesc.GroupByOperatorExplainVectorization.getProjectedOutputColumnNums() |
String |
SelectDesc.SelectOperatorExplainVectorization.getProjectedOutputColumnNums() |
Map |
TableDesc.getPropertiesExplain() |
Map |
PartitionDesc.getPropertiesExplain() |
String |
ShowTblPropertiesDesc.getPropertyName() |
HashMap<String,String> |
AlterTableDesc.getProps() |
List<String> |
TableScanDesc.getPrunedColumnPaths() |
PTFDesc.PTFOperatorExplainVectorization |
PTFDesc.getPTFVectorization() |
List<String> |
KillQueryDesc.getQueryIds() |
String |
ReduceWork.ReduceExplainVectorization.getReduceColumnNullOrder() |
String |
ReduceWork.ReduceExplainVectorization.getReduceColumnSortOrder() |
ReduceWork.ReduceExplainVectorization |
ReduceWork.getReduceExplainVectorization() |
Operator<?> |
ReduceWork.getReducer() |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization |
ReduceSinkDesc.getReduceSinkVectorization() |
ReduceWork |
MapredWork.getReduceWork() |
boolean |
LoadTableDesc.getReplace() |
String |
ShowLocksDesc.getResFile() |
String |
DescTableDesc.getResFile() |
String |
DescDatabaseDesc.getResFile() |
String |
ShowColumnsDesc.getResFile() |
String |
ShowDatabasesDesc.getResFile() |
String |
ShowCreateDatabaseDesc.getResFile() |
String |
AlterResourcePlanDesc.getResFile() |
String |
ShowFunctionsDesc.getResFile() |
org.apache.hadoop.fs.Path |
ShowConfDesc.getResFile() |
String |
ShowResourcePlanDesc.getResFile() |
String |
ShowPartitionsDesc.getResFile() |
String |
DescFunctionDesc.getResFile() |
String |
ShowTablesDesc.getResFile() |
String |
ShowCreateTableDesc.getResFile() |
String |
ShowTblPropertiesDesc.getResFileString() |
String |
ShowTableStatusDesc.getResFileString() |
String |
JoinDesc.getResidualFilterExprsString() |
WMNullableResourcePlan |
AlterResourcePlanDesc.getResourcePlan() |
WMResourcePlan |
CreateResourcePlanDesc.getResourcePlan() |
String |
AlterResourcePlanDesc.getResourcePlanName() |
String |
CreateOrDropTriggerToPoolMappingDesc.getResourcePlanName() |
String |
ShowResourcePlanDesc.getResourcePlanName() |
List<String> |
GrantRevokeRoleDDL.getRoles() |
Integer |
TableScanDesc.getRowLimitExplain() |
String |
DropWMTriggerDesc.getRpName() |
String |
DropResourcePlanDesc.getRpName() |
String |
FilterDesc.getSampleDescExpr() |
String |
MapWork.getSamplingTypeString() |
String |
TableScanDesc.TableScanOperatorExplainVectorization.getSchemaColumns() |
List<String> |
CreateViewDesc.getSchemaString() |
String |
BaseWork.BaseExplainVectorization.RowBatchContextExplainVectorization.getScratchColumnTypeNames() |
String |
ScriptDesc.getScriptCmd() |
TableDesc |
ScriptDesc.getScriptOutputInfo() |
List<String> |
SelectDesc.SelectOperatorExplainVectorization.getSelectExpressions() |
SelectDesc.SelectOperatorExplainVectorization |
SelectDesc.getSelectVectorization() |
String |
TableDesc.getSerdeClassName() |
String |
PartitionDesc.getSerdeClassName() |
String |
AlterTableDesc.getSerdeName() |
Map<String,String> |
CreateTableDesc.getSerdeProps() |
String |
CreateTableDesc.getSerName() |
ShowColumnsDesc |
DDLWork.getShowColumnsDesc() |
ShowCompactionsDesc |
DDLWork.getShowCompactionsDesc() |
ShowCreateDatabaseDesc |
DDLWork.getShowCreateDbDesc() |
ShowCreateTableDesc |
DDLWork.getShowCreateTblDesc() |
ShowDatabasesDesc |
DDLWork.getShowDatabasesDesc() |
ShowFunctionsDesc |
DDLWork.getShowFuncsDesc() |
ShowLocksDesc |
DDLWork.getShowLocksDesc() |
ShowPartitionsDesc |
DDLWork.getShowPartsDesc() |
ShowResourcePlanDesc |
DDLWork.getShowResourcePlanDesc() |
ShowTablesDesc |
DDLWork.getShowTblsDesc() |
ShowTxnsDesc |
DDLWork.getShowTxnsDesc() |
String |
SparkWork.Dependency.getShuffleType() |
String |
SparkEdgeProperty.getShuffleType() |
String |
MapJoinDesc.MapJoinOperatorExplainVectorization.getSmallTableColumns() |
MapJoinDesc.SMBJoinOperatorExplainVectorization |
MapJoinDesc.getSMBJoinVectorization() |
List<Order> |
CreateTableDesc.getSortCols() |
Map<String,List<BucketingSortingCtx.SortCol>> |
MapWork.getSortedColsByDirectory() |
Operator<?> |
FetchWork.getSource() |
List<org.apache.hadoop.fs.Path> |
LoadMultiFilesDesc.getSourceDirs() |
org.apache.hadoop.fs.Path |
LoadDesc.getSourcePath() |
String |
FileSinkDesc.getStaticSpec() |
Statistics |
AbstractOperatorDesc.getStatistics() |
String |
FileSinkDesc.getStatsAggPrefix()
Construct the key prefix used as (intermediate) statistics publishing
and aggregation.
|
String |
TableScanDesc.getStatsAggPrefix() |
String |
CreateTableDesc.getStorageHandler() |
String |
AlterTableDesc.getStorageHandler() |
String |
PTFDesc.PTFOperatorExplainVectorization.getStreamingColumns() |
String |
MapWork.MapExplainVectorization.getSupportRemovedReasons() |
TableDesc |
LoadTableDesc.getTable() |
boolean |
PrivilegeObjectDesc.getTable() |
TableDesc |
PartitionDesc.getTableDesc() |
TableDesc |
FileSinkDesc.getTableInfo() |
String |
ShowTblPropertiesDesc.getTableName() |
String |
ShowLocksDesc.getTableName() |
String |
DescTableDesc.getTableName() |
String |
TruncateTableDesc.getTableName() |
String |
CreateTableDesc.getTableName() |
String |
ShowColumnsDesc.getTableName() |
String |
TableDesc.getTableName() |
String |
DropTableDesc.getTableName() |
String |
ColumnStatsDesc.getTableName() |
String |
CreateTableLikeDesc.getTableName() |
String |
PartitionDesc.getTableName() |
String |
TableScanDesc.getTableName() |
String |
ShowCreateTableDesc.getTableName() |
TableScanDesc.TableScanOperatorExplainVectorization |
TableScanDesc.getTableScanVectorization() |
String |
ShowPartitionsDesc.getTabName() |
int |
BaseWork.getTag() |
int |
ReduceSinkDesc.getTag() |
Map<Integer,String> |
ReduceWork.getTagToInput() |
org.apache.hadoop.fs.Path |
LoadFileDesc.getTargetDir() |
List<org.apache.hadoop.fs.Path> |
LoadMultiFilesDesc.getTargetDirs() |
String |
TableScanDesc.getTbl() |
Map<String,String> |
CreateTableDesc.getTblProps() |
Map<String,String> |
CreateViewDesc.getTblProps() |
Map<String,String> |
CreateTableLikeDesc.getTblProps() |
org.apache.hadoop.fs.Path |
CopyWork.getToPathExplain() |
org.apache.hadoop.fs.Path[] |
CopyWork.getToPathsExplain() |
Integer |
ReduceSinkDesc.getTopNExplain() |
Float |
ReduceSinkDesc.getTopNMemoryUsageExplain() |
int |
FileSinkDesc.getTotalFiles() |
WMTrigger |
CreateWMTriggerDesc.getTrigger() |
WMTrigger |
AlterWMTriggerDesc.getTrigger() |
String |
DropWMTriggerDesc.getTriggerName() |
String |
CreateOrDropTriggerToPoolMappingDesc.getTriggerName() |
Map<String,ArrayList<String>> |
MapWork.getTruncatedPathToAliases()
This is used to display and verify output of "Path -> Alias" in test framework.
|
TruncateTableDesc |
DDLWork.getTruncateTblDesc() |
PrincipalType |
PrincipalDesc.getType() |
String |
TezWork.Dependency.getType() |
TableType |
ShowTablesDesc.getType() |
String |
UDTFDesc.getUDTFName() |
UnlockTableDesc |
DDLWork.getUnlockTblDesc() |
Map<Byte,String> |
MapJoinDesc.getUserLevelExplainKeysString() |
Map<Byte,String> |
HashTableSinkDesc.getUserLevelExplainKeysString() |
Map<Byte,String> |
JoinDesc.getUserLevelExplainKeysString() |
String |
GroupByDesc.getUserLevelExplainKeyString() |
ArrayList<String> |
GroupByDesc.getUserLevelExplainOutputColumnNames() |
List<String> |
SelectDesc.getUserLevelExplainOutputColumnNames() |
List<String> |
JoinDesc.getUserLevelExplainOutputColumnNames() |
ArrayList<String> |
LateralViewJoinDesc.getUserLevelExplainOutputInternalColNames() |
String |
ReduceSinkDesc.getUserLevelExplainParitionColsString() |
String |
FilterDesc.getUserLevelExplainPredicateString(boolean postProcess) |
String |
JoinCondDesc.getUserLevelJoinCondString() |
String |
AbstractOperatorDesc.getUserLevelStatistics() |
String |
ReduceSinkDesc.getValueColsString() |
String |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization.getValueColumnNums() |
List<String> |
ReduceSinkDesc.ReduceSinkOperatorExplainVectorization.getValueExpression() |
String |
MapWork.MapExplainVectorization.getVectorizationSupportInUse() |
List<String> |
GroupByDesc.GroupByOperatorExplainVectorization.getVectorOutputConditionsNotMet() |
String |
AppMasterEventDesc.getVertexName() |
String |
CreateViewDesc.getViewExpandedText() |
String |
CreateViewDesc.getViewName() |
String |
CreateViewDesc.getViewOriginalText() |
Map<String,BaseWork> |
SparkWork.getWorkMap() |
Map<String,BaseWork> |
TezWork.getWorkMap()
getWorkMap returns a map of "vertex name" to BaseWork
|
String |
FileSinkDesc.getWriteTypeString() |
String |
LoadDesc.getWriteTypeString() |
Set<String> |
MapWork.MapExplainVectorization.inputFileFormats() |
boolean |
ReduceSinkDesc.isAutoParallel() |
boolean |
MapJoinDesc.isBucketMapJoin() |
boolean |
FetchWork.isCachedResult() |
boolean |
CreateTableDesc.isExternal() |
boolean |
CreateTableLikeDesc.isExternal() |
boolean |
FileSinkDesc.isGatherStats() |
boolean |
TableScanDesc.isGatherStats() |
boolean |
GrantDesc.isGrantOption() |
boolean |
MapJoinDesc.isHybridHashJoin() |
boolean |
PTFDesc.isMapSide() |
boolean |
CreateTableDesc.isMaterialization() |
Boolean |
LoadTableDesc.isMmTableExplain() |
boolean |
FileSinkDesc.isMultiFileSpray() |
String |
UDTFDesc.isOuterLateralView() |
boolean |
ReduceSinkDesc.isQuickStart() |
boolean |
CreateViewDesc.isReplace() |
boolean |
CreateViewDesc.isRewriteEnabled() |
boolean |
ColumnStatsDesc.isTblLevel() |
boolean |
CreateTableDesc.isTemporary() |
boolean |
CreateTableLikeDesc.isTemporary() |
boolean |
TableScanDesc.isTemporary() |
boolean |
CreateOrAlterWMMappingDesc.isUpdate() |
boolean |
CreateOrAlterWMPoolDesc.isUpdate() |
Boolean |
BaseWork.BaseExplainVectorization.nativeVectorized() |
String |
BaseWork.BaseExplainVectorization.notVectorizedReason() |
boolean |
GroupByDesc.pruneGroupingSetId() |
boolean |
CreateOrDropTriggerToPoolMappingDesc.shouldDrop() |
boolean |
AlterResourcePlanDesc.shouldValidate() |
String |
Statistics.toString() |
String |
Statistics.toUserLevelExplainString() |
Boolean |
BaseWork.BaseExplainVectorization.usesVectorUDFAdaptor() |
Boolean |
BaseWork.BaseExplainVectorization.vectorized() |
BaseWork.BaseExplainVectorization.RowBatchContextExplainVectorization |
BaseWork.BaseExplainVectorization.vectorizedRowBatchContext() |
Modifier and Type | Class and Description |
---|---|
class |
PartitionedTableFunctionDef |
class |
PTFQueryInputDef |
class |
WindowFunctionDef |
class |
WindowTableFunctionDef |
Modifier and Type | Method and Description |
---|---|
String |
WindowExpressionDef.getAlias() |
String |
PTFInputDef.getAlias() |
String |
PartitionedTableFunctionDef.getArgsExplain() |
String |
WindowFunctionDef.getArgsExplain() |
String |
PTFQueryInputDef.getDestination() |
String |
PTFExpressionDef.getExprNodeExplain() |
String |
PartitionedTableFunctionDef.getName() |
String |
WindowFunctionDef.getName() |
String |
PartitionedTableFunctionDef.getOrderExplain() |
String |
PTFInputDef.getOutputShapeExplain() |
String |
PartitionedTableFunctionDef.getPartitionExplain() |
ShapeDetails |
PartitionedTableFunctionDef.getRawInputShapeExplain() |
List<String> |
PartitionedTableFunctionDef.getReferencedColumns() |
String |
PTFQueryInputDef.getTypeExplain() |
String |
WindowFunctionDef.getWFnEvalExplain() |
String |
WindowFunctionDef.getWindowFrameExplain() |
List<WindowFunctionDef> |
WindowTableFunctionDef.getWindowFunctions() |
boolean |
WindowFunctionDef.isDistinct() |
boolean |
WindowFunctionDef.isPivotResult() |
boolean |
WindowFunctionDef.isStar() |
boolean |
PartitionedTableFunctionDef.isTransformsRawInput() |
Copyright © 2022 The Apache Software Foundation. All rights reserved.