You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by dj...@apache.org on 2018/01/10 22:48:07 UTC

hive git commit: HIVE-18408 : load data should rename files consistent with insert statements (bucketed tables only) Part10 (Deepak Jaiswal, reviewed by Eugene Koifman)

Repository: hive
Updated Branches:
  refs/heads/master 69d32f589 -> 15c2b524c


HIVE-18408 : load data should rename files consistent with insert statements (bucketed tables only) Part10 (Deepak Jaiswal, reviewed by Eugene Koifman)


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

Branch: refs/heads/master
Commit: 15c2b524cb1a3cc5ab14fba9a4f40a2389a6b00c
Parents: 69d32f5
Author: djaiswal <dj...@apache.org>
Authored: Wed Jan 10 14:46:19 2018 -0800
Committer: djaiswal <dj...@apache.org>
Committed: Wed Jan 10 14:47:48 2018 -0800

----------------------------------------------------------------------
 data/files/in/000000_0                              |  3 +++
 data/files/in/000001_0                              |  3 +++
 .../test/queries/clientpositive/auto_join_filters.q |  8 ++++----
 .../clientpositive/dynpart_sort_opt_bucketing.q     |  2 +-
 ql/src/test/queries/clientpositive/join_filters.q   | 10 +++++-----
 ql/src/test/queries/clientpositive/join_nulls.q     | 10 +++++-----
 .../clientpositive/dynpart_sort_opt_bucketing.q.out |  4 ++--
 .../clientpositive/llap/auto_join_filters.q.out     | 16 ++++++++--------
 .../results/clientpositive/llap/join_filters.q.out  | 16 ++++++++--------
 .../results/clientpositive/llap/join_nulls.q.out    | 16 ++++++++--------
 .../clientpositive/spark/auto_join_filters.q.out    | 16 ++++++++--------
 11 files changed, 55 insertions(+), 49 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/data/files/in/000000_0
----------------------------------------------------------------------
diff --git a/data/files/in/000000_0 b/data/files/in/000000_0
new file mode 100644
index 0000000..1a59496
--- /dev/null
+++ b/data/files/in/000000_0
@@ -0,0 +1,3 @@
+35
+48
+100100

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/data/files/in/000001_0
----------------------------------------------------------------------
diff --git a/data/files/in/000001_0 b/data/files/in/000001_0
new file mode 100644
index 0000000..71f7e09
--- /dev/null
+++ b/data/files/in/000001_0
@@ -0,0 +1,3 @@
+135
+148
+200200

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/ql/src/test/queries/clientpositive/auto_join_filters.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/auto_join_filters.q b/ql/src/test/queries/clientpositive/auto_join_filters.q
index a4d2b5c..a44ffb3 100644
--- a/ql/src/test/queries/clientpositive/auto_join_filters.q
+++ b/ql/src/test/queries/clientpositive/auto_join_filters.q
@@ -39,10 +39,10 @@ SELECT sum(hash(a.key,a.value,b.key,b.value)) FROM myinput1 a LEFT OUTER JOIN my
 
 CREATE TABLE smb_input1(key int, value int) CLUSTERED BY (key) SORTED BY (key) INTO 2 BUCKETS; 
 CREATE TABLE smb_input2(key int, value int) CLUSTERED BY (value) SORTED BY (value) INTO 2 BUCKETS; 
-LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1;
-LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1;
-LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2;
-LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2;
+LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1;
+LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1;
+LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2;
+LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2;
 
 SET hive.optimize.bucketmapjoin = true;
 SET hive.optimize.bucketmapjoin.sortedmerge = true;

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/ql/src/test/queries/clientpositive/dynpart_sort_opt_bucketing.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/dynpart_sort_opt_bucketing.q b/ql/src/test/queries/clientpositive/dynpart_sort_opt_bucketing.q
index 4520e2c..af9853c 100644
--- a/ql/src/test/queries/clientpositive/dynpart_sort_opt_bucketing.q
+++ b/ql/src/test/queries/clientpositive/dynpart_sort_opt_bucketing.q
@@ -12,7 +12,7 @@ clustered by(a)
 sorted by(a desc)
 into 256 buckets stored as textfile;
 
-load data local inpath '../../data/files/sortdp.txt' overwrite into table t1_staging partition (e='epart');
+load data local inpath '../../data/files/sortdp/000000_0' overwrite into table t1_staging partition (e='epart');
 
 set hive.optimize.sort.dynamic.partition=true;
 set hive.exec.dynamic.partition.mode=nonstrict;

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/ql/src/test/queries/clientpositive/join_filters.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/join_filters.q b/ql/src/test/queries/clientpositive/join_filters.q
index 0ff40b7..0113c40 100644
--- a/ql/src/test/queries/clientpositive/join_filters.q
+++ b/ql/src/test/queries/clientpositive/join_filters.q
@@ -57,11 +57,11 @@ SELECT /*+ MAPJOIN(a) */ * FROM myinput1 a RIGHT OUTER JOIN myinput1 b ON a.key
 SELECT /*+ MAPJOIN(a) */ * FROM myinput1 a RIGHT OUTER JOIN myinput1 b ON a.value = b.value AND a.key > 40 AND a.value > 50 AND a.key = a.value AND b.key > 40 AND b.value > 50 AND b.key = b.value;
 
 CREATE TABLE smb_input1(key int, value int) CLUSTERED BY (key) SORTED BY (key) INTO 2 BUCKETS; 
-CREATE TABLE smb_input2(key int, value int) CLUSTERED BY (value) SORTED BY (value) INTO 2 BUCKETS; 
-LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1;
-LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1;
-LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2;
-LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2;
+CREATE TABLE smb_input2(key int, value int) CLUSTERED BY (value) SORTED BY (value) INTO 2 BUCKETS;
+LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1;
+LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1;
+LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2;
+LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2;
 
 SET hive.optimize.bucketmapjoin = true;
 SET hive.optimize.bucketmapjoin.sortedmerge = true;

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/ql/src/test/queries/clientpositive/join_nulls.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/join_nulls.q b/ql/src/test/queries/clientpositive/join_nulls.q
index 09c55af..3b7ecd9 100644
--- a/ql/src/test/queries/clientpositive/join_nulls.q
+++ b/ql/src/test/queries/clientpositive/join_nulls.q
@@ -44,11 +44,11 @@ SELECT /*+ MAPJOIN(a) */ * FROM myinput1 a RIGHT OUTER JOIN myinput1 b ON a.key
 SELECT /*+ MAPJOIN(a) */ * FROM myinput1 a RIGHT OUTER JOIN myinput1 b ON a.value = b.value;
 
 CREATE TABLE smb_input1(key int, value int) CLUSTERED BY (key) SORTED BY (key) INTO 2 BUCKETS; 
-CREATE TABLE smb_input2(key int, value int) CLUSTERED BY (value) SORTED BY (value) INTO 2 BUCKETS; 
-LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1;
-LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1;
-LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2;
-LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2;
+CREATE TABLE smb_input2(key int, value int) CLUSTERED BY (value) SORTED BY (value) INTO 2 BUCKETS;
+LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1;
+LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1;
+LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2;
+LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2;
 
 SET hive.optimize.bucketmapjoin = true;
 SET hive.optimize.bucketmapjoin.sortedmerge = true;

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/ql/src/test/results/clientpositive/dynpart_sort_opt_bucketing.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/dynpart_sort_opt_bucketing.q.out b/ql/src/test/results/clientpositive/dynpart_sort_opt_bucketing.q.out
index e370c9d..3fbcec8 100644
--- a/ql/src/test/results/clientpositive/dynpart_sort_opt_bucketing.q.out
+++ b/ql/src/test/results/clientpositive/dynpart_sort_opt_bucketing.q.out
@@ -26,11 +26,11 @@ into 256 buckets stored as textfile
 POSTHOOK: type: CREATETABLE
 POSTHOOK: Output: database:default
 POSTHOOK: Output: default@t1_staging
-PREHOOK: query: load data local inpath '../../data/files/sortdp.txt' overwrite into table t1_staging partition (e='epart')
+PREHOOK: query: load data local inpath '../../data/files/sortdp/000000_0' overwrite into table t1_staging partition (e='epart')
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@t1_staging
-POSTHOOK: query: load data local inpath '../../data/files/sortdp.txt' overwrite into table t1_staging partition (e='epart')
+POSTHOOK: query: load data local inpath '../../data/files/sortdp/000000_0' overwrite into table t1_staging partition (e='epart')
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@t1_staging

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/ql/src/test/results/clientpositive/llap/auto_join_filters.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/auto_join_filters.q.out b/ql/src/test/results/clientpositive/llap/auto_join_filters.q.out
index 079f047..540612d 100644
--- a/ql/src/test/results/clientpositive/llap/auto_join_filters.q.out
+++ b/ql/src/test/results/clientpositive/llap/auto_join_filters.q.out
@@ -268,35 +268,35 @@ POSTHOOK: query: CREATE TABLE smb_input2(key int, value int) CLUSTERED BY (value
 POSTHOOK: type: CREATETABLE
 POSTHOOK: Output: database:default
 POSTHOOK: Output: default@smb_input2
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input1
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input1
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input1
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input1
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input2
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input2
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input2
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input2

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/ql/src/test/results/clientpositive/llap/join_filters.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/join_filters.q.out b/ql/src/test/results/clientpositive/llap/join_filters.q.out
index 191c976..41106ed 100644
--- a/ql/src/test/results/clientpositive/llap/join_filters.q.out
+++ b/ql/src/test/results/clientpositive/llap/join_filters.q.out
@@ -552,35 +552,35 @@ POSTHOOK: query: CREATE TABLE smb_input2(key int, value int) CLUSTERED BY (value
 POSTHOOK: type: CREATETABLE
 POSTHOOK: Output: database:default
 POSTHOOK: Output: default@smb_input2
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input1
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input1
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input1
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input1
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input2
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input2
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input2
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input2

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/ql/src/test/results/clientpositive/llap/join_nulls.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/join_nulls.q.out b/ql/src/test/results/clientpositive/llap/join_nulls.q.out
index 5427b9f..a680324 100644
--- a/ql/src/test/results/clientpositive/llap/join_nulls.q.out
+++ b/ql/src/test/results/clientpositive/llap/join_nulls.q.out
@@ -444,35 +444,35 @@ POSTHOOK: query: CREATE TABLE smb_input2(key int, value int) CLUSTERED BY (value
 POSTHOOK: type: CREATETABLE
 POSTHOOK: Output: database:default
 POSTHOOK: Output: default@smb_input2
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input1
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input1
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input1
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input1
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input2
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input2
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input2
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input2

http://git-wip-us.apache.org/repos/asf/hive/blob/15c2b524/ql/src/test/results/clientpositive/spark/auto_join_filters.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/spark/auto_join_filters.q.out b/ql/src/test/results/clientpositive/spark/auto_join_filters.q.out
index c00fdf1..8ae5a0e 100644
--- a/ql/src/test/results/clientpositive/spark/auto_join_filters.q.out
+++ b/ql/src/test/results/clientpositive/spark/auto_join_filters.q.out
@@ -268,35 +268,35 @@ POSTHOOK: query: CREATE TABLE smb_input2(key int, value int) CLUSTERED BY (value
 POSTHOOK: type: CREATETABLE
 POSTHOOK: Output: database:default
 POSTHOOK: Output: default@smb_input2
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input1
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input1
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input1
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input1
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input1
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input1
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input1
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input1
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input2
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in1.txt' into table smb_input2
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000000_0' into table smb_input2
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input2
-PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2
+PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2
 PREHOOK: type: LOAD
 #### A masked pattern was here ####
 PREHOOK: Output: default@smb_input2
-POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in2.txt' into table smb_input2
+POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/in/000001_0' into table smb_input2
 POSTHOOK: type: LOAD
 #### A masked pattern was here ####
 POSTHOOK: Output: default@smb_input2