Skip to content

Commit d9ec041

Browse files
armitage420araika
armitage420
and
araika
authored
HIVE-20889: Support timestamp-micros in AvroSerDe (#5779)
Co-authored-by: araika <[email protected]>
1 parent aa800ef commit d9ec041

File tree

19 files changed

+420
-23
lines changed

19 files changed

+420
-23
lines changed

‎common/src/java/org/apache/hadoop/hive/common/type/Timestamp.java‎

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -163,6 +163,11 @@ public long toEpochMilli() {
163163
return localDateTime.toInstant(ZoneOffset.UTC).toEpochMilli();
164164
}
165165

166+
public long toEpochMicro() {
167+
return localDateTime.toEpochSecond(ZoneOffset.UTC) * 1_000_000
168+
+ localDateTime.getNano() / 1000;
169+
}
170+
166171
public long toEpochMilli(ZoneId id) {
167172
return localDateTime.atZone(id).toInstant().toEpochMilli();
168173
}
@@ -237,6 +242,18 @@ public static Timestamp ofEpochMilli(long epochMilli, int nanos) {
237242
.withNano(nanos));
238243
}
239244

245+
public static Timestamp ofEpochMicro(long epochMicro) {
246+
int nanos = Math.toIntExact((epochMicro % 1000000) * 1000);
247+
epochMicro -= nanos / 1_000_000;
248+
249+
Instant instant = Instant.ofEpochSecond(
250+
epochMicro / 1_000_000,
251+
nanos
252+
);
253+
254+
return new Timestamp(LocalDateTime.ofInstant(instant, ZoneOffset.UTC));
255+
}
256+
240257
public void setNanos(int nanos) {
241258
localDateTime = localDateTime.withNano(nanos);
242259
}

‎data/files/avro_timestamp.txt‎

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,4 +5,12 @@
55
1412-02-21 07:08:09.123|foo:0980-12-16 07:08:09.123,bar:0998-05-07 07:08:09.123|0011-09-04 07:08:09.123,0011-09-05 07:08:09.123
66
1214-02-11 07:08:09.123|baz:0981-12-16 07:08:09.123|0011-09-05 07:08:09.123
77
0847-02-11 07:08:09.123|baz:0921-12-16 07:08:09.123|0011-09-05 07:08:09.123
8-
0600-02-11 07:08:09.123|baz:0981-12-16 07:08:09.123|0039-09-05 07:08:09.123
8+
0600-02-11 07:08:09.123|baz:0981-12-16 07:08:09.123|0039-09-05 07:08:09.123
9+
2012-02-21 07:08:09.123456|foo:1980-12-16 07:08:09.123456,bar:1998-05-07 07:08:09.123456|2011-09-04 07:08:09.123456,2011-09-05 07:08:09.123456
10+
2014-02-11 07:08:09.123456|baz:1981-12-16 07:08:09.123456|2011-09-05 07:08:09.123456
11+
1947-02-11 07:08:09.123456|baz:1921-12-16 07:08:09.123456|2011-09-05 07:08:09.123456
12+
8200-02-11 07:08:09.123456|baz:6981-12-16 07:08:09.123456|1039-09-05 07:08:09.123456
13+
1412-02-21 07:08:09.123456|foo:0980-12-16 07:08:09.123456,bar:0998-05-07 07:08:09.123456|0011-09-04 07:08:09.123456,0011-09-05 07:08:09.123456
14+
1214-02-11 07:08:09.123456|baz:0981-12-16 07:08:09.123456|0011-09-05 07:08:09.123456
15+
0847-02-11 07:08:09.123456|baz:0921-12-16 07:08:09.123456|0011-09-05 07:08:09.123456
16+
0600-02-11 07:08:09.123456|baz:0981-12-16 07:08:09.123456|0039-09-05 07:08:09.123456

‎ql/src/test/queries/clientpositive/avro_hybrid_mixed_timestamp.q‎

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,17 @@ stored as avro;
66
INSERT INTO hybrid_table VALUES
77
('2012-02-21 07:08:09.123'),
88
('2014-02-11 07:08:09.123'),
9+
('2014-02-11 07:08:09.123456'),
910
('1947-02-11 07:08:09.123'),
1011
('8200-02-11 07:08:09.123'),
12+
('8200-02-11 07:08:09.123456'),
1113
('1012-02-21 07:15:11.123'),
14+
('1012-02-21 07:15:11.12345'),
1215
('1014-02-11 07:15:11.123'),
16+
('1014-02-11 07:15:11.1234'),
1317
('0947-02-11 07:15:11.123'),
14-
('0200-02-11 07:15:11.123');
18+
('0200-02-11 07:15:11.123'),
19+
('0200-02-11 07:15:11.1234');
1520

1621
select * from hybrid_table;
1722

‎ql/src/test/queries/clientpositive/avro_proleptic_mixed_timestamp.q‎

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,12 +8,17 @@ stored as avro;
88
INSERT INTO hybrid_table VALUES
99
('2012-02-21 07:08:09.123'),
1010
('2014-02-11 07:08:09.123'),
11+
('2014-02-11 07:08:09.123456'),
1112
('1947-02-11 07:08:09.123'),
13+
('1947-02-11 07:08:09.1234'),
1214
('8200-02-11 07:08:09.123'),
1315
('1012-02-21 07:15:11.123'),
16+
('1012-02-21 07:15:11.12345'),
1417
('1014-02-11 07:15:11.123'),
1518
('0947-02-11 07:15:11.123'),
16-
('0200-02-11 07:15:11.123');
19+
('0947-02-11 07:15:11.12345'),
20+
('0200-02-11 07:15:11.123'),
21+
('0200-02-11 07:15:11.123456');
1722

1823
select * from hybrid_table;
1924

‎ql/src/test/queries/clientpositive/avro_timestamp_micros.q‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
CREATE EXTERNAL TABLE micros_table(`dt` timestamp)
2+
STORED AS AVRO;
3+
4+
INSERT INTO micros_table VALUES
5+
(cast('2024-08-09 14:08:26.326107' as timestamp)),
6+
('2012-02-21 07:08:09.123'),
7+
('1014-02-11 07:15:11.12345');
8+
9+
SELECT * FROM micros_table;

‎ql/src/test/results/clientpositive/llap/avro_hybrid_mixed_timestamp.q.out‎

Lines changed: 22 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,24 +15,34 @@ POSTHOOK: Output: default@hybrid_table
1515
PREHOOK: query: INSERT INTO hybrid_table VALUES
1616
('2012-02-21 07:08:09.123'),
1717
('2014-02-11 07:08:09.123'),
18+
('2014-02-11 07:08:09.123456'),
1819
('1947-02-11 07:08:09.123'),
1920
('8200-02-11 07:08:09.123'),
21+
('8200-02-11 07:08:09.123456'),
2022
('1012-02-21 07:15:11.123'),
23+
('1012-02-21 07:15:11.12345'),
2124
('1014-02-11 07:15:11.123'),
25+
('1014-02-11 07:15:11.1234'),
2226
('0947-02-11 07:15:11.123'),
23-
('0200-02-11 07:15:11.123')
27+
('0200-02-11 07:15:11.123'),
28+
('0200-02-11 07:15:11.1234')
2429
PREHOOK: type: QUERY
2530
PREHOOK: Input: _dummy_database@_dummy_table
2631
PREHOOK: Output: default@hybrid_table
2732
POSTHOOK: query: INSERT INTO hybrid_table VALUES
2833
('2012-02-21 07:08:09.123'),
2934
('2014-02-11 07:08:09.123'),
35+
('2014-02-11 07:08:09.123456'),
3036
('1947-02-11 07:08:09.123'),
3137
('8200-02-11 07:08:09.123'),
38+
('8200-02-11 07:08:09.123456'),
3239
('1012-02-21 07:15:11.123'),
40+
('1012-02-21 07:15:11.12345'),
3341
('1014-02-11 07:15:11.123'),
42+
('1014-02-11 07:15:11.1234'),
3443
('0947-02-11 07:15:11.123'),
35-
('0200-02-11 07:15:11.123')
44+
('0200-02-11 07:15:11.123'),
45+
('0200-02-11 07:15:11.1234')
3646
POSTHOOK: type: QUERY
3747
POSTHOOK: Input: _dummy_database@_dummy_table
3848
POSTHOOK: Output: default@hybrid_table
@@ -47,12 +57,17 @@ POSTHOOK: Input: default@hybrid_table
4757
#### A masked pattern was here ####
4858
2012-02-21 07:08:09.123
4959
2014-02-11 07:08:09.123
60+
2014-02-11 07:08:09.123456
5061
1947-02-11 07:08:09.123
5162
8200-02-11 07:08:09.123
63+
8200-02-11 07:08:09.123456
5264
1012-02-21 07:15:11.123
65+
1012-02-21 07:15:11.12345
5366
1014-02-11 07:15:11.123
67+
1014-02-11 07:15:11.1234
5468
0947-02-11 07:15:11.123
5569
0200-02-11 07:15:11.123
70+
0200-02-11 07:15:11.1234
5671
PREHOOK: query: select * from hybrid_table
5772
PREHOOK: type: QUERY
5873
PREHOOK: Input: default@hybrid_table
@@ -63,12 +78,17 @@ POSTHOOK: Input: default@hybrid_table
6378
#### A masked pattern was here ####
6479
2012-02-21 07:08:09.123
6580
2014-02-11 07:08:09.123
81+
2014-02-11 07:08:09.123456
6682
1947-02-11 07:08:09.123
6783
8200-02-11 07:08:09.123
84+
8200-02-11 07:08:09.123456
6885
1012-02-21 07:15:11.123
86+
1012-02-21 07:15:11.12345
6987
1014-02-11 07:15:11.123
88+
1014-02-11 07:15:11.1234
7089
0947-02-11 07:15:11.123
7190
0200-02-11 07:15:11.123
91+
0200-02-11 07:15:11.1234
7292
PREHOOK: query: drop table hybrid_table
7393
PREHOOK: type: DROPTABLE
7494
PREHOOK: Input: default@hybrid_table

‎ql/src/test/results/clientpositive/llap/avro_proleptic_mixed_timestamp.q.out‎

Lines changed: 22 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,24 +15,34 @@ POSTHOOK: Output: default@hybrid_table
1515
PREHOOK: query: INSERT INTO hybrid_table VALUES
1616
('2012-02-21 07:08:09.123'),
1717
('2014-02-11 07:08:09.123'),
18+
('2014-02-11 07:08:09.123456'),
1819
('1947-02-11 07:08:09.123'),
20+
('1947-02-11 07:08:09.1234'),
1921
('8200-02-11 07:08:09.123'),
2022
('1012-02-21 07:15:11.123'),
23+
('1012-02-21 07:15:11.12345'),
2124
('1014-02-11 07:15:11.123'),
2225
('0947-02-11 07:15:11.123'),
23-
('0200-02-11 07:15:11.123')
26+
('0947-02-11 07:15:11.12345'),
27+
('0200-02-11 07:15:11.123'),
28+
('0200-02-11 07:15:11.123456')
2429
PREHOOK: type: QUERY
2530
PREHOOK: Input: _dummy_database@_dummy_table
2631
PREHOOK: Output: default@hybrid_table
2732
POSTHOOK: query: INSERT INTO hybrid_table VALUES
2833
('2012-02-21 07:08:09.123'),
2934
('2014-02-11 07:08:09.123'),
35+
('2014-02-11 07:08:09.123456'),
3036
('1947-02-11 07:08:09.123'),
37+
('1947-02-11 07:08:09.1234'),
3138
('8200-02-11 07:08:09.123'),
3239
('1012-02-21 07:15:11.123'),
40+
('1012-02-21 07:15:11.12345'),
3341
('1014-02-11 07:15:11.123'),
3442
('0947-02-11 07:15:11.123'),
35-
('0200-02-11 07:15:11.123')
43+
('0947-02-11 07:15:11.12345'),
44+
('0200-02-11 07:15:11.123'),
45+
('0200-02-11 07:15:11.123456')
3646
POSTHOOK: type: QUERY
3747
POSTHOOK: Input: _dummy_database@_dummy_table
3848
POSTHOOK: Output: default@hybrid_table
@@ -47,12 +57,17 @@ POSTHOOK: Input: default@hybrid_table
4757
#### A masked pattern was here ####
4858
2012-02-21 07:08:09.123
4959
2014-02-11 07:08:09.123
60+
2014-02-11 07:08:09.123456
5061
1947-02-11 07:08:09.123
62+
1947-02-11 07:08:09.1234
5163
8200-02-11 07:08:09.123
5264
1012-02-21 07:15:11.123
65+
1012-02-21 07:15:11.12345
5366
1014-02-11 07:15:11.123
5467
0947-02-11 07:15:11.123
68+
0947-02-11 07:15:11.12345
5569
0200-02-11 07:15:11.123
70+
0200-02-11 07:15:11.123456
5671
PREHOOK: query: select * from hybrid_table
5772
PREHOOK: type: QUERY
5873
PREHOOK: Input: default@hybrid_table
@@ -63,12 +78,17 @@ POSTHOOK: Input: default@hybrid_table
6378
#### A masked pattern was here ####
6479
2012-02-21 07:08:09.123
6580
2014-02-11 07:08:09.123
81+
2014-02-11 07:08:09.123456
6682
1947-02-11 07:08:09.123
83+
1947-02-11 07:08:09.1234
6784
8200-02-11 07:08:09.123
6885
1012-02-21 07:15:11.123
86+
1012-02-21 07:15:11.12345
6987
1014-02-11 07:15:11.123
7088
0947-02-11 07:15:11.123
89+
0947-02-11 07:15:11.12345
7190
0200-02-11 07:15:11.123
91+
0200-02-11 07:15:11.123456
7292
PREHOOK: query: drop table hybrid_table
7393
PREHOOK: type: DROPTABLE
7494
PREHOOK: Input: default@hybrid_table

‎ql/src/test/results/clientpositive/llap/avro_timestamp.q.out‎

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,14 @@ POSTHOOK: Input: default@avro_timestamp@p1=2/p2=2014-09-26 07%3A08%3A09.123
8383
1214-02-11 07:08:09.123 {"baz":"0981-12-16 07:08:09.123"} ["0011-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
8484
0847-02-11 07:08:09.123 {"baz":"0921-12-16 07:08:09.123"} ["0011-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
8585
0600-02-11 07:08:09.123 {"baz":"0981-12-16 07:08:09.123"} ["0039-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
86+
2012-02-21 07:08:09.123456 {"bar":"1998-05-07 07:08:09.123456","foo":"1980-12-16 07:08:09.123456"} ["2011-09-04 07:08:09.123456","2011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
87+
2014-02-11 07:08:09.123456 {"baz":"1981-12-16 07:08:09.123456"} ["2011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
88+
1947-02-11 07:08:09.123456 {"baz":"1921-12-16 07:08:09.123456"} ["2011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
89+
8200-02-11 07:08:09.123456 {"baz":"6981-12-16 07:08:09.123456"} ["1039-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
90+
1412-02-21 07:08:09.123456 {"bar":"0998-05-07 07:08:09.123456","foo":"0980-12-16 07:08:09.123456"} ["0011-09-04 07:08:09.123456","0011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
91+
1214-02-11 07:08:09.123456 {"baz":"0981-12-16 07:08:09.123456"} ["0011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
92+
0847-02-11 07:08:09.123456 {"baz":"0921-12-16 07:08:09.123456"} ["0011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
93+
0600-02-11 07:08:09.123456 {"baz":"0981-12-16 07:08:09.123456"} ["0039-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
8694
PREHOOK: query: SELECT d, COUNT(d) FROM avro_timestamp GROUP BY d
8795
PREHOOK: type: QUERY
8896
PREHOOK: Input: default@avro_timestamp
@@ -97,10 +105,18 @@ POSTHOOK: Input: default@avro_timestamp@p1=2/p2=2014-09-26 07%3A08%3A09.123
97105
1214-02-11 07:08:09.123 1
98106
1947-02-11 07:08:09.123 1
99107
2014-02-11 07:08:09.123 1
108+
0600-02-11 07:08:09.123456 1
100109
0847-02-11 07:08:09.123 1
110+
0847-02-11 07:08:09.123456 1
111+
1214-02-11 07:08:09.123456 1
101112
1412-02-21 07:08:09.123 1
113+
1412-02-21 07:08:09.123456 1
114+
1947-02-11 07:08:09.123456 1
102115
2012-02-21 07:08:09.123 1
116+
2012-02-21 07:08:09.123456 1
117+
2014-02-11 07:08:09.123456 1
103118
8200-02-11 07:08:09.123 1
119+
8200-02-11 07:08:09.123456 1
104120
PREHOOK: query: SELECT * FROM avro_timestamp WHERE d!='1947-02-11 07:08:09.123'
105121
PREHOOK: type: QUERY
106122
PREHOOK: Input: default@avro_timestamp
@@ -118,6 +134,14 @@ POSTHOOK: Input: default@avro_timestamp@p1=2/p2=2014-09-26 07%3A08%3A09.123
118134
1214-02-11 07:08:09.123 {"baz":"0981-12-16 07:08:09.123"} ["0011-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
119135
0847-02-11 07:08:09.123 {"baz":"0921-12-16 07:08:09.123"} ["0011-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
120136
0600-02-11 07:08:09.123 {"baz":"0981-12-16 07:08:09.123"} ["0039-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
137+
2012-02-21 07:08:09.123456 {"bar":"1998-05-07 07:08:09.123456","foo":"1980-12-16 07:08:09.123456"} ["2011-09-04 07:08:09.123456","2011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
138+
2014-02-11 07:08:09.123456 {"baz":"1981-12-16 07:08:09.123456"} ["2011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
139+
1947-02-11 07:08:09.123456 {"baz":"1921-12-16 07:08:09.123456"} ["2011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
140+
8200-02-11 07:08:09.123456 {"baz":"6981-12-16 07:08:09.123456"} ["1039-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
141+
1412-02-21 07:08:09.123456 {"bar":"0998-05-07 07:08:09.123456","foo":"0980-12-16 07:08:09.123456"} ["0011-09-04 07:08:09.123456","0011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
142+
1214-02-11 07:08:09.123456 {"baz":"0981-12-16 07:08:09.123456"} ["0011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
143+
0847-02-11 07:08:09.123456 {"baz":"0921-12-16 07:08:09.123456"} ["0011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
144+
0600-02-11 07:08:09.123456 {"baz":"0981-12-16 07:08:09.123456"} ["0039-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
121145
PREHOOK: query: SELECT * FROM avro_timestamp WHERE d<'2014-12-21 07:08:09.123'
122146
PREHOOK: type: QUERY
123147
PREHOOK: Input: default@avro_timestamp
@@ -135,6 +159,13 @@ POSTHOOK: Input: default@avro_timestamp@p1=2/p2=2014-09-26 07%3A08%3A09.123
135159
1214-02-11 07:08:09.123 {"baz":"0981-12-16 07:08:09.123"} ["0011-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
136160
0847-02-11 07:08:09.123 {"baz":"0921-12-16 07:08:09.123"} ["0011-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
137161
0600-02-11 07:08:09.123 {"baz":"0981-12-16 07:08:09.123"} ["0039-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
162+
2012-02-21 07:08:09.123456 {"bar":"1998-05-07 07:08:09.123456","foo":"1980-12-16 07:08:09.123456"} ["2011-09-04 07:08:09.123456","2011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
163+
2014-02-11 07:08:09.123456 {"baz":"1981-12-16 07:08:09.123456"} ["2011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
164+
1947-02-11 07:08:09.123456 {"baz":"1921-12-16 07:08:09.123456"} ["2011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
165+
1412-02-21 07:08:09.123456 {"bar":"0998-05-07 07:08:09.123456","foo":"0980-12-16 07:08:09.123456"} ["0011-09-04 07:08:09.123456","0011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
166+
1214-02-11 07:08:09.123456 {"baz":"0981-12-16 07:08:09.123456"} ["0011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
167+
0847-02-11 07:08:09.123456 {"baz":"0921-12-16 07:08:09.123456"} ["0011-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
168+
0600-02-11 07:08:09.123456 {"baz":"0981-12-16 07:08:09.123456"} ["0039-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123
138169
PREHOOK: query: SELECT * FROM avro_timestamp WHERE d>'8000-12-01 07:08:09.123'
139170
PREHOOK: type: QUERY
140171
PREHOOK: Input: default@avro_timestamp
@@ -146,3 +177,4 @@ POSTHOOK: Input: default@avro_timestamp
146177
POSTHOOK: Input: default@avro_timestamp@p1=2/p2=2014-09-26 07%3A08%3A09.123
147178
#### A masked pattern was here ####
148179
8200-02-11 07:08:09.123 {"baz":"6981-12-16 07:08:09.123"} ["1039-09-05 07:08:09.123"] 2 2014-09-26 07:08:09.123
180+
8200-02-11 07:08:09.123456 {"baz":"6981-12-16 07:08:09.123456"} ["1039-09-05 07:08:09.123456"] 2 2014-09-26 07:08:09.123

‎ql/src/test/results/clientpositive/llap/avro_timestamp_micros.q.out‎

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
PREHOOK: query: CREATE EXTERNAL TABLE micros_table(`dt` timestamp)
2+
STORED AS AVRO
3+
PREHOOK: type: CREATETABLE
4+
PREHOOK: Output: database:default
5+
PREHOOK: Output: default@micros_table
6+
POSTHOOK: query: CREATE EXTERNAL TABLE micros_table(`dt` timestamp)
7+
STORED AS AVRO
8+
POSTHOOK: type: CREATETABLE
9+
POSTHOOK: Output: database:default
10+
POSTHOOK: Output: default@micros_table
11+
PREHOOK: query: INSERT INTO micros_table VALUES
12+
(cast('2024-08-09 14:08:26.326107' as timestamp)),
13+
('2012-02-21 07:08:09.123'),
14+
('1014-02-11 07:15:11.12345')
15+
PREHOOK: type: QUERY
16+
PREHOOK: Input: _dummy_database@_dummy_table
17+
PREHOOK: Output: default@micros_table
18+
POSTHOOK: query: INSERT INTO micros_table VALUES
19+
(cast('2024-08-09 14:08:26.326107' as timestamp)),
20+
('2012-02-21 07:08:09.123'),
21+
('1014-02-11 07:15:11.12345')
22+
POSTHOOK: type: QUERY
23+
POSTHOOK: Input: _dummy_database@_dummy_table
24+
POSTHOOK: Output: default@micros_table
25+
POSTHOOK: Lineage: micros_table.dt SCRIPT []
26+
PREHOOK: query: SELECT * FROM micros_table
27+
PREHOOK: type: QUERY
28+
PREHOOK: Input: default@micros_table
29+
#### A masked pattern was here ####
30+
POSTHOOK: query: SELECT * FROM micros_table
31+
POSTHOOK: type: QUERY
32+
POSTHOOK: Input: default@micros_table
33+
#### A masked pattern was here ####
34+
2024-08-09 14:08:26.326107
35+
2012-02-21 07:08:09.123
36+
1014-02-11 07:15:11.12345

0 commit comments

Comments
 (0)