This is an automated email from the ASF dual-hosted git repository.
kgyrtkirk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git.
from 8eefac7 HIVE-21558: Query based compaction fails if the temporary FS
is different than the table FS (Peter Vary reviewed Marta Kuczora)
new 80a323f HIVE-21523: Break up DDLTask - extract View related
operations (Miklos Gergely via Zoltan Haindrich)
new 4da9d05 HIVE-21425: Use DirectExecutorService for getInputSummary
(David Mollitor via Zoltan Haindrich)
new 2fcde8e HIVE-16815: Clean up javadoc from error for the rest of
modules (Robert Kucsora via Zoltan Haindrich)
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../predicate/AccumuloPredicateHandler.java | 4 +-
.../accumulo/serde/AccumuloCompositeRowId.java | 10 +-
.../java/org/apache/hive/http/ProfileServlet.java | 4 +-
.../apache/hadoop/hive/contrib/mr/GenericMR.java | 2 +-
.../hadoop/hive/contrib/serde2/RegexSerDe.java | 4 +-
.../hive/contrib/udaf/example/UDAFExampleAvg.java | 2 +-
.../hadoop/hive/hbase/HBaseCompositeKey.java | 9 +-
.../org/apache/hadoop/hive/hbase/HBaseSerDe.java | 2 +-
.../hadoop/hive/hbase/struct/HBaseStructValue.java | 9 +-
.../hive/hbase/struct/HBaseValueFactory.java | 4 +-
.../apache/hive/hcatalog/common/HCatConstants.java | 2 +-
.../org/apache/hive/hcatalog/common/HCatUtil.java | 14 +-
.../hive/hcatalog/data/transfer/HCatWriter.java | 6 +-
.../hcatalog/listener/NotificationListener.java | 4 +-
.../hcatalog/streaming/AbstractRecordWriter.java | 2 +-
.../hcatalog/streaming/DelimitedInputWriter.java | 4 +-
.../hive/hcatalog/streaming/HiveEndPoint.java | 2 +-
.../hive/hcatalog/streaming/RecordWriter.java | 2 +-
.../hcatalog/streaming/StreamingConnection.java | 2 +-
.../hive/hcatalog/streaming/StrictJsonWriter.java | 2 +-
.../hive/hcatalog/streaming/StrictRegexWriter.java | 2 +-
.../hive/hcatalog/streaming/TransactionBatch.java | 2 +-
.../mutate/worker/MutatorCoordinator.java | 2 +-
.../org/apache/hive/hcatalog/api/HCatClient.java | 27 ++--
.../hive/hcatalog/api/repl/ReplicationTask.java | 12 +-
.../src/main/java/org/apache/hive/hplsql/Meta.java | 2 +-
.../main/java/org/apache/hive/hplsql/Utils.java | 4 +-
.../src/main/java/org/apache/hive/hplsql/Var.java | 2 +-
jdbc/src/java/org/apache/hive/jdbc/Utils.java | 4 +-
.../java/org/apache/hadoop/hive/llap/LlapDump.java | 3 +-
.../apache/hadoop/hive/llap/ConsumerFeedback.java | 2 +-
.../hadoop/hive/llap/cache/LowLevelCache.java | 2 +-
.../llap/daemon/impl/PriorityBlockingDeque.java | 42 +++---
.../hive/llap/daemon/impl/TaskExecutorService.java | 6 +-
.../hive/llap/daemon/impl/TaskRunnerCallable.java | 2 +-
.../hive/llap/metrics/LlapDaemonJvmInfo.java | 2 +-
.../AlterMaterializedViewDesc.java} | 32 +++--
.../alter/AlterMaterializedViewRewriteDesc.java} | 83 ++---------
.../AlterMaterializedViewRewriteOperation.java | 86 +++++++++++
.../hadoop/hive/ql/ddl/alter}/package-info.java | 7 +-
.../ql/{plan => ddl/table}/CreateViewDesc.java | 98 +++++--------
.../hive/ql/ddl/table/CreateViewOperation.java | 117 +++++++++++++++
.../org/apache/hadoop/hive/ql/exec/DDLTask.java | 160 ---------------------
.../org/apache/hadoop/hive/ql/exec/Utilities.java | 47 +++---
.../hadoop/hive/ql/parse/DDLSemanticAnalyzer.java | 13 +-
.../apache/hadoop/hive/ql/parse/ParseContext.java | 2 +-
.../java/org/apache/hadoop/hive/ql/parse/QB.java | 2 +-
.../hadoop/hive/ql/parse/SemanticAnalyzer.java | 5 +-
.../apache/hadoop/hive/ql/parse/TaskCompiler.java | 50 ++++---
.../org/apache/hadoop/hive/ql/plan/DDLWork.java | 44 ------
.../hadoop/hive/ql/plan/ImportTableDesc.java | 3 +-
.../apache/hadoop/hive/ql/plan/LoadFileDesc.java | 1 +
.../org/apache/hadoop/hive/ql/plan/PlanUtils.java | 1 +
.../clientnegative/create_view_failure1.q.out | 2 +-
.../clientnegative/create_view_failure4.q.out | 2 +-
.../test/results/clientnegative/masking_mv.q.out | 13 +-
.../materialized_view_no_cbo_rewrite_2.q.out | 2 +-
...terialized_view_no_supported_op_rewrite_2.q.out | 2 +-
.../beeline/materialized_view_create_rewrite.q.out | 7 +-
.../test/results/clientpositive/create_view.q.out | 11 +-
.../clientpositive/create_view_translate.q.out | 11 +-
.../test/results/clientpositive/explain_ddl.q.out | 11 +-
.../clientpositive/llap/explainuser_1.q.out | 6 +-
.../llap/materialized_view_create_rewrite.q.out | 7 +-
.../llap/materialized_view_create_rewrite_3.q.out | 13 +-
.../llap/materialized_view_create_rewrite_4.q.out | 22 ++-
.../materialized_view_create_rewrite_dummy.q.out | 7 +-
...ialized_view_create_rewrite_rebuild_dummy.q.out | 13 +-
...erialized_view_create_rewrite_time_window.q.out | 22 ++-
.../llap/materialized_view_partitioned.q.out | 15 +-
.../llap/materialized_view_partitioned_3.q.out | 15 +-
.../clientpositive/llap/selectDistinctStar.q.out | 22 ++-
.../clientpositive/llap/union_top_level.q.out | 11 +-
.../clientpositive/llap/vector_windowing.q.out | 26 ++--
.../test/results/clientpositive/masking_mv.q.out | 26 ++--
.../clientpositive/spark/spark_explainuser_1.q.out | 6 +-
.../clientpositive/spark/union_top_level.q.out | 11 +-
.../clientpositive/tez/explainanalyze_3.q.out | 4 +-
.../results/clientpositive/tez/explainuser_3.q.out | 4 +-
.../teradata/TeradataBinaryDataInputStream.java | 6 +-
.../teradata/TeradataBinaryDataOutputStream.java | 6 +-
.../src/java/org/apache/hive/service/Service.java | 2 +-
.../org/apache/hive/service/ServiceOperations.java | 10 +-
.../apache/hive/service/auth/HttpAuthUtils.java | 2 +-
.../service/auth/PasswdAuthenticationProvider.java | 2 +-
.../hive/service/auth/TSetIpAddressProcessor.java | 4 +-
.../auth/ldap/CustomQueryFilterFactory.java | 2 +-
.../hive/service/auth/ldap/GroupFilterFactory.java | 2 +-
.../apache/hive/service/auth/ldap/LdapUtils.java | 12 +-
.../service/auth/ldap/SearchResultHandler.java | 2 +-
.../hive/service/auth/ldap/UserFilterFactory.java | 2 +-
.../apache/hive/service/cli/CLIServiceUtils.java | 2 +-
.../cli/operation/ClassicTableTypeMapping.java | 6 +-
.../service/cli/operation/TableTypeMapping.java | 2 +-
.../server/ThreadFactoryWithGarbageCleanup.java | 6 +-
.../apache/hadoop/hive/metastore/HiveMetaHook.java | 2 +-
.../hadoop/hive/metastore/IMetaStoreClient.java | 7 +-
.../apache/hadoop/hive/metastore/Warehouse.java | 2 +-
.../hadoop/hive/metastore/utils/FilterUtils.java | 1 -
.../apache/hadoop/hive/metastore/AlterHandler.java | 10 +-
.../MaterializationsRebuildLockHandler.java | 9 +-
.../hadoop/hive/metastore/PartitionIterable.java | 6 +-
.../org/apache/hadoop/hive/metastore/RawStore.java | 10 +-
.../hadoop/hive/metastore/events/OpenTxnEvent.java | 2 +-
.../hadoop/hive/metastore/txn/CompactionInfo.java | 2 +-
.../apache/hadoop/hive/metastore/txn/TxnUtils.java | 6 +-
.../hadoop/hive/common/io/FileMetadataCache.java | 2 -
.../hive/streaming/HiveStreamingConnection.java | 4 +-
.../hive/streaming/StreamingTransaction.java | 2 +-
.../hive/testutils/jdbc/HiveBurnInClient.java | 2 +-
110 files changed, 620 insertions(+), 763 deletions(-)
copy
ql/src/java/org/apache/hadoop/hive/ql/ddl/{database/SwitchDatabaseDesc.java =>
alter/AlterMaterializedViewDesc.java} (60%)
rename
ql/src/java/org/apache/hadoop/hive/ql/{plan/AlterMaterializedViewDesc.java =>
ddl/alter/AlterMaterializedViewRewriteDesc.java} (52%)
create mode 100644
ql/src/java/org/apache/hadoop/hive/ql/ddl/alter/AlterMaterializedViewRewriteOperation.java
copy {druid-handler/src/java/org/apache/hadoop/hive/druid =>
ql/src/java/org/apache/hadoop/hive/ql/ddl/alter}/package-info.java (88%)
rename ql/src/java/org/apache/hadoop/hive/ql/{plan =>
ddl/table}/CreateViewDesc.java (87%)
create mode 100644
ql/src/java/org/apache/hadoop/hive/ql/ddl/table/CreateViewOperation.java
