hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hashut...@apache.org
Subject [3/3] hive git commit: HIVE-16288 : Add blobstore tests for ORC and RCFILE file formats (Thomas Poepping via Ashutosh Chauhan)
Date Wed, 29 Mar 2017 17:30:54 GMT
HIVE-16288 : Add blobstore tests for ORC and RCFILE file formats (Thomas Poepping via Ashutosh Chauhan)

Signed-off-by: Ashutosh Chauhan <hashutosh@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/ea41d0a6
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/ea41d0a6
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/ea41d0a6

Branch: refs/heads/master
Commit: ea41d0a685fb346ce20075d0dcc3c736e375bb20
Parents: b176d07
Author: Thomas Poepping <poeppt@amazon.com>
Authored: Wed Mar 29 10:29:46 2017 -0700
Committer: Ashutosh Chauhan <hashutosh@apache.org>
Committed: Wed Mar 29 10:29:46 2017 -0700

----------------------------------------------------------------------
 files/events.txt                                | 200 +++++++
 .../test/queries/clientpositive/orc_buckets.q   |  31 ++
 .../queries/clientpositive/orc_format_nonpart.q |  30 ++
 .../queries/clientpositive/orc_format_part.q    |  67 +++
 .../clientpositive/orc_nonstd_partitions_loc.q  | 100 ++++
 .../queries/clientpositive/rcfile_buckets.q     |  31 ++
 .../clientpositive/rcfile_format_nonpart.q      |  30 ++
 .../queries/clientpositive/rcfile_format_part.q |  67 +++
 .../rcfile_nonstd_partitions_loc.q              | 100 ++++
 .../results/clientpositive/orc_buckets.q.out    | 183 +++++++
 .../clientpositive/orc_format_nonpart.q.out     | 195 +++++++
 .../clientpositive/orc_format_part.q.out        | 274 ++++++++++
 .../orc_nonstd_partitions_loc.q.out             | 513 ++++++++++++++++++
 .../results/clientpositive/rcfile_buckets.q.out | 183 +++++++
 .../clientpositive/rcfile_format_nonpart.q.out  | 195 +++++++
 .../clientpositive/rcfile_format_part.q.out     | 274 ++++++++++
 .../rcfile_nonstd_partitions_loc.q.out          | 533 +++++++++++++++++++
 17 files changed, 3006 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/files/events.txt
----------------------------------------------------------------------
diff --git a/files/events.txt b/files/events.txt
new file mode 100644
index 0000000..e0bd0be
--- /dev/null
+++ b/files/events.txt
@@ -0,0 +1,200 @@
+1111,20121121,1111,1,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,2,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,3,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,4,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,5,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,6,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,7,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,8,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,9,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,10,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,11,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,12,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,13,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,14,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,15,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,16,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,17,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,18,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,19,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,20,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,21,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,22,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,23,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,24,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,25,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,26,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,27,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,28,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,29,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,30,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,31,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,32,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,33,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,34,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,35,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,36,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,37,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,38,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,39,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,40,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,41,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,42,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,43,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,44,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,45,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,46,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,47,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,48,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,49,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121121,1111,50,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121021,1111,1,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,2,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,3,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,4,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,5,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,6,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,7,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,8,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,9,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,10,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,11,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,12,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,13,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,14,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,15,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,16,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,17,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,18,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,19,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,20,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,21,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,22,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,23,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,24,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,25,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,26,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,27,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,28,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,29,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,30,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,31,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,32,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,33,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,34,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,35,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,36,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,37,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,38,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,39,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,40,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,41,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,42,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,43,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,44,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,45,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,46,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,47,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,48,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,49,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121021,1111,50,type1,eventData,session,full_uid,20121021,39,hq_change
+1111,20121221,1111,1,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,2,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,3,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,4,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,5,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,6,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,7,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,8,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,9,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,10,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,11,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,12,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,13,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,14,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,15,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,16,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,17,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,18,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,19,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,20,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,21,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,22,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,23,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,24,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,25,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,26,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,27,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,28,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,29,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,30,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,31,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,32,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,33,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,34,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,35,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,36,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,37,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,38,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,39,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,40,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,41,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,42,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,43,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,44,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,45,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,46,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,47,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,48,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,49,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20121221,1111,50,type1,eventData,session,full_uid,20121121,39,hq_change
+1111,20120921,1111,1,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,2,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,3,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,4,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,5,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,6,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,7,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,8,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,9,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,10,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,11,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,12,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,13,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,14,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,15,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,16,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,17,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,18,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,19,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,20,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,21,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,22,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,23,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,24,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,25,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,26,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,27,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,28,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,29,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,30,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,31,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,32,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,33,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,34,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,35,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,36,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,37,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,38,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,39,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,40,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,41,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,42,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,43,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,44,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,45,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,46,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,47,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,48,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,49,type1,eventData,session,full_uid,20120921,39,hq_change
+1111,20120921,1111,50,type1,eventData,session,full_uid,20120921,39,hq_change

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/queries/clientpositive/orc_buckets.q
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/queries/clientpositive/orc_buckets.q b/hive-blobstore/src/test/queries/clientpositive/orc_buckets.q
new file mode 100644
index 0000000..9571842
--- /dev/null
+++ b/hive-blobstore/src/test/queries/clientpositive/orc_buckets.q
@@ -0,0 +1,31 @@
+-- Test simple interaction with partitioned bucketed table with orc format in blobstore
+
+SET hive.exec.dynamic.partition=true;
+SET hive.exec.reducers.max=10;
+SET hive.exec.dynamic.partition.mode=nonstrict;
+
+DROP TABLE blobstore_source;
+CREATE TABLE blobstore_source(a STRING, b STRING, c DOUBLE)
+ROW FORMAT DELIMITED
+FIELDS TERMINATED BY ' '
+COLLECTION ITEMS TERMINATED BY '\t'
+LINES TERMINATED BY '\n'
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_buckets/blobstore_source/';
+LOAD DATA LOCAL INPATH '../../data/files/3col_data.txt' INTO TABLE blobstore_source;
+
+DROP TABLE orc_buckets;
+CREATE TABLE orc_buckets (a STRING, value DOUBLE)
+PARTITIONED BY (b STRING)
+CLUSTERED BY (a) INTO 10 BUCKETS
+STORED AS ORC
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_buckets/orc_buckets';
+
+INSERT OVERWRITE TABLE orc_buckets
+PARTITION (b)
+SELECT a, c, b FROM blobstore_source;
+SELECT * FROM orc_buckets;
+
+INSERT INTO TABLE orc_buckets
+PARTITION (b)
+SELECT a, c, b FROM blobstore_source;
+SELECT * FROM orc_buckets;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/queries/clientpositive/orc_format_nonpart.q
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/queries/clientpositive/orc_format_nonpart.q b/hive-blobstore/src/test/queries/clientpositive/orc_format_nonpart.q
new file mode 100644
index 0000000..ad95459
--- /dev/null
+++ b/hive-blobstore/src/test/queries/clientpositive/orc_format_nonpart.q
@@ -0,0 +1,30 @@
+-- Test INSERT OVERWRITE and INSERT INTO on orc table in blobstore
+
+DROP TABLE blobstore_source;
+CREATE TABLE blobstore_source(a STRING, b STRING, c DOUBLE)
+ROW FORMAT DELIMITED
+FIELDS TERMINATED BY ' '
+COLLECTION ITEMS TERMINATED BY '\t'
+LINES TERMINATED BY '\n'
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_format_nonpart/blobstore_source/';
+LOAD DATA LOCAL INPATH '../../data/files/3col_data.txt' INTO TABLE blobstore_source;
+
+DROP TABLE orc_table;
+CREATE EXTERNAL TABLE orc_table (a INT, b STRING, value DOUBLE) STORED AS ORC
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_format_nonpart/orc_table';
+ 
+INSERT OVERWRITE TABLE orc_table
+SELECT * FROM blobstore_source;
+ 
+SELECT * FROM orc_table;
+SELECT a FROM orc_table GROUP BY a;
+SELECT b FROM orc_table GROUP BY b;
+SELECT value FROM orc_table GROUP BY value;
+
+INSERT INTO TABLE orc_table
+SELECT * FROM blobstore_source;
+
+SELECT * FROM orc_table;
+SELECT a FROM orc_table GROUP BY a;
+SELECT b FROM orc_table GROUP BY b;
+SELECT value FROM orc_table GROUP BY value;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/queries/clientpositive/orc_format_part.q
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/queries/clientpositive/orc_format_part.q b/hive-blobstore/src/test/queries/clientpositive/orc_format_part.q
new file mode 100644
index 0000000..358eccd
--- /dev/null
+++ b/hive-blobstore/src/test/queries/clientpositive/orc_format_part.q
@@ -0,0 +1,67 @@
+-- Test INSERT INTO and INSERT OVERWRITE on partitioned orc table in blobstore
+
+DROP TABLE src_events;
+CREATE TABLE src_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT,
+  run_date    STRING,
+  game_id     INT,
+  event_name  STRING
+)
+ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_format_part/src_events/';
+LOAD DATA LOCAL INPATH '../../data/files/events.txt' INTO TABLE src_events;
+
+DROP TABLE orc_events;
+CREATE TABLE orc_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT
+)
+PARTITIONED BY (run_date STRING, game_id INT, event_name STRING)
+STORED AS ORC
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_format_part/orc_events';
+
+SET hive.exec.dynamic.partition=true;
+SET hive.exec.dynamic.partition.mode=nonstrict;
+
+INSERT OVERWRITE TABLE orc_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events;
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
+SELECT COUNT(*) FROM orc_events WHERE run_date=20120921;
+SELECT COUNT(*) FROM orc_events WHERE run_date=20121121;
+
+INSERT OVERWRITE TABLE orc_events PARTITION (run_date=201211, game_id, event_name)
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid,game_id,event_name FROM src_events
+WHERE SUBSTR(run_date,1,6)='201211';
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
+
+INSERT INTO TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name)
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid,event_name FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39;
+SELECT COUNT(*) FROM orc_events;
+
+INSERT INTO TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39 AND event_name='hq_change';
+SELECT COUNT(*) FROM orc_events;
+
+INSERT OVERWRITE TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39 AND event_name='hq_change';
+SELECT COUNT(*) FROM orc_events;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/queries/clientpositive/orc_nonstd_partitions_loc.q
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/queries/clientpositive/orc_nonstd_partitions_loc.q b/hive-blobstore/src/test/queries/clientpositive/orc_nonstd_partitions_loc.q
new file mode 100644
index 0000000..c462538
--- /dev/null
+++ b/hive-blobstore/src/test/queries/clientpositive/orc_nonstd_partitions_loc.q
@@ -0,0 +1,100 @@
+-- Test table in orc format with non-standard partition locations in blobstore
+
+DROP TABLE src_events;
+CREATE TABLE src_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT,
+  run_date    STRING,
+  game_id     INT,
+  event_name  STRING
+)
+ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_nonstd_partitions_loc/src_events/';
+LOAD DATA LOCAL INPATH '../../data/files/events.txt' INTO TABLE src_events;
+
+DROP TABLE orc_events;
+CREATE TABLE orc_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT
+)
+PARTITIONED BY (run_date STRING, game_id INT, event_name STRING)
+STORED AS ORC
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_nonstd_partitions_loc/orc_events/';
+
+SET hive.exec.dynamic.partition=true;
+SET hive.exec.dynamic.partition.mode=nonstrict;
+
+INSERT OVERWRITE TABLE orc_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events;
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
+
+-- verify INSERT OVERWRITE and INSERT INTO nonstandard partition location
+ALTER TABLE orc_events ADD PARTITION (run_date=201211, game_id=39, event_name='hq_change')
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_nonstd_partitions_loc/orc_nonstd_loc/ns-part-1/';
+INSERT OVERWRITE TABLE orc_events PARTITION (run_date=201211, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201211';
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
+INSERT INTO TABLE orc_events PARTITION (run_date=201211, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201211';
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
+
+SET hive.merge.mapfiles=false;
+
+-- verify INSERT OVERWRITE and INSERT INTO nonstandard partition location with hive.merge.mapfiles false
+ALTER TABLE orc_events ADD PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_nonstd_partitions_loc/orc_nonstd_loc/ns-part-2/';
+INSERT OVERWRITE TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209';
+INSERT INTO TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209';
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
+
+-- verify dynamic INSERT OVERWRITE over all partitions (standard and nonstandard locations) with hive.merge.mapfiles false
+INSERT OVERWRITE TABLE orc_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events;
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
+
+SET hive.merge.mapfiles=true;
+
+ALTER TABLE orc_events ADD PARTITION (run_date=201207, game_id=39, event_name='hq_change')
+LOCATION '${hiveconf:test.blobstore.path.unique}/orc_nonstd_partitions_loc/orc_nonstd_loc/ns-part-3/';
+INSERT INTO TABLE orc_events PARTITION (run_date=201207, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209';
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
+
+-- verify dynamic INSERT OVERWRITE over all partitions (standard and nonstandard locations) with hive.merge.mapfiles true
+INSERT OVERWRITE TABLE orc_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events;
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
+
+ALTER TABLE orc_events DROP PARTITION (run_date=201211, game_id=39, event_name='hq_change');
+ALTER TABLE orc_events DROP PARTITION (run_date=201209, game_id=39, event_name='hq_change');
+ALTER TABLE orc_events DROP PARTITION (run_date=201207, game_id=39, event_name='hq_change');
+SHOW PARTITIONS orc_events;
+SELECT COUNT(*) FROM orc_events;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/queries/clientpositive/rcfile_buckets.q
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/queries/clientpositive/rcfile_buckets.q b/hive-blobstore/src/test/queries/clientpositive/rcfile_buckets.q
new file mode 100644
index 0000000..606ef720
--- /dev/null
+++ b/hive-blobstore/src/test/queries/clientpositive/rcfile_buckets.q
@@ -0,0 +1,31 @@
+-- Test simple interaction with partitioned bucketed table with rcfile format in blobstore
+
+SET hive.exec.dynamic.partition=true;
+SET hive.exec.reducers.max=10;
+SET hive.exec.dynamic.partition.mode=nonstrict;
+
+DROP TABLE blobstore_source;
+CREATE TABLE blobstore_source(a STRING, b STRING, c DOUBLE)
+ROW FORMAT DELIMITED
+FIELDS TERMINATED BY ' '
+COLLECTION ITEMS TERMINATED BY '\t'
+LINES TERMINATED BY '\n'
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_buckets/blobstore_source/';
+LOAD DATA LOCAL INPATH '../../data/files/3col_data.txt' INTO TABLE blobstore_source;
+
+DROP TABLE rcfile_buckets;
+CREATE TABLE rcfile_buckets (a STRING, value DOUBLE)
+PARTITIONED BY (b STRING)
+CLUSTERED BY (a) INTO 10 BUCKETS
+STORED AS RCFILE
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_buckets/rcfile_buckets';
+
+INSERT OVERWRITE TABLE rcfile_buckets
+PARTITION (b)
+SELECT a, c, b FROM blobstore_source;
+SELECT * FROM rcfile_buckets;
+
+INSERT INTO TABLE rcfile_buckets
+PARTITION (b)
+SELECT a, c, b FROM blobstore_source;
+SELECT * FROM rcfile_buckets;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/queries/clientpositive/rcfile_format_nonpart.q
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/queries/clientpositive/rcfile_format_nonpart.q b/hive-blobstore/src/test/queries/clientpositive/rcfile_format_nonpart.q
new file mode 100644
index 0000000..9cd909e
--- /dev/null
+++ b/hive-blobstore/src/test/queries/clientpositive/rcfile_format_nonpart.q
@@ -0,0 +1,30 @@
+-- Test INSERT OVERWRITE and INSERT INTO on rcfile table in blobstore
+
+DROP TABLE blobstore_source;
+CREATE TABLE blobstore_source(a STRING, b STRING, c DOUBLE)
+ROW FORMAT DELIMITED
+FIELDS TERMINATED BY ' '
+COLLECTION ITEMS TERMINATED BY '\t'
+LINES TERMINATED BY '\n'
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_format_nonpart/blobstore_source/';
+LOAD DATA LOCAL INPATH '../../data/files/3col_data.txt' INTO TABLE blobstore_source;
+
+DROP TABLE rcfile_table;
+CREATE TABLE rcfile_table (a INT, b STRING, value DOUBLE) STORED AS RCFILE
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_format_nonpart/rcfile_table';
+ 
+INSERT OVERWRITE TABLE rcfile_table
+SELECT * FROM blobstore_source;
+ 
+SELECT * FROM rcfile_table;
+SELECT a FROM rcfile_table GROUP BY a;
+SELECT b FROM rcfile_table GROUP BY b;
+SELECT VALUE FROM rcfile_table GROUP BY VALUE;
+
+INSERT INTO TABLE rcfile_table
+SELECT * FROM blobstore_source;
+
+SELECT * FROM rcfile_table;
+SELECT a FROM rcfile_table GROUP BY a;
+SELECT b FROM rcfile_table GROUP BY b;
+SELECT value FROM rcfile_table GROUP BY value;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/queries/clientpositive/rcfile_format_part.q
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/queries/clientpositive/rcfile_format_part.q b/hive-blobstore/src/test/queries/clientpositive/rcfile_format_part.q
new file mode 100644
index 0000000..c563d3a
--- /dev/null
+++ b/hive-blobstore/src/test/queries/clientpositive/rcfile_format_part.q
@@ -0,0 +1,67 @@
+-- Test INSERT INTO and INSERT OVERWRITE on partitioned rcfile table in blobstore
+
+DROP TABLE src_events;
+CREATE TABLE src_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT,
+  run_date    STRING,
+  game_id     INT,
+  event_name  STRING
+)
+ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_format_part/src_events/';
+LOAD DATA LOCAL INPATH '../../data/files/events.txt' INTO TABLE src_events;
+
+DROP TABLE rcfile_events;
+CREATE TABLE rcfile_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT
+)
+PARTITIONED BY (run_date STRING, game_id INT, event_name STRING)
+STORED AS RCFILE
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_format_part/rcfile_events';
+
+SET hive.exec.dynamic.partition=true;
+SET hive.exec.dynamic.partition.mode=nonstrict;
+
+INSERT OVERWRITE TABLE rcfile_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events;
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;
+SELECT COUNT(*) FROM rcfile_events WHERE run_date=20120921;
+SELECT COUNT(*) FROM rcfile_events WHERE run_date=20121121;
+
+INSERT OVERWRITE TABLE rcfile_events PARTITION (run_date=201211, game_id, event_name)
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid,game_id,event_name FROM src_events
+WHERE SUBSTR(run_date,1,6)='201211';
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;
+
+INSERT INTO TABLE rcfile_events PARTITION (run_date=201209, game_id=39, event_name)
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid,event_name FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39;
+SELECT COUNT(*) FROM rcfile_events;
+
+INSERT INTO TABLE rcfile_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39 AND event_name='hq_change';
+SELECT COUNT(*) FROM rcfile_events;
+
+INSERT OVERWRITE TABLE rcfile_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39 AND event_name='hq_change';
+SELECT COUNT(*) FROM rcfile_events;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/queries/clientpositive/rcfile_nonstd_partitions_loc.q
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/queries/clientpositive/rcfile_nonstd_partitions_loc.q b/hive-blobstore/src/test/queries/clientpositive/rcfile_nonstd_partitions_loc.q
new file mode 100644
index 0000000..d17c281
--- /dev/null
+++ b/hive-blobstore/src/test/queries/clientpositive/rcfile_nonstd_partitions_loc.q
@@ -0,0 +1,100 @@
+-- Test table in rcfile format with non-standard partition locations in blobstore
+
+DROP TABLE src_events;
+CREATE TABLE src_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT,
+  run_date    STRING,
+  game_id     INT,
+  event_name  STRING
+)
+ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_nonstd_partitions_loc/src_events/';
+LOAD DATA LOCAL INPATH '../../data/files/events.txt' INTO TABLE src_events;
+
+DROP TABLE rcfile_events;
+CREATE TABLE rcfile_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT
+)
+PARTITIONED BY (run_date STRING, game_id INT, event_name STRING)
+STORED AS RCFILE
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_nonstd_partitions_loc/rcfile_events/';
+
+SET hive.exec.dynamic.partition=true;
+SET hive.exec.dynamic.partition.mode=nonstrict;
+
+INSERT OVERWRITE TABLE rcfile_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events;
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;
+
+-- verify INSERT OVERWRITE and INSERT INTO nonstandard partition location
+ALTER TABLE rcfile_events ADD PARTITION (run_date=201211, game_id=39, event_name='hq_change')
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_nonstd_partitions_loc/rcfile_nonstd_loc/ns-part-1/';
+INSERT OVERWRITE TABLE rcfile_events PARTITION (run_date=201211, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201211';
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;
+INSERT INTO TABLE rcfile_events PARTITION (run_date=201211, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201211';
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;
+
+SET hive.merge.mapfiles=false;
+
+-- verify INSERT OVERWRITE and INSERT INTO nonstandard partition location with hive.merge.mapfiles false
+ALTER TABLE rcfile_events ADD PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_nonstd_partitions_loc/rcfile_nonstd_loc/ns-part-2/';
+INSERT INTO TABLE rcfile_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209';
+INSERT INTO TABLE rcfile_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209';
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;
+
+-- verify dynamic INSERT OVERWRITE over all partitions (standard and nonstandard locations) with hive.merge.mapfiles false
+INSERT OVERWRITE TABLE rcfile_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events;
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;
+
+SET hive.merge.mapfiles=true;
+
+ALTER TABLE rcfile_events ADD PARTITION (run_date=201207, game_id=39, event_name='hq_change')
+LOCATION '${hiveconf:test.blobstore.path.unique}/rcfile_nonstd_partitions_loc/rcfile_nonstd_loc/ns-part-3/';
+INSERT INTO TABLE rcfile_events PARTITION(run_date=201207,game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209';
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;
+
+-- verify dynamic INSERT OVERWRITE over all partitions (standard and nonstandard locations) with hive.merge.mapfiles true
+INSERT OVERWRITE TABLE rcfile_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events;
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;
+
+ALTER TABLE rcfile_events DROP PARTITION (run_date=201211,game_id=39, event_name='hq_change');
+ALTER TABLE rcfile_events DROP PARTITION (run_date=201209,game_id=39, event_name='hq_change');
+ALTER TABLE rcfile_events DROP PARTITION (run_date=201207,game_id=39, event_name='hq_change');
+SHOW PARTITIONS rcfile_events;
+SELECT COUNT(*) FROM rcfile_events;

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/results/clientpositive/orc_buckets.q.out
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/results/clientpositive/orc_buckets.q.out b/hive-blobstore/src/test/results/clientpositive/orc_buckets.q.out
new file mode 100644
index 0000000..e54b84e
--- /dev/null
+++ b/hive-blobstore/src/test/results/clientpositive/orc_buckets.q.out
@@ -0,0 +1,183 @@
+PREHOOK: query: DROP TABLE blobstore_source
+PREHOOK: type: DROPTABLE
+POSTHOOK: query: DROP TABLE blobstore_source
+POSTHOOK: type: DROPTABLE
+PREHOOK: query: CREATE TABLE blobstore_source(a STRING, b STRING, c DOUBLE)
+ROW FORMAT DELIMITED
+FIELDS TERMINATED BY ' '
+COLLECTION ITEMS TERMINATED BY '\t'
+LINES TERMINATED BY '\n'
+#### A masked pattern was here ####
+PREHOOK: type: CREATETABLE
+PREHOOK: Input: ### test.blobstore.path ###/orc_buckets/blobstore_source
+PREHOOK: Output: database:default
+PREHOOK: Output: default@blobstore_source
+POSTHOOK: query: CREATE TABLE blobstore_source(a STRING, b STRING, c DOUBLE)
+ROW FORMAT DELIMITED
+FIELDS TERMINATED BY ' '
+COLLECTION ITEMS TERMINATED BY '\t'
+LINES TERMINATED BY '\n'
+#### A masked pattern was here ####
+POSTHOOK: type: CREATETABLE
+POSTHOOK: Input: ### test.blobstore.path ###/orc_buckets/blobstore_source
+POSTHOOK: Output: database:default
+POSTHOOK: Output: default@blobstore_source
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/3col_data.txt' INTO TABLE blobstore_source
+PREHOOK: type: LOAD
+#### A masked pattern was here ####
+PREHOOK: Output: default@blobstore_source
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/3col_data.txt' INTO TABLE blobstore_source
+POSTHOOK: type: LOAD
+#### A masked pattern was here ####
+POSTHOOK: Output: default@blobstore_source
+PREHOOK: query: DROP TABLE orc_buckets
+PREHOOK: type: DROPTABLE
+POSTHOOK: query: DROP TABLE orc_buckets
+POSTHOOK: type: DROPTABLE
+PREHOOK: query: CREATE TABLE orc_buckets (a STRING, value DOUBLE)
+PARTITIONED BY (b STRING)
+CLUSTERED BY (a) INTO 10 BUCKETS
+STORED AS ORC
+#### A masked pattern was here ####
+PREHOOK: type: CREATETABLE
+PREHOOK: Input: ### test.blobstore.path ###/orc_buckets/orc_buckets
+PREHOOK: Output: database:default
+PREHOOK: Output: default@orc_buckets
+POSTHOOK: query: CREATE TABLE orc_buckets (a STRING, value DOUBLE)
+PARTITIONED BY (b STRING)
+CLUSTERED BY (a) INTO 10 BUCKETS
+STORED AS ORC
+#### A masked pattern was here ####
+POSTHOOK: type: CREATETABLE
+POSTHOOK: Input: ### test.blobstore.path ###/orc_buckets/orc_buckets
+POSTHOOK: Output: database:default
+POSTHOOK: Output: default@orc_buckets
+PREHOOK: query: INSERT OVERWRITE TABLE orc_buckets
+PARTITION (b)
+SELECT a, c, b FROM blobstore_source
+PREHOOK: type: QUERY
+PREHOOK: Input: default@blobstore_source
+PREHOOK: Output: default@orc_buckets
+POSTHOOK: query: INSERT OVERWRITE TABLE orc_buckets
+PARTITION (b)
+SELECT a, c, b FROM blobstore_source
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@blobstore_source
+POSTHOOK: Output: default@orc_buckets@b=abc
+POSTHOOK: Output: default@orc_buckets@b=ajss
+POSTHOOK: Output: default@orc_buckets@b=data
+POSTHOOK: Output: default@orc_buckets@b=def
+POSTHOOK: Output: default@orc_buckets@b=djns
+POSTHOOK: Output: default@orc_buckets@b=ne
+POSTHOOK: Output: default@orc_buckets@b=random
+POSTHOOK: Lineage: orc_buckets PARTITION(b=abc).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=abc).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=ajss).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=ajss).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=data).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=data).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=def).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=def).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=djns).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=djns).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=ne).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=ne).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=random).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=random).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+PREHOOK: query: SELECT * FROM orc_buckets
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_buckets
+PREHOOK: Input: default@orc_buckets@b=abc
+PREHOOK: Input: default@orc_buckets@b=ajss
+PREHOOK: Input: default@orc_buckets@b=data
+PREHOOK: Input: default@orc_buckets@b=def
+PREHOOK: Input: default@orc_buckets@b=djns
+PREHOOK: Input: default@orc_buckets@b=ne
+PREHOOK: Input: default@orc_buckets@b=random
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT * FROM orc_buckets
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_buckets
+POSTHOOK: Input: default@orc_buckets@b=abc
+POSTHOOK: Input: default@orc_buckets@b=ajss
+POSTHOOK: Input: default@orc_buckets@b=data
+POSTHOOK: Input: default@orc_buckets@b=def
+POSTHOOK: Input: default@orc_buckets@b=djns
+POSTHOOK: Input: default@orc_buckets@b=ne
+POSTHOOK: Input: default@orc_buckets@b=random
+#### A masked pattern was here ####
+1	10.5	abc
+3	90.23232	ajss
+6	3.002	data
+2	11.5	def
+4	89.02002	djns
+7	71.9084	ne
+5	2.99	random
+PREHOOK: query: INSERT INTO TABLE orc_buckets
+PARTITION (b)
+SELECT a, c, b FROM blobstore_source
+PREHOOK: type: QUERY
+PREHOOK: Input: default@blobstore_source
+PREHOOK: Output: default@orc_buckets
+POSTHOOK: query: INSERT INTO TABLE orc_buckets
+PARTITION (b)
+SELECT a, c, b FROM blobstore_source
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@blobstore_source
+POSTHOOK: Output: default@orc_buckets@b=abc
+POSTHOOK: Output: default@orc_buckets@b=ajss
+POSTHOOK: Output: default@orc_buckets@b=data
+POSTHOOK: Output: default@orc_buckets@b=def
+POSTHOOK: Output: default@orc_buckets@b=djns
+POSTHOOK: Output: default@orc_buckets@b=ne
+POSTHOOK: Output: default@orc_buckets@b=random
+POSTHOOK: Lineage: orc_buckets PARTITION(b=abc).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=abc).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=ajss).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=ajss).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=data).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=data).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=def).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=def).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=djns).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=djns).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=ne).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=ne).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=random).a SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:a, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_buckets PARTITION(b=random).value SIMPLE [(blobstore_source)blobstore_source.FieldSchema(name:c, type:double, comment:null), ]
+PREHOOK: query: SELECT * FROM orc_buckets
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_buckets
+PREHOOK: Input: default@orc_buckets@b=abc
+PREHOOK: Input: default@orc_buckets@b=ajss
+PREHOOK: Input: default@orc_buckets@b=data
+PREHOOK: Input: default@orc_buckets@b=def
+PREHOOK: Input: default@orc_buckets@b=djns
+PREHOOK: Input: default@orc_buckets@b=ne
+PREHOOK: Input: default@orc_buckets@b=random
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT * FROM orc_buckets
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_buckets
+POSTHOOK: Input: default@orc_buckets@b=abc
+POSTHOOK: Input: default@orc_buckets@b=ajss
+POSTHOOK: Input: default@orc_buckets@b=data
+POSTHOOK: Input: default@orc_buckets@b=def
+POSTHOOK: Input: default@orc_buckets@b=djns
+POSTHOOK: Input: default@orc_buckets@b=ne
+POSTHOOK: Input: default@orc_buckets@b=random
+#### A masked pattern was here ####
+1	10.5	abc
+1	10.5	abc
+3	90.23232	ajss
+3	90.23232	ajss
+6	3.002	data
+6	3.002	data
+2	11.5	def
+2	11.5	def
+4	89.02002	djns
+4	89.02002	djns
+7	71.9084	ne
+7	71.9084	ne
+5	2.99	random
+5	2.99	random

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/results/clientpositive/orc_format_nonpart.q.out
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/results/clientpositive/orc_format_nonpart.q.out b/hive-blobstore/src/test/results/clientpositive/orc_format_nonpart.q.out
new file mode 100644
index 0000000..f470568
--- /dev/null
+++ b/hive-blobstore/src/test/results/clientpositive/orc_format_nonpart.q.out
@@ -0,0 +1,195 @@
+PREHOOK: query: DROP TABLE blobstore_source
+PREHOOK: type: DROPTABLE
+POSTHOOK: query: DROP TABLE blobstore_source
+POSTHOOK: type: DROPTABLE
+PREHOOK: query: CREATE TABLE blobstore_source(a STRING, b STRING, c DOUBLE)
+ROW FORMAT DELIMITED
+FIELDS TERMINATED BY ' '
+COLLECTION ITEMS TERMINATED BY '\t'
+LINES TERMINATED BY '\n'
+#### A masked pattern was here ####
+PREHOOK: type: CREATETABLE
+PREHOOK: Input: ### test.blobstore.path ###/orc_format_nonpart/blobstore_source
+PREHOOK: Output: database:default
+PREHOOK: Output: default@blobstore_source
+POSTHOOK: query: CREATE TABLE blobstore_source(a STRING, b STRING, c DOUBLE)
+ROW FORMAT DELIMITED
+FIELDS TERMINATED BY ' '
+COLLECTION ITEMS TERMINATED BY '\t'
+LINES TERMINATED BY '\n'
+#### A masked pattern was here ####
+POSTHOOK: type: CREATETABLE
+POSTHOOK: Input: ### test.blobstore.path ###/orc_format_nonpart/blobstore_source
+POSTHOOK: Output: database:default
+POSTHOOK: Output: default@blobstore_source
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/3col_data.txt' INTO TABLE blobstore_source
+PREHOOK: type: LOAD
+#### A masked pattern was here ####
+PREHOOK: Output: default@blobstore_source
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/3col_data.txt' INTO TABLE blobstore_source
+POSTHOOK: type: LOAD
+#### A masked pattern was here ####
+POSTHOOK: Output: default@blobstore_source
+PREHOOK: query: DROP TABLE orc_table
+PREHOOK: type: DROPTABLE
+POSTHOOK: query: DROP TABLE orc_table
+POSTHOOK: type: DROPTABLE
+PREHOOK: query: CREATE EXTERNAL TABLE orc_table (a INT, b STRING, value DOUBLE) STORED AS ORC
+#### A masked pattern was here ####
+PREHOOK: type: CREATETABLE
+PREHOOK: Input: ### test.blobstore.path ###/orc_format_nonpart/orc_table
+PREHOOK: Output: database:default
+PREHOOK: Output: default@orc_table
+POSTHOOK: query: CREATE EXTERNAL TABLE orc_table (a INT, b STRING, value DOUBLE) STORED AS ORC
+#### A masked pattern was here ####
+POSTHOOK: type: CREATETABLE
+POSTHOOK: Input: ### test.blobstore.path ###/orc_format_nonpart/orc_table
+POSTHOOK: Output: database:default
+POSTHOOK: Output: default@orc_table
+PREHOOK: query: INSERT OVERWRITE TABLE orc_table
+SELECT * FROM blobstore_source
+PREHOOK: type: QUERY
+PREHOOK: Input: default@blobstore_source
+PREHOOK: Output: default@orc_table
+POSTHOOK: query: INSERT OVERWRITE TABLE orc_table
+SELECT * FROM blobstore_source
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@blobstore_source
+POSTHOOK: Output: default@orc_table
+PREHOOK: query: SELECT * FROM orc_table
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT * FROM orc_table
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+1	abc	10.5
+2	def	11.5
+3	ajss	90.23232
+4	djns	89.02002
+5	random	2.99
+6	data	3.002
+7	ne	71.9084
+PREHOOK: query: SELECT a FROM orc_table GROUP BY a
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT a FROM orc_table GROUP BY a
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+1
+2
+3
+4
+5
+6
+7
+PREHOOK: query: SELECT b FROM orc_table GROUP BY b
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT b FROM orc_table GROUP BY b
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+abc
+ajss
+data
+def
+djns
+ne
+random
+PREHOOK: query: SELECT value FROM orc_table GROUP BY value
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT value FROM orc_table GROUP BY value
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+2.99
+3.002
+10.5
+11.5
+71.9084
+89.02002
+90.23232
+PREHOOK: query: INSERT INTO TABLE orc_table
+SELECT * FROM blobstore_source
+PREHOOK: type: QUERY
+PREHOOK: Input: default@blobstore_source
+PREHOOK: Output: default@orc_table
+POSTHOOK: query: INSERT INTO TABLE orc_table
+SELECT * FROM blobstore_source
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@blobstore_source
+POSTHOOK: Output: default@orc_table
+PREHOOK: query: SELECT * FROM orc_table
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT * FROM orc_table
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+1	abc	10.5
+2	def	11.5
+3	ajss	90.23232
+4	djns	89.02002
+5	random	2.99
+6	data	3.002
+7	ne	71.9084
+1	abc	10.5
+2	def	11.5
+3	ajss	90.23232
+4	djns	89.02002
+5	random	2.99
+6	data	3.002
+7	ne	71.9084
+PREHOOK: query: SELECT a FROM orc_table GROUP BY a
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT a FROM orc_table GROUP BY a
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+1
+2
+3
+4
+5
+6
+7
+PREHOOK: query: SELECT b FROM orc_table GROUP BY b
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT b FROM orc_table GROUP BY b
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+abc
+ajss
+data
+def
+djns
+ne
+random
+PREHOOK: query: SELECT value FROM orc_table GROUP BY value
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT value FROM orc_table GROUP BY value
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_table
+#### A masked pattern was here ####
+2.99
+3.002
+10.5
+11.5
+71.9084
+89.02002
+90.23232

http://git-wip-us.apache.org/repos/asf/hive/blob/ea41d0a6/hive-blobstore/src/test/results/clientpositive/orc_format_part.q.out
----------------------------------------------------------------------
diff --git a/hive-blobstore/src/test/results/clientpositive/orc_format_part.q.out b/hive-blobstore/src/test/results/clientpositive/orc_format_part.q.out
new file mode 100644
index 0000000..5d1319f
--- /dev/null
+++ b/hive-blobstore/src/test/results/clientpositive/orc_format_part.q.out
@@ -0,0 +1,274 @@
+PREHOOK: query: DROP TABLE src_events
+PREHOOK: type: DROPTABLE
+POSTHOOK: query: DROP TABLE src_events
+POSTHOOK: type: DROPTABLE
+PREHOOK: query: CREATE TABLE src_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT,
+  run_date    STRING,
+  game_id     INT,
+  event_name  STRING
+)
+ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
+#### A masked pattern was here ####
+PREHOOK: type: CREATETABLE
+PREHOOK: Input: ### test.blobstore.path ###/orc_format_part/src_events
+PREHOOK: Output: database:default
+PREHOOK: Output: default@src_events
+POSTHOOK: query: CREATE TABLE src_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT,
+  run_date    STRING,
+  game_id     INT,
+  event_name  STRING
+)
+ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
+#### A masked pattern was here ####
+POSTHOOK: type: CREATETABLE
+POSTHOOK: Input: ### test.blobstore.path ###/orc_format_part/src_events
+POSTHOOK: Output: database:default
+POSTHOOK: Output: default@src_events
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/events.txt' INTO TABLE src_events
+PREHOOK: type: LOAD
+#### A masked pattern was here ####
+PREHOOK: Output: default@src_events
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/events.txt' INTO TABLE src_events
+POSTHOOK: type: LOAD
+#### A masked pattern was here ####
+POSTHOOK: Output: default@src_events
+PREHOOK: query: DROP TABLE orc_events
+PREHOOK: type: DROPTABLE
+POSTHOOK: query: DROP TABLE orc_events
+POSTHOOK: type: DROPTABLE
+PREHOOK: query: CREATE TABLE orc_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT
+)
+PARTITIONED BY (run_date STRING, game_id INT, event_name STRING)
+STORED AS ORC
+#### A masked pattern was here ####
+PREHOOK: type: CREATETABLE
+PREHOOK: Input: ### test.blobstore.path ###/orc_format_part/orc_events
+PREHOOK: Output: database:default
+PREHOOK: Output: default@orc_events
+POSTHOOK: query: CREATE TABLE orc_events
+(
+  log_id      BIGINT,
+  time        BIGINT,
+  uid         BIGINT,
+  user_id     BIGINT,
+  type        INT,
+  event_data  STRING,
+  session_id  STRING,
+  full_uid    BIGINT
+)
+PARTITIONED BY (run_date STRING, game_id INT, event_name STRING)
+STORED AS ORC
+#### A masked pattern was here ####
+POSTHOOK: type: CREATETABLE
+POSTHOOK: Input: ### test.blobstore.path ###/orc_format_part/orc_events
+POSTHOOK: Output: database:default
+POSTHOOK: Output: default@orc_events
+PREHOOK: query: INSERT OVERWRITE TABLE orc_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events
+PREHOOK: type: QUERY
+PREHOOK: Input: default@src_events
+PREHOOK: Output: default@orc_events
+POSTHOOK: query: INSERT OVERWRITE TABLE orc_events PARTITION (run_date, game_id, event_name)
+SELECT * FROM src_events
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@src_events
+POSTHOOK: Output: default@orc_events@run_date=20120921/game_id=39/event_name=hq_change
+POSTHOOK: Output: default@orc_events@run_date=20121021/game_id=39/event_name=hq_change
+POSTHOOK: Output: default@orc_events@run_date=20121121/game_id=39/event_name=hq_change
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20120921,game_id=39,event_name=hq_change).event_data SIMPLE [(src_events)src_events.FieldSchema(name:event_data, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20120921,game_id=39,event_name=hq_change).full_uid SIMPLE [(src_events)src_events.FieldSchema(name:full_uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20120921,game_id=39,event_name=hq_change).log_id SIMPLE [(src_events)src_events.FieldSchema(name:log_id, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20120921,game_id=39,event_name=hq_change).session_id SIMPLE [(src_events)src_events.FieldSchema(name:session_id, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20120921,game_id=39,event_name=hq_change).time SIMPLE [(src_events)src_events.FieldSchema(name:time, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20120921,game_id=39,event_name=hq_change).type SIMPLE [(src_events)src_events.FieldSchema(name:type, type:int, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20120921,game_id=39,event_name=hq_change).uid SIMPLE [(src_events)src_events.FieldSchema(name:uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20120921,game_id=39,event_name=hq_change).user_id SIMPLE [(src_events)src_events.FieldSchema(name:user_id, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121021,game_id=39,event_name=hq_change).event_data SIMPLE [(src_events)src_events.FieldSchema(name:event_data, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121021,game_id=39,event_name=hq_change).full_uid SIMPLE [(src_events)src_events.FieldSchema(name:full_uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121021,game_id=39,event_name=hq_change).log_id SIMPLE [(src_events)src_events.FieldSchema(name:log_id, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121021,game_id=39,event_name=hq_change).session_id SIMPLE [(src_events)src_events.FieldSchema(name:session_id, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121021,game_id=39,event_name=hq_change).time SIMPLE [(src_events)src_events.FieldSchema(name:time, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121021,game_id=39,event_name=hq_change).type SIMPLE [(src_events)src_events.FieldSchema(name:type, type:int, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121021,game_id=39,event_name=hq_change).uid SIMPLE [(src_events)src_events.FieldSchema(name:uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121021,game_id=39,event_name=hq_change).user_id SIMPLE [(src_events)src_events.FieldSchema(name:user_id, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121121,game_id=39,event_name=hq_change).event_data SIMPLE [(src_events)src_events.FieldSchema(name:event_data, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121121,game_id=39,event_name=hq_change).full_uid SIMPLE [(src_events)src_events.FieldSchema(name:full_uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121121,game_id=39,event_name=hq_change).log_id SIMPLE [(src_events)src_events.FieldSchema(name:log_id, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121121,game_id=39,event_name=hq_change).session_id SIMPLE [(src_events)src_events.FieldSchema(name:session_id, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121121,game_id=39,event_name=hq_change).time SIMPLE [(src_events)src_events.FieldSchema(name:time, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121121,game_id=39,event_name=hq_change).type SIMPLE [(src_events)src_events.FieldSchema(name:type, type:int, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121121,game_id=39,event_name=hq_change).uid SIMPLE [(src_events)src_events.FieldSchema(name:uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=20121121,game_id=39,event_name=hq_change).user_id SIMPLE [(src_events)src_events.FieldSchema(name:user_id, type:bigint, comment:null), ]
+PREHOOK: query: SHOW PARTITIONS orc_events
+PREHOOK: type: SHOWPARTITIONS
+PREHOOK: Input: default@orc_events
+POSTHOOK: query: SHOW PARTITIONS orc_events
+POSTHOOK: type: SHOWPARTITIONS
+POSTHOOK: Input: default@orc_events
+run_date=20120921/game_id=39/event_name=hq_change
+run_date=20121021/game_id=39/event_name=hq_change
+run_date=20121121/game_id=39/event_name=hq_change
+PREHOOK: query: SELECT COUNT(*) FROM orc_events
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT COUNT(*) FROM orc_events
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+200
+PREHOOK: query: SELECT COUNT(*) FROM orc_events WHERE run_date=20120921
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT COUNT(*) FROM orc_events WHERE run_date=20120921
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+50
+PREHOOK: query: SELECT COUNT(*) FROM orc_events WHERE run_date=20121121
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT COUNT(*) FROM orc_events WHERE run_date=20121121
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+100
+PREHOOK: query: INSERT OVERWRITE TABLE orc_events PARTITION (run_date=201211, game_id, event_name)
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid,game_id,event_name FROM src_events
+WHERE SUBSTR(run_date,1,6)='201211'
+PREHOOK: type: QUERY
+PREHOOK: Input: default@src_events
+PREHOOK: Output: default@orc_events@run_date=201211
+POSTHOOK: query: INSERT OVERWRITE TABLE orc_events PARTITION (run_date=201211, game_id, event_name)
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid,game_id,event_name FROM src_events
+WHERE SUBSTR(run_date,1,6)='201211'
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@src_events
+POSTHOOK: Output: default@orc_events@run_date=201211/game_id=39/event_name=hq_change
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201211,game_id=39,event_name=hq_change).event_data SIMPLE [(src_events)src_events.FieldSchema(name:event_data, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201211,game_id=39,event_name=hq_change).full_uid SIMPLE [(src_events)src_events.FieldSchema(name:full_uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201211,game_id=39,event_name=hq_change).log_id SIMPLE [(src_events)src_events.FieldSchema(name:log_id, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201211,game_id=39,event_name=hq_change).session_id SIMPLE [(src_events)src_events.FieldSchema(name:session_id, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201211,game_id=39,event_name=hq_change).time SIMPLE [(src_events)src_events.FieldSchema(name:time, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201211,game_id=39,event_name=hq_change).type SIMPLE [(src_events)src_events.FieldSchema(name:type, type:int, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201211,game_id=39,event_name=hq_change).uid SIMPLE [(src_events)src_events.FieldSchema(name:uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201211,game_id=39,event_name=hq_change).user_id SIMPLE [(src_events)src_events.FieldSchema(name:user_id, type:bigint, comment:null), ]
+PREHOOK: query: SHOW PARTITIONS orc_events
+PREHOOK: type: SHOWPARTITIONS
+PREHOOK: Input: default@orc_events
+POSTHOOK: query: SHOW PARTITIONS orc_events
+POSTHOOK: type: SHOWPARTITIONS
+POSTHOOK: Input: default@orc_events
+run_date=20120921/game_id=39/event_name=hq_change
+run_date=20121021/game_id=39/event_name=hq_change
+run_date=201211/game_id=39/event_name=hq_change
+run_date=20121121/game_id=39/event_name=hq_change
+PREHOOK: query: SELECT COUNT(*) FROM orc_events
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT COUNT(*) FROM orc_events
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+300
+PREHOOK: query: INSERT INTO TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name)
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid,event_name FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39
+PREHOOK: type: QUERY
+PREHOOK: Input: default@src_events
+PREHOOK: Output: default@orc_events@run_date=201209/game_id=39
+POSTHOOK: query: INSERT INTO TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name)
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid,event_name FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@src_events
+POSTHOOK: Output: default@orc_events@run_date=201209/game_id=39/event_name=hq_change
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201209,game_id=39,event_name=hq_change).event_data SIMPLE [(src_events)src_events.FieldSchema(name:event_data, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201209,game_id=39,event_name=hq_change).full_uid SIMPLE [(src_events)src_events.FieldSchema(name:full_uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201209,game_id=39,event_name=hq_change).log_id SIMPLE [(src_events)src_events.FieldSchema(name:log_id, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201209,game_id=39,event_name=hq_change).session_id SIMPLE [(src_events)src_events.FieldSchema(name:session_id, type:string, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201209,game_id=39,event_name=hq_change).time SIMPLE [(src_events)src_events.FieldSchema(name:time, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201209,game_id=39,event_name=hq_change).type SIMPLE [(src_events)src_events.FieldSchema(name:type, type:int, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201209,game_id=39,event_name=hq_change).uid SIMPLE [(src_events)src_events.FieldSchema(name:uid, type:bigint, comment:null), ]
+POSTHOOK: Lineage: orc_events PARTITION(run_date=201209,game_id=39,event_name=hq_change).user_id SIMPLE [(src_events)src_events.FieldSchema(name:user_id, type:bigint, comment:null), ]
+PREHOOK: query: SELECT COUNT(*) FROM orc_events
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT COUNT(*) FROM orc_events
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+350
+PREHOOK: query: INSERT INTO TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39 AND event_name='hq_change'
+PREHOOK: type: QUERY
+PREHOOK: Input: default@src_events
+PREHOOK: Output: default@orc_events@run_date=201209/game_id=39/event_name=hq_change
+POSTHOOK: query: INSERT INTO TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39 AND event_name='hq_change'
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@src_events
+POSTHOOK: Output: default@orc_events@run_date=201209/game_id=39/event_name=hq_change
+PREHOOK: query: SELECT COUNT(*) FROM orc_events
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT COUNT(*) FROM orc_events
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+400
+PREHOOK: query: INSERT OVERWRITE TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39 AND event_name='hq_change'
+PREHOOK: type: QUERY
+PREHOOK: Input: default@src_events
+PREHOOK: Output: default@orc_events@run_date=201209/game_id=39/event_name=hq_change
+POSTHOOK: query: INSERT OVERWRITE TABLE orc_events PARTITION (run_date=201209, game_id=39, event_name='hq_change')
+SELECT log_id,time,uid,user_id,type,event_data,session_id,full_uid FROM src_events
+WHERE SUBSTR(run_date,1,6)='201209' AND game_id=39 AND event_name='hq_change'
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@src_events
+POSTHOOK: Output: default@orc_events@run_date=201209/game_id=39/event_name=hq_change
+PREHOOK: query: SELECT COUNT(*) FROM orc_events
+PREHOOK: type: QUERY
+PREHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+POSTHOOK: query: SELECT COUNT(*) FROM orc_events
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@orc_events
+#### A masked pattern was here ####
+350


Mime
View raw message