This is an automated email from the ASF dual-hosted git repository.
krisztiankasa pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git.
from 9380c08 HIVE-24919. Optimise AddPartition replication call. (#2098)
(Ayush Saxena, reviewed by Aasha Medhi)
add cc0a707 HIVE-24855: Introduce virtual colum ROW__IS__DELETED
(Krisztian Kasa, reviewed by Jesus Camacho Rodriguez)
No new revisions were added by this update.
Summary of changes:
.../org/apache/hadoop/hive/conf/Constants.java | 2 +
.../hive/llap/io/api/impl/LlapInputFormat.java | 27 +-
.../org/apache/hadoop/hive/ql/exec/FetchTask.java | 2 +-
.../apache/hadoop/hive/ql/exec/MapOperator.java | 5 +
.../hadoop/hive/ql/exec/SMBMapJoinOperator.java | 2 +-
.../hadoop/hive/ql/exec/mr/MapredLocalTask.java | 2 +-
.../apache/hadoop/hive/ql/io/AcidInputFormat.java | 5 +-
.../org/apache/hadoop/hive/ql/io/AcidUtils.java | 10 +-
.../apache/hadoop/hive/ql/io/BatchToRowReader.java | 66 +-
.../hive/ql/io/HiveContextAwareRecordReader.java | 6 +-
.../apache/hadoop/hive/ql/io/HiveInputFormat.java | 4 +-
.../org/apache/hadoop/hive/ql/io/IOContext.java | 9 +
.../hadoop/hive/ql/io/orc/OrcInputFormat.java | 120 ++--
.../hive/ql/io/orc/OrcOiBatchToRowReader.java | 45 +-
.../hadoop/hive/ql/io/orc/OrcRawRecordMerger.java | 20 +-
.../hadoop/hive/ql/metadata/VirtualColumn.java | 2 +
.../hadoop/hive/ql/parse/SemanticAnalyzer.java | 4 +
.../apache/hadoop/hive/ql/plan/TableScanDesc.java | 10 +
.../hive/ql/io/orc/TestInputOutputFormat.java | 4 +-
.../queries/clientpositive/fetch_deleted_rows.q | 48 ++
.../queries/clientpositive/masking_mv_by_text.q | 2 +-
.../results/clientnegative/udf_assert_true.q.out | 16 +-
.../results/clientnegative/udf_assert_true2.q.out | 8 +-
.../beeline/materialized_view_create_rewrite.q.out | 4 +-
.../clientpositive/beeline/smb_mapjoin_1.q.out | 32 +-
.../clientpositive/beeline/smb_mapjoin_10.q.out | 4 +-
.../clientpositive/beeline/smb_mapjoin_11.q.out | 4 +-
.../clientpositive/beeline/smb_mapjoin_12.q.out | 8 +-
.../clientpositive/beeline/smb_mapjoin_13.q.out | 8 +-
.../clientpositive/beeline/smb_mapjoin_2.q.out | 32 +-
.../clientpositive/beeline/smb_mapjoin_3.q.out | 32 +-
.../clientpositive/beeline/smb_mapjoin_7.q.out | 4 +-
.../clientpositive/bucket_map_join_spark1.q.out | 40 +-
.../clientpositive/bucket_map_join_spark2.q.out | 28 +-
.../clientpositive/bucket_map_join_spark3.q.out | 28 +-
.../results/clientpositive/bucketcontext_1.q.out | 12 +-
.../results/clientpositive/bucketcontext_2.q.out | 8 +-
.../results/clientpositive/bucketcontext_3.q.out | 12 +-
.../results/clientpositive/bucketcontext_4.q.out | 8 +-
.../results/clientpositive/bucketcontext_7.q.out | 8 +-
.../results/clientpositive/bucketcontext_8.q.out | 12 +-
.../results/clientpositive/bucketmapjoin10.q.out | 10 +-
.../results/clientpositive/bucketmapjoin11.q.out | 20 +-
.../results/clientpositive/bucketmapjoin12.q.out | 20 +-
.../results/clientpositive/bucketmapjoin5.q.out | 20 +-
.../results/clientpositive/bucketmapjoin8.q.out | 20 +-
.../results/clientpositive/bucketmapjoin9.q.out | 20 +-
.../clientpositive/bucketmapjoin_negative.q.out | 16 +-
.../clientpositive/bucketmapjoin_negative2.q.out | 4 +-
.../clientpositive/bucketmapjoin_negative3.q.out | 36 +-
.../test/results/clientpositive/join_map_ppr.q.out | 8 +-
.../llap/annotate_stats_lateral_view_join.q.out | 672 ++++++++++-----------
.../clientpositive/llap/annotate_stats_udtf.q.out | 8 +-
.../llap/auto_sortmerge_join_1.q.out | 24 +-
.../llap/auto_sortmerge_join_11.q.out | 40 +-
.../llap/auto_sortmerge_join_12.q.out | 22 +-
.../llap/auto_sortmerge_join_3.q.out | 24 +-
.../llap/auto_sortmerge_join_8.q.out | 24 +-
.../clientpositive/llap/bucketmapjoin1.q.out | 32 +-
.../clientpositive/llap/bucketmapjoin2.q.out | 40 +-
.../clientpositive/llap/bucketmapjoin3.q.out | 32 +-
.../clientpositive/llap/bucketmapjoin7.q.out | 32 +-
.../clientpositive/llap/check_constraint.q.out | 14 +-
.../test/results/clientpositive/llap/cluster.q.out | 16 +-
.../clientpositive/llap/column_table_stats.q.out | 36 +-
.../results/clientpositive/llap/concat_op.q.out | 6 +-
.../llap/constant_prop_join_rs.q.out | 10 +-
ql/src/test/results/clientpositive/llap/ctas.q.out | 2 +-
.../llap/dynamic_partition_join_noncbo.q.out | 18 +-
.../clientpositive/llap/explainanalyze_2.q.out | 2 +-
.../clientpositive/llap/explainuser_1.q.out | 36 +-
.../clientpositive/llap/explainuser_2.q.out | 2 +-
.../clientpositive/llap/fetch_deleted_rows.q.out | 259 ++++++++
.../results/clientpositive/llap/hashjoin.q.out | 20 +-
.../llap/infer_bucket_sort_map_operators.q.out | 8 +-
.../test/results/clientpositive/llap/input4.q.out | 2 +-
.../llap/insert1_overwrite_partitions.q.out | 30 +-
.../llap/insert2_overwrite_partitions.q.out | 20 +-
.../insert_values_orig_table_use_metadata.q.out | 4 +-
.../test/results/clientpositive/llap/join44.q.out | 6 +-
.../test/results/clientpositive/llap/join46.q.out | 2 +-
.../llap/join_by_range_rule_not_null.q.out | 6 +-
.../llap/join_is_not_distinct_from.q.out | 40 +-
.../clientpositive/llap/join_nullsafe.q.out | 40 +-
.../results/clientpositive/llap/join_reorder.q.out | 32 +-
.../clientpositive/llap/join_reorder2.q.out | 36 +-
.../clientpositive/llap/join_reorder3.q.out | 36 +-
.../clientpositive/llap/join_reorder4.q.out | 24 +-
.../results/clientpositive/llap/join_thrift.q.out | 4 +-
.../results/clientpositive/llap/lateral_view.q.out | 80 +--
.../clientpositive/llap/lateral_view_cp.q.out | 4 +-
.../llap/lateral_view_explode2.q.out | 12 +-
.../clientpositive/llap/lateral_view_noalias.q.out | 24 +-
.../clientpositive/llap/lateral_view_onview.q.out | 4 +-
.../clientpositive/llap/lateral_view_outer.q.out | 24 +-
.../clientpositive/llap/lateral_view_ppd.q.out | 56 +-
.../results/clientpositive/llap/lineage2.q.out | 4 +-
.../clientpositive/llap/llap_nullscan.q.out | 4 +-
.../clientpositive/llap/load_data_using_job.q.out | 58 +-
.../llap/load_static_ptn_into_bucketed_table.q.out | 36 +-
.../results/clientpositive/llap/lvj_mapjoin.q.out | 16 +-
.../llap/mapjoin_decimal_vectorized.q.out | 8 +-
.../clientpositive/llap/masking_disablecbo_1.q.out | 4 +-
.../clientpositive/llap/masking_disablecbo_2.q.out | 4 +-
.../clientpositive/llap/masking_disablecbo_3.q.out | 4 +-
.../clientpositive/llap/masking_mv_by_text.q.out | 4 +-
.../llap/materialized_view_create.q.out | 2 +-
.../llap/materialized_view_create_rewrite.q.out | 4 +-
.../materialized_view_create_rewrite_dummy.q.out | 4 +-
.../llap/materialized_view_rewrite_window.q.out | 2 +-
.../llap/merge_dynamic_partition.q.out | 46 +-
.../llap/merge_dynamic_partition2.q.out | 20 +-
.../llap/merge_dynamic_partition3.q.out | 20 +-
.../llap/multi_insert_lateral_view.q.out | 80 +--
.../llap/multi_insert_with_join2.q.out | 24 +-
.../llap/nested_column_pruning.q.out | 28 +-
.../results/clientpositive/llap/nullgroup3.q.out | 8 +-
.../results/clientpositive/llap/nullgroup5.q.out | 8 +-
.../clientpositive/llap/optimize_nullscan.q.out | 4 +-
.../llap/orc_nested_column_pruning.q.out | 28 +-
.../results/clientpositive/llap/plan_json.q.out | 2 +-
.../results/clientpositive/llap/pointlookup2.q.out | 12 +-
.../results/clientpositive/llap/pointlookup3.q.out | 6 +-
ql/src/test/results/clientpositive/llap/ppd2.q.out | 4 +-
.../clientpositive/llap/ppd_clusterby.q.out | 8 +-
ql/src/test/results/clientpositive/llap/ptf.q.out | 4 +-
.../llap/reduce_deduplicate_null_keys.q.out | 8 +-
.../test/results/clientpositive/llap/sample8.q.out | 14 +-
.../llap/select_column_pruning.q.out | 12 +-
.../results/clientpositive/llap/semijoin2.q.out | 54 +-
.../results/clientpositive/llap/semijoin7.q.out | 16 +-
.../clientpositive/llap/semijoin_hint.q.out | 28 +-
.../results/clientpositive/llap/skewjoin.q.out | 56 +-
.../clientpositive/llap/skewjoin_mapjoin6.q.out | 4 +-
.../llap/special_character_in_tabnames_1.q.out | 30 +-
.../special_character_in_tabnames_quotes_1.q.out | 30 +-
.../test/results/clientpositive/llap/stats11.q.out | 32 +-
.../clientpositive/llap/subquery_multiinsert.q.out | 8 +-
.../llap/subquery_unqual_corr_expr.q.out | 4 +-
.../temp_table_insert1_overwrite_partitions.q.out | 30 +-
.../temp_table_insert2_overwrite_partitions.q.out | 20 +-
.../llap/temp_table_merge_dynamic_partition.q.out | 34 +-
.../llap/temp_table_merge_dynamic_partition2.q.out | 8 +-
.../llap/temp_table_merge_dynamic_partition3.q.out | 8 +-
.../clientpositive/llap/udtf_json_tuple.q.out | 32 +-
.../clientpositive/llap/udtf_parse_url_tuple.q.out | 32 +-
.../results/clientpositive/llap/udtf_stack.q.out | 16 +-
.../test/results/clientpositive/llap/union26.q.out | 4 +-
.../llap/vector_delete_orig_table.q.out | 4 +-
.../llap/vector_include_no_sel.q.out | 4 +-
.../clientpositive/llap/vector_nullsafe_join.q.out | 64 +-
.../llap/vector_orc_nested_column_pruning.q.out | 28 +-
.../llap/vectorized_bucketmapjoin1.q.out | 12 +-
.../clientpositive/llap/vectorized_ptf.q.out | 4 +-
.../test/results/clientpositive/nonmr_fetch.q.out | 8 +-
.../results/clientpositive/skewjoinopt10.q.out | 8 +-
.../test/results/clientpositive/smb_mapjoin9.q.out | 12 +-
.../clientpositive/tez/explainanalyze_3.q.out | 4 +-
.../clientpositive/tez/explainanalyze_5.q.out | 2 +-
.../results/clientpositive/tez/explainuser_3.q.out | 4 +-
.../clientpositive/tez/tez_union_udtf.q.out | 4 +-
161 files changed, 2137 insertions(+), 1699 deletions(-)
create mode 100644 ql/src/test/queries/clientpositive/fetch_deleted_rows.q
create mode 100644
ql/src/test/results/clientpositive/llap/fetch_deleted_rows.q.out
