Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -578,6 +578,10 @@ private static TypeInfo columnVectorTypeToTypeInfo(Type type) {
return TypeInfoUtils.getTypeInfoFromTypeString(serdeConstants.TIMESTAMP_TYPE_NAME);
case LONG:
return TypeInfoUtils.getTypeInfoFromTypeString(serdeConstants.INT_TYPE_NAME);
case INTERVAL_DAY_TIME:
return TypeInfoUtils.getTypeInfoFromTypeString(serdeConstants.INTERVAL_DAY_TIME_TYPE_NAME);
case VOID:
return TypeInfoUtils.getTypeInfoFromTypeString(serdeConstants.VOID_TYPE_NAME);
default:
throw new RuntimeException("Cannot convert column vector type: '" + type + "' to TypeInfo");
}
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,10 @@
create table vectptf(age int, name string) stored as orc;
insert into vectptf values(20, 'PQR'), (10, 'ABC'), (30, 'XYZ');

select cast(row_number() over(order by NULL) as STRING), age, name from vectptf;
select cast(rank() over(order by INTERVAL '1' DAY) as STRING), age, name from vectptf;

set hive.vectorized.execution.ptf.enabled=false;

select cast(row_number() over(order by NULL) as STRING), age, name from vectptf;
select cast(rank() over(order by INTERVAL '1' DAY) as STRING), age, name from vectptf;
Original file line number Diff line number Diff line change
@@ -0,0 +1,62 @@
PREHOOK: query: create table vectptf(age int, name string) stored as orc
PREHOOK: type: CREATETABLE
PREHOOK: Output: database:default
PREHOOK: Output: default@vectptf
POSTHOOK: query: create table vectptf(age int, name string) stored as orc
POSTHOOK: type: CREATETABLE
POSTHOOK: Output: database:default
POSTHOOK: Output: default@vectptf
PREHOOK: query: insert into vectptf values(20, 'PQR'), (10, 'ABC'), (30, 'XYZ')
PREHOOK: type: QUERY
PREHOOK: Input: _dummy_database@_dummy_table
PREHOOK: Output: default@vectptf
POSTHOOK: query: insert into vectptf values(20, 'PQR'), (10, 'ABC'), (30, 'XYZ')
POSTHOOK: type: QUERY
POSTHOOK: Input: _dummy_database@_dummy_table
POSTHOOK: Output: default@vectptf
POSTHOOK: Lineage: vectptf.age SCRIPT []
POSTHOOK: Lineage: vectptf.name SCRIPT []
PREHOOK: query: select cast(row_number() over(order by NULL) as STRING), age, name from vectptf
PREHOOK: type: QUERY
PREHOOK: Input: default@vectptf
#### A masked pattern was here ####
POSTHOOK: query: select cast(row_number() over(order by NULL) as STRING), age, name from vectptf
POSTHOOK: type: QUERY
POSTHOOK: Input: default@vectptf
#### A masked pattern was here ####
1 20 PQR
2 10 ABC
3 30 XYZ
PREHOOK: query: select cast(rank() over(order by INTERVAL '1' DAY) as STRING), age, name from vectptf
PREHOOK: type: QUERY
PREHOOK: Input: default@vectptf
#### A masked pattern was here ####
POSTHOOK: query: select cast(rank() over(order by INTERVAL '1' DAY) as STRING), age, name from vectptf
POSTHOOK: type: QUERY
POSTHOOK: Input: default@vectptf
#### A masked pattern was here ####
1 20 PQR
1 10 ABC
1 30 XYZ
PREHOOK: query: select cast(row_number() over(order by NULL) as STRING), age, name from vectptf
PREHOOK: type: QUERY
PREHOOK: Input: default@vectptf
#### A masked pattern was here ####
POSTHOOK: query: select cast(row_number() over(order by NULL) as STRING), age, name from vectptf
POSTHOOK: type: QUERY
POSTHOOK: Input: default@vectptf
#### A masked pattern was here ####
1 20 PQR
2 10 ABC
3 30 XYZ
PREHOOK: query: select cast(rank() over(order by INTERVAL '1' DAY) as STRING), age, name from vectptf
PREHOOK: type: QUERY
PREHOOK: Input: default@vectptf
#### A masked pattern was here ####
POSTHOOK: query: select cast(rank() over(order by INTERVAL '1' DAY) as STRING), age, name from vectptf
POSTHOOK: type: QUERY
POSTHOOK: Input: default@vectptf
#### A masked pattern was here ####
1 20 PQR
1 10 ABC
1 30 XYZ
Loading