http://git-wip-us.apache.org/repos/asf/hive/blob/6a99cf53/ql/src/test/results/clientpositive/vector_windowing_range_multiorder.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/vector_windowing_range_multiorder.q.out b/ql/src/test/results/clientpositive/vector_windowing_range_multiorder.q.out index ac65a98..336bc78 100644 --- a/ql/src/test/results/clientpositive/vector_windowing_range_multiorder.q.out +++ b/ql/src/test/results/clientpositive/vector_windowing_range_multiorder.q.out @@ -65,7 +65,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 50877 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -78,7 +78,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 50877 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE value expressions: t (type: tinyint) Execution mode: vectorized Map Vectorization: @@ -102,7 +102,7 @@ STAGE PLANS: Select Operator expressions: VALUE._col0 (type: tinyint), KEY.reducesinkkey0 (type: smallint), KEY.reducesinkkey1 (type: int), KEY.reducesinkkey2 (type: bigint) outputColumnNames: _col0, _col1, _col2, _col3 - Statistics: Num rows: 50877 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -122,17 +122,17 @@ STAGE PLANS: name: first_value window function: GenericUDAFFirstValueEvaluator window frame: RANGE PRECEDING(MAX)~CURRENT - Statistics: Num rows: 50877 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: first_value_window_0 (type: tinyint) outputColumnNames: _col0 - Statistics: Num rows: 50877 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 2000 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 2000 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -274,7 +274,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -287,7 +287,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -310,7 +310,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: smallint), KEY.reducesinkkey2 (type: int), KEY.reducesinkkey3 (type: float), KEY.reducesinkkey1 (type: boolean) outputColumnNames: _col1, _col2, _col4, _col6 - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -330,17 +330,17 @@ STAGE PLANS: name: last_value window function: GenericUDAFLastValueEvaluator window frame: RANGE CURRENT~CURRENT - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: last_value_window_0 (type: int) outputColumnNames: _col0 - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 1600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 1600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -482,7 +482,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -495,7 +495,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -518,7 +518,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: smallint), KEY.reducesinkkey2 (type: int), KEY.reducesinkkey3 (type: float), KEY.reducesinkkey1 (type: boolean) outputColumnNames: _col1, _col2, _col4, _col6 - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -538,17 +538,17 @@ STAGE PLANS: window function: GenericUDAFRowNumberEvaluator window frame: RANGE PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: row_number_window_0 (type: int) outputColumnNames: _col0 - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 1600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 1600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -690,7 +690,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -703,7 +703,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE value expressions: si (type: smallint), i (type: int) Execution mode: vectorized Map Vectorization: @@ -727,7 +727,7 @@ STAGE PLANS: Select Operator expressions: VALUE._col1 (type: smallint), VALUE._col2 (type: int), KEY.reducesinkkey0 (type: string) outputColumnNames: _col1, _col2, _col7 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -747,14 +747,14 @@ STAGE PLANS: name: avg window function: GenericUDAFAverageEvaluatorDouble window frame: RANGE PRECEDING(MAX)~CURRENT - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col7 (type: string), _col1 (type: smallint), _col2 (type: int), avg_window_0 (type: double) outputColumnNames: _col0, _col1, _col2, _col3 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -10795,7 +10795,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -10808,7 +10808,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -10831,7 +10831,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey1 (type: smallint), KEY.reducesinkkey2 (type: int), KEY.reducesinkkey0 (type: string) outputColumnNames: _col1, _col2, _col7 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -10851,17 +10851,17 @@ STAGE PLANS: name: avg window function: GenericUDAFAverageEvaluatorDouble window frame: RANGE PRECEDING(MAX)~CURRENT - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col7 (type: string), _col1 (type: smallint), _col2 (type: int), avg_window_0 (type: double) outputColumnNames: _col0, _col1, _col2, _col3 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 10800 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 10800 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -11003,7 +11003,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -11016,7 +11016,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -11039,7 +11039,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey1 (type: smallint), KEY.reducesinkkey2 (type: int), KEY.reducesinkkey0 (type: string) outputColumnNames: _col1, _col2, _col7 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -11059,17 +11059,17 @@ STAGE PLANS: name: min window function: GenericUDAFMinEvaluator window frame: RANGE PRECEDING(MAX)~CURRENT - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col7 (type: string), _col1 (type: smallint), _col2 (type: int), min_window_0 (type: int) outputColumnNames: _col0, _col1, _col2, _col3 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 10800 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 10800 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -11211,7 +11211,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -11224,7 +11224,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -11247,7 +11247,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey1 (type: smallint), KEY.reducesinkkey2 (type: int), KEY.reducesinkkey0 (type: string) outputColumnNames: _col1, _col2, _col7 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -11267,17 +11267,17 @@ STAGE PLANS: name: avg window function: GenericUDAFAverageEvaluatorDouble window frame: RANGE PRECEDING(MAX)~CURRENT - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col7 (type: string), _col1 (type: smallint), _col2 (type: int), avg_window_0 (type: double) outputColumnNames: _col0, _col1, _col2, _col3 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 10800 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 10800 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -11419,7 +11419,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -11432,7 +11432,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -11455,7 +11455,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: smallint), KEY.reducesinkkey2 (type: int), KEY.reducesinkkey3 (type: float), KEY.reducesinkkey1 (type: boolean) outputColumnNames: _col1, _col2, _col4, _col6 - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -11475,17 +11475,17 @@ STAGE PLANS: name: max window function: GenericUDAFMaxEvaluator window frame: RANGE PRECEDING(MAX)~CURRENT - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col1 (type: smallint), _col6 (type: boolean), _col2 (type: int), _col4 (type: float), max_window_0 (type: int) outputColumnNames: _col0, _col1, _col2, _col3, _col4 - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 1600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 1600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -11627,7 +11627,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -11640,7 +11640,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -11663,7 +11663,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: int), KEY.reducesinkkey2 (type: bigint), KEY.reducesinkkey1 (type: boolean) outputColumnNames: _col2, _col3, _col6 - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -11684,17 +11684,17 @@ STAGE PLANS: window function: GenericUDAFRankEvaluator window frame: RANGE PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col6 (type: boolean), rank_window_0 (type: int) outputColumnNames: _col0, _col1 - Statistics: Num rows: 63596 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 1600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 1600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -11836,7 +11836,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -11849,7 +11849,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE value expressions: s (type: string) Execution mode: vectorized Map Vectorization: @@ -11874,7 +11874,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: int), VALUE._col6 (type: string) outputColumnNames: _col2, _col7 - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -11895,17 +11895,17 @@ STAGE PLANS: window function: GenericUDAFRankEvaluator window frame: RANGE PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: CAST( _col7 AS CHAR(12) (type: char(12)), rank_window_0 (type: int) outputColumnNames: _col0, _col1 - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 10400 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 10400 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -12047,7 +12047,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -12060,7 +12060,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE value expressions: s (type: string) Execution mode: vectorized Map Vectorization: @@ -12085,7 +12085,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: int), VALUE._col6 (type: string) outputColumnNames: _col2, _col7 - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -12106,17 +12106,17 @@ STAGE PLANS: window function: GenericUDAFRankEvaluator window frame: RANGE PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: CAST( _col7 AS varchar(12)) (type: varchar(12)), rank_window_0 (type: int) outputColumnNames: _col0, _col1 - Statistics: Num rows: 9784 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 10400 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 10400 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
http://git-wip-us.apache.org/repos/asf/hive/blob/6a99cf53/ql/src/test/results/clientpositive/vector_windowing_rank.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/vector_windowing_rank.q.out b/ql/src/test/results/clientpositive/vector_windowing_rank.q.out index a0e4fc1..d629659 100644 --- a/ql/src/test/results/clientpositive/vector_windowing_rank.q.out +++ b/ql/src/test/results/clientpositive/vector_windowing_rank.q.out @@ -65,7 +65,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -78,7 +78,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE value expressions: s (type: string) Execution mode: vectorized Map Vectorization: @@ -102,7 +102,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey1 (type: tinyint), KEY.reducesinkkey0 (type: float), VALUE._col5 (type: string) outputColumnNames: _col0, _col4, _col7 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -123,17 +123,17 @@ STAGE PLANS: window function: GenericUDAFRankEvaluator window frame: ROWS PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col7 (type: string), rank_window_0 (type: int) outputColumnNames: _col0, _col1 - Statistics: Num rows: 9421 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 10800 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 10800 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -275,7 +275,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 7066 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -288,7 +288,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 7066 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -311,7 +311,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey1 (type: int), KEY.reducesinkkey2 (type: string), KEY.reducesinkkey0 (type: timestamp) outputColumnNames: _col2, _col7, _col8 - Statistics: Num rows: 7066 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -332,17 +332,17 @@ STAGE PLANS: window function: GenericUDAFDenseRankEvaluator window frame: ROWS PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 7066 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col7 (type: string), dense_rank_window_0 (type: int) outputColumnNames: _col0, _col1 - Statistics: Num rows: 7066 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 14400 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 14400 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -484,7 +484,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 9085 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -497,7 +497,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 9085 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -520,7 +520,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey1 (type: bigint), KEY.reducesinkkey0 (type: boolean), KEY.reducesinkkey2 (type: string) outputColumnNames: _col3, _col6, _col7 - Statistics: Num rows: 9085 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -541,17 +541,17 @@ STAGE PLANS: window function: GenericUDAFCumeDistEvaluator window frame: ROWS PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 9085 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col7 (type: string), cume_dist_window_0 (type: double) outputColumnNames: _col0, _col1 - Statistics: Num rows: 9085 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 11200 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 11200 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -693,7 +693,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 4710 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -706,7 +706,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 4710 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE value expressions: s (type: string) Execution mode: vectorized Map Vectorization: @@ -730,7 +730,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey1 (type: float), VALUE._col6 (type: string), KEY.reducesinkkey0 (type: decimal(4,2)) outputColumnNames: _col4, _col7, _col9 - Statistics: Num rows: 4710 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -751,17 +751,17 @@ STAGE PLANS: window function: GenericUDAFPercentRankEvaluator window frame: ROWS PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 4710 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col7 (type: string), percent_rank_window_0 (type: double) outputColumnNames: _col0, _col1 - Statistics: Num rows: 4710 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 100 - Statistics: Num rows: 100 Data size: 21600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 100 Data size: 21600 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -924,35 +924,35 @@ STAGE PLANS: Map Operator Tree: TableScan alias: other - Statistics: Num rows: 6359 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: b is not null (type: boolean) - Statistics: Num rows: 6359 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: b (type: bigint), ts (type: timestamp), dec (type: decimal(4,2)) outputColumnNames: _col0, _col1, _col2 - Statistics: Num rows: 6359 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator key expressions: _col0 (type: bigint) sort order: + Map-reduce partition columns: _col0 (type: bigint) - Statistics: Num rows: 6359 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE value expressions: _col1 (type: timestamp), _col2 (type: decimal(4,2)) TableScan alias: over10k - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: b is not null (type: boolean) - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: b (type: bigint) outputColumnNames: _col0 - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator key expressions: _col0 (type: bigint) sort order: + Map-reduce partition columns: _col0 (type: bigint) - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Map Vectorization: enabled: false enabledConditionsNotMet: Vectorized map work only works with 1 TableScanOperator IS false @@ -968,7 +968,7 @@ STAGE PLANS: 0 _col0 (type: bigint) 1 _col0 (type: bigint) outputColumnNames: _col1, _col2 - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false table: @@ -992,7 +992,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -1015,7 +1015,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: timestamp), KEY.reducesinkkey1 (type: decimal(4,2)) outputColumnNames: _col1, _col2 - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -1036,20 +1036,20 @@ STAGE PLANS: window function: GenericUDAFRankEvaluator window frame: ROWS PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: (rank_window_0 = 1) (type: boolean) - Statistics: Num rows: 69956 Data size: 559649 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col1 (type: timestamp), _col2 (type: decimal(4,2)), 1 (type: int) outputColumnNames: _col0, _col1, _col2 - Statistics: Num rows: 69956 Data size: 559649 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 10 - Statistics: Num rows: 10 Data size: 80 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 10 Data size: 80 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -1142,35 +1142,35 @@ STAGE PLANS: Map Operator Tree: TableScan alias: other - Statistics: Num rows: 6359 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: b is not null (type: boolean) - Statistics: Num rows: 6359 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: b (type: bigint), ts (type: timestamp), dec (type: decimal(4,2)) outputColumnNames: _col0, _col1, _col2 - Statistics: Num rows: 6359 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator key expressions: _col0 (type: bigint) sort order: + Map-reduce partition columns: _col0 (type: bigint) - Statistics: Num rows: 6359 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE value expressions: _col1 (type: timestamp), _col2 (type: decimal(4,2)) TableScan alias: over10k - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: b is not null (type: boolean) - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: b (type: bigint) outputColumnNames: _col0 - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator key expressions: _col0 (type: bigint) sort order: + Map-reduce partition columns: _col0 (type: bigint) - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Map Vectorization: enabled: false enabledConditionsNotMet: Vectorized map work only works with 1 TableScanOperator IS false @@ -1186,7 +1186,7 @@ STAGE PLANS: 0 _col0 (type: bigint) 1 _col0 (type: bigint) outputColumnNames: _col1, _col2 - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false table: @@ -1210,7 +1210,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE value expressions: _col2 (type: decimal(4,2)) Execution mode: vectorized Map Vectorization: @@ -1234,7 +1234,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: timestamp), VALUE._col1 (type: decimal(4,2)) outputColumnNames: _col1, _col2 - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -1255,20 +1255,20 @@ STAGE PLANS: window function: GenericUDAFRankEvaluator window frame: ROWS PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: (_col2 = 89.5) (type: boolean) - Statistics: Num rows: 69956 Data size: 559649 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col1 (type: timestamp), 89.5 (type: decimal(4,2)), rank_window_0 (type: int) outputColumnNames: _col0, _col1, _col2 - Statistics: Num rows: 69956 Data size: 559649 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 10 - Statistics: Num rows: 10 Data size: 80 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 10 Data size: 80 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat @@ -1363,35 +1363,35 @@ STAGE PLANS: Map Operator Tree: TableScan alias: other - Statistics: Num rows: 6204 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: ((t < 10) and b is not null) (type: boolean) - Statistics: Num rows: 2068 Data size: 339181 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: b (type: bigint), ts (type: timestamp), dec (type: decimal(4,2)) outputColumnNames: _col1, _col2, _col3 - Statistics: Num rows: 2068 Data size: 339181 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator key expressions: _col1 (type: bigint) sort order: + Map-reduce partition columns: _col1 (type: bigint) - Statistics: Num rows: 2068 Data size: 339181 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE value expressions: _col2 (type: timestamp), _col3 (type: decimal(4,2)) TableScan alias: over10k - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: b is not null (type: boolean) - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: b (type: bigint) outputColumnNames: _col0 - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator key expressions: _col0 (type: bigint) sort order: + Map-reduce partition columns: _col0 (type: bigint) - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Map Vectorization: enabled: false enabledConditionsNotMet: Vectorized map work only works with 1 TableScanOperator IS false @@ -1407,7 +1407,7 @@ STAGE PLANS: 0 _col1 (type: bigint) 1 _col0 (type: bigint) outputColumnNames: _col2, _col3 - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false table: @@ -1431,7 +1431,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No PTF TopN IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Execution mode: vectorized Map Vectorization: enabled: true @@ -1454,7 +1454,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: timestamp), KEY.reducesinkkey1 (type: decimal(4,2)) outputColumnNames: _col2, _col3 - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -1475,20 +1475,20 @@ STAGE PLANS: window function: GenericUDAFRankEvaluator window frame: ROWS PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 139912 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: (rank_window_0 = 1) (type: boolean) - Statistics: Num rows: 69956 Data size: 559649 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col2 (type: timestamp), _col3 (type: decimal(4,2)), 1 (type: int) outputColumnNames: _col0, _col1, _col2 - Statistics: Num rows: 69956 Data size: 559649 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE Limit Number of rows: 10 - Statistics: Num rows: 10 Data size: 80 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 10 Data size: 80 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1119298 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat http://git-wip-us.apache.org/repos/asf/hive/blob/6a99cf53/ql/src/test/results/clientpositive/vector_windowing_streaming.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/vector_windowing_streaming.q.out b/ql/src/test/results/clientpositive/vector_windowing_streaming.q.out index 0198e2b..658b105 100644 --- a/ql/src/test/results/clientpositive/vector_windowing_streaming.q.out +++ b/ql/src/test/results/clientpositive/vector_windowing_streaming.q.out @@ -320,7 +320,7 @@ STAGE PLANS: Map Operator Tree: TableScan alias: over10k - Statistics: Num rows: 127193 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TableScan Vectorization: native: true projectedOutputColumns: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10] @@ -330,7 +330,7 @@ STAGE PLANS: native: true predicateExpression: FilterLongColLessLongScalar(col 0, val 5) -> boolean predicate: (t < 5) (type: boolean) - Statistics: Num rows: 42397 Data size: 339176 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator key expressions: t (type: tinyint), f (type: float) sort order: ++ @@ -340,7 +340,7 @@ STAGE PLANS: native: false nativeConditionsMet: hive.vectorized.execution.reducesink.new.enabled IS true, No DISTINCT columns IS true, BinarySortableSerDe for keys IS true, LazyBinarySerDe for values IS true nativeConditionsNotMet: hive.execution.engine mr IN [tez, spark] IS false, No PTF TopN IS false - Statistics: Num rows: 42397 Data size: 339176 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE TopN Hash Memory Usage: 0.8 Execution mode: vectorized Map Vectorization: @@ -364,7 +364,7 @@ STAGE PLANS: Select Operator expressions: KEY.reducesinkkey0 (type: tinyint), KEY.reducesinkkey1 (type: float) outputColumnNames: _col0, _col4 - Statistics: Num rows: 42397 Data size: 339176 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE PTF Operator Function definitions: Input definition @@ -385,17 +385,17 @@ STAGE PLANS: window function: GenericUDAFRankEvaluator window frame: ROWS PRECEDING(MAX)~FOLLOWING(MAX) isPivotResult: true - Statistics: Num rows: 42397 Data size: 339176 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Filter Operator predicate: (rank_window_0 < 6) (type: boolean) - Statistics: Num rows: 14132 Data size: 113056 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: _col0 (type: tinyint), _col4 (type: float), rank_window_0 (type: int) outputColumnNames: _col0, _col1, _col2 - Statistics: Num rows: 14132 Data size: 113056 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 14132 Data size: 113056 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 1 Data size: 1017544 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
