HIVE-10834 : Support First_value()/last_value() over x preceding and y preceding windowing (Aihua Xu via Ashutosh Chauhan)
Signed-off-by: Ashutosh Chauhan <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/6d413db8 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/6d413db8 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/6d413db8 Branch: refs/heads/llap Commit: 6d413db8bb8a26c92daaa9ee76dea99d54250ca9 Parents: cfab025 Author: Aihua Xu <[email protected]> Authored: Sat May 30 13:47:00 2015 -0700 Committer: Ashutosh Chauhan <[email protected]> Committed: Sun May 31 00:07:41 2015 -0700 ---------------------------------------------------------------------- .../ql/udf/generic/GenericUDAFFirstValue.java | 41 +- .../ql/udf/generic/GenericUDAFLastValue.java | 33 +- .../generic/GenericUDAFStreamingEvaluator.java | 22 - .../clientpositive/windowing_windowspec2.q | 12 + .../clientpositive/windowing_windowspec2.q.out | 868 +++++++++++++++++++ 5 files changed, 926 insertions(+), 50 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/6d413db8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFFirstValue.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFFirstValue.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFFirstValue.java index dd9eaf3..1bed46b 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFFirstValue.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFFirstValue.java @@ -154,9 +154,7 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { @Override public GenericUDAFEvaluator getWindowingEvaluator(WindowFrameDef wFrmDef) { - BoundaryDef start = wFrmDef.getStart(); - BoundaryDef end = wFrmDef.getEnd(); - return new FirstValStreamingFixedWindow(this, start.getAmt(), end.getAmt()); + return new FirstValStreamingFixedWindow(this, wFrmDef); } } @@ -180,7 +178,7 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { public State(AggregationBuffer buf) { super(buf); - valueChain = new ArrayDeque<ValIndexPair>(numPreceding + numFollowing + 1); + valueChain = new ArrayDeque<ValIndexPair>(wFrameDef.isStartUnbounded() ? 1 : wFrameDef.getWindowSize()); } @Override @@ -192,7 +190,7 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { if (underlying == -1) { return -1; } - if (numPreceding == BoundarySpec.UNBOUNDED_AMOUNT) { + if (wFrameDef.isStartUnbounded()) { return -1; } /* @@ -201,7 +199,7 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { * underlying * wdwSz sz of maxChain = sz of underlying * wdwSz */ - int wdwSz = numPreceding + numFollowing + 1; + int wdwSz = wFrameDef.getWindowSize(); return underlying + (underlying * wdwSz) + (underlying * wdwSz) + (3 * JavaDataModel.PRIMITIVES1); } @@ -212,9 +210,8 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { } } - public FirstValStreamingFixedWindow(GenericUDAFEvaluator wrappedEval, int numPreceding, - int numFollowing) { - super(wrappedEval, numPreceding, numFollowing); + public FirstValStreamingFixedWindow(GenericUDAFEvaluator wrappedEval, WindowFrameDef wFrameDef) { + super(wrappedEval, wFrameDef); } @Override @@ -243,6 +240,10 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { */ if (fb.firstRow) { wrappedEval.iterate(fb, parameters); + // We need to insert 'null' before processing first row for the case: X preceding and y preceding + for (int i = wFrameDef.getEnd().getRelativeOffset(); i < 0; i++) { + s.results.add(null); + } } Object o = ObjectInspectorUtils.copyToStandardObject(parameters[0], inputOI(), @@ -252,7 +253,7 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { * add row to chain. except in case of UNB preceding: - only 1 firstVal * needs to be tracked. */ - if (numPreceding != BoundarySpec.UNBOUNDED_AMOUNT || s.valueChain.isEmpty()) { + if (!wFrameDef.isStartUnbounded() || s.valueChain.isEmpty()) { /* * add value to chain if it is not null or if skipNulls is false. */ @@ -261,7 +262,7 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { } } - if (s.numRows >= numFollowing) { + if (s.numRows >= wFrameDef.getEnd().getRelativeOffset()) { /* * if skipNulls is true and there are no rows in valueChain => all rows * in partition are null so far; so add null in o/p @@ -276,8 +277,8 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { if (s.valueChain.size() > 0) { int fIdx = (Integer) s.valueChain.getFirst().idx; - if (numPreceding != BoundarySpec.UNBOUNDED_AMOUNT - && s.numRows > fIdx + numPreceding + numFollowing) { + if (!wFrameDef.isStartUnbounded() + && s.numRows >= fIdx + wFrameDef.getWindowSize()) { s.valueChain.removeFirst(); } } @@ -288,13 +289,16 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { State s = (State) agg; ValIndexPair r = s.valueChain.size() == 0 ? null : s.valueChain.getFirst(); - for (int i = 0; i < numFollowing; i++) { + // After all the rows are processed, continue to generate results for the rows that results haven't generated. + // For the case: X following and Y following, process first Y-X results and then insert X nulls. + // For the case X preceding and Y following, process Y results. + for (int i = Math.max(0, wFrameDef.getStart().getRelativeOffset()); i < wFrameDef.getEnd().getRelativeOffset(); i++) { s.results.add(r == null ? null : r.val); s.numRows++; if (r != null) { int fIdx = (Integer) r.idx; - if (numPreceding != BoundarySpec.UNBOUNDED_AMOUNT - && s.numRows > fIdx + numPreceding + numFollowing + if (!wFrameDef.isStartUnbounded() + && s.numRows + i >= fIdx + wFrameDef.getWindowSize() && !s.valueChain.isEmpty()) { s.valueChain.removeFirst(); r = !s.valueChain.isEmpty() ? s.valueChain.getFirst() : r; @@ -302,6 +306,11 @@ public class GenericUDAFFirstValue extends AbstractGenericUDAFResolver { } } + for (int i = 0; i < wFrameDef.getStart().getRelativeOffset(); i++) { + s.results.add(null); + s.numRows++; + } + return null; } http://git-wip-us.apache.org/repos/asf/hive/blob/6d413db8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFLastValue.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFLastValue.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFLastValue.java index 3ed6de7..aa98cc9 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFLastValue.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFLastValue.java @@ -141,9 +141,7 @@ public class GenericUDAFLastValue extends AbstractGenericUDAFResolver { @Override public GenericUDAFEvaluator getWindowingEvaluator(WindowFrameDef wFrmDef) { - BoundaryDef start = wFrmDef.getStart(); - BoundaryDef end = wFrmDef.getEnd(); - return new LastValStreamingFixedWindow(this, start.getAmt(), end.getAmt()); + return new LastValStreamingFixedWindow(this, wFrmDef); } } @@ -179,9 +177,8 @@ public class GenericUDAFLastValue extends AbstractGenericUDAFResolver { } } - public LastValStreamingFixedWindow(GenericUDAFEvaluator wrappedEval, int numPreceding, - int numFollowing) { - super(wrappedEval, numPreceding, numFollowing); + public LastValStreamingFixedWindow(GenericUDAFEvaluator wrappedEval, WindowFrameDef wFrameDef) { + super(wrappedEval, wFrameDef); } @Override @@ -210,6 +207,11 @@ public class GenericUDAFLastValue extends AbstractGenericUDAFResolver { */ if (lb.firstRow) { wrappedEval.iterate(lb, parameters); + + // We need to insert 'null' before processing first row for the case: X preceding and y preceding + for (int i = wFrameDef.getEnd().getRelativeOffset(); i < 0; i++) { + s.results.add(null); + } } Object o = ObjectInspectorUtils.copyToStandardObject(parameters[0], inputOI(), @@ -219,14 +221,14 @@ public class GenericUDAFLastValue extends AbstractGenericUDAFResolver { s.lastValue = o; s.lastIdx = s.numRows; } else if (lb.skipNulls && s.lastIdx != -1) { - if (numPreceding != BoundarySpec.UNBOUNDED_AMOUNT - && s.numRows > s.lastIdx + numPreceding + numFollowing) { + if (!wFrameDef.isStartUnbounded() + && s.numRows >= s.lastIdx + wFrameDef.getWindowSize()) { s.lastValue = null; s.lastIdx = -1; } } - if (s.numRows >= (numFollowing)) { + if (s.numRows >= wFrameDef.getEnd().getRelativeOffset()) { s.results.add(s.lastValue); } s.numRows++; @@ -238,16 +240,23 @@ public class GenericUDAFLastValue extends AbstractGenericUDAFResolver { LastValueBuffer lb = (LastValueBuffer) s.wrappedBuf; if (lb.skipNulls && s.lastIdx != -1) { - if (numPreceding != BoundarySpec.UNBOUNDED_AMOUNT - && s.numRows > s.lastIdx + numPreceding + numFollowing) { + if (!wFrameDef.isStartUnbounded() + && s.numRows >= s.lastIdx + wFrameDef.getWindowSize()) { s.lastValue = null; s.lastIdx = -1; } } - for (int i = 0; i < numFollowing; i++) { + // After all the rows are processed, continue to generate results for the rows that results haven't generated. + // For the case: X following and Y following, process first Y-X results and then insert X nulls. + // For the case X preceding and Y following, process Y results. + for (int i = Math.max(0, wFrameDef.getStart().getRelativeOffset()); i < wFrameDef.getEnd().getRelativeOffset(); i++) { s.results.add(s.lastValue); } + for (int i = 0; i < wFrameDef.getStart().getRelativeOffset(); i++) { + s.results.add(null); + s.numRows++; + } return null; } http://git-wip-us.apache.org/repos/asf/hive/blob/6d413db8/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStreamingEvaluator.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStreamingEvaluator.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStreamingEvaluator.java index f27d066..3c76404 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStreamingEvaluator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFStreamingEvaluator.java @@ -34,33 +34,11 @@ public abstract class GenericUDAFStreamingEvaluator<T1> extends protected final GenericUDAFEvaluator wrappedEval; protected final WindowFrameDef wFrameDef; - protected final int numPreceding; - protected final int numFollowing; - - /** - * @param wrappedEval - * @param numPreceding - * @param numFollowing - * @deprecated - */ - public GenericUDAFStreamingEvaluator(GenericUDAFEvaluator wrappedEval, - int numPreceding, int numFollowing) { - this.wrappedEval = wrappedEval; - this.wFrameDef = null; - this.mode = wrappedEval.mode; - - this.numPreceding = numPreceding; - this.numFollowing = numFollowing; - } - public GenericUDAFStreamingEvaluator(GenericUDAFEvaluator wrappedEval, WindowFrameDef wFrameDef) { this.wrappedEval = wrappedEval; this.wFrameDef = wFrameDef; this.mode = wrappedEval.mode; - - this.numPreceding = -1; - this.numFollowing = -1; } class StreamingState extends AbstractAggregationBuffer { http://git-wip-us.apache.org/repos/asf/hive/blob/6d413db8/ql/src/test/queries/clientpositive/windowing_windowspec2.q ---------------------------------------------------------------------- diff --git a/ql/src/test/queries/clientpositive/windowing_windowspec2.q b/ql/src/test/queries/clientpositive/windowing_windowspec2.q index e77c4eb..e270a86 100644 --- a/ql/src/test/queries/clientpositive/windowing_windowspec2.q +++ b/ql/src/test/queries/clientpositive/windowing_windowspec2.q @@ -40,3 +40,15 @@ select ts, f, min(f) over (partition by ts order by t rows between 2 preceding a select ts, f, min(f) over (partition by ts order by t rows between unbounded preceding and 1 preceding) from over10k limit 100; select ts, f, min(f) over (partition by ts order by t rows between 1 following and 2 following) from over10k limit 100; select ts, f, min(f) over (partition by ts order by t rows between unbounded preceding and 1 following) from over10k limit 100; + +-- first_value +select ts, f, first_value(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k limit 100; +select ts, f, first_value(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k limit 100; +select ts, f, first_value(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k limit 100; +select ts, f, first_value(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k limit 100; + +-- last_value +select ts, f, last_value(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k limit 100; +select ts, f, last_value(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k limit 100; +select ts, f, last_value(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k limit 100; +select ts, f, last_value(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k limit 100; http://git-wip-us.apache.org/repos/asf/hive/blob/6d413db8/ql/src/test/results/clientpositive/windowing_windowspec2.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/windowing_windowspec2.q.out b/ql/src/test/results/clientpositive/windowing_windowspec2.q.out index b187f35..a318398 100644 --- a/ql/src/test/results/clientpositive/windowing_windowspec2.q.out +++ b/ql/src/test/results/clientpositive/windowing_windowspec2.q.out @@ -1780,3 +1780,871 @@ POSTHOOK: Input: default@over10k 2013-03-01 09:11:58.703072 88.83 0.48 2013-03-01 09:11:58.703072 9.0 0.48 2013-03-01 09:11:58.703072 54.1 0.48 +PREHOOK: query: -- first_value +select ts, f, first_value(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k limit 100 +PREHOOK: type: QUERY +PREHOOK: Input: default@over10k +#### A masked pattern was here #### +POSTHOOK: query: -- first_value +select ts, f, first_value(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k limit 100 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@over10k +#### A masked pattern was here #### +2013-03-01 09:11:58.70307 3.17 NULL +2013-03-01 09:11:58.70307 10.89 3.17 +2013-03-01 09:11:58.70307 14.54 3.17 +2013-03-01 09:11:58.70307 14.78 10.89 +2013-03-01 09:11:58.70307 17.85 14.54 +2013-03-01 09:11:58.70307 20.61 14.78 +2013-03-01 09:11:58.70307 28.69 17.85 +2013-03-01 09:11:58.70307 29.22 20.61 +2013-03-01 09:11:58.70307 31.17 28.69 +2013-03-01 09:11:58.70307 38.35 29.22 +2013-03-01 09:11:58.70307 38.61 31.17 +2013-03-01 09:11:58.70307 39.48 38.35 +2013-03-01 09:11:58.70307 40.54 38.61 +2013-03-01 09:11:58.70307 41.6 39.48 +2013-03-01 09:11:58.70307 46.08 40.54 +2013-03-01 09:11:58.70307 54.36 41.6 +2013-03-01 09:11:58.70307 56.94 46.08 +2013-03-01 09:11:58.70307 64.96 54.36 +2013-03-01 09:11:58.70307 73.52 56.94 +2013-03-01 09:11:58.70307 78.58 64.96 +2013-03-01 09:11:58.70307 81.41 73.52 +2013-03-01 09:11:58.70307 84.71 78.58 +2013-03-01 09:11:58.70307 87.43 81.41 +2013-03-01 09:11:58.70307 91.36 84.71 +2013-03-01 09:11:58.70307 92.96 87.43 +2013-03-01 09:11:58.70307 95.04 91.36 +2013-03-01 09:11:58.703071 0.83 NULL +2013-03-01 09:11:58.703071 1.99 0.83 +2013-03-01 09:11:58.703071 3.73 0.83 +2013-03-01 09:11:58.703071 8.86 1.99 +2013-03-01 09:11:58.703071 10.62 3.73 +2013-03-01 09:11:58.703071 11.32 8.86 +2013-03-01 09:11:58.703071 12.83 10.62 +2013-03-01 09:11:58.703071 14.7 11.32 +2013-03-01 09:11:58.703071 14.96 12.83 +2013-03-01 09:11:58.703071 17.58 14.7 +2013-03-01 09:11:58.703071 19.1 14.96 +2013-03-01 09:11:58.703071 21.01 17.58 +2013-03-01 09:11:58.703071 26.95 19.1 +2013-03-01 09:11:58.703071 27.23 21.01 +2013-03-01 09:11:58.703071 29.07 26.95 +2013-03-01 09:11:58.703071 29.71 27.23 +2013-03-01 09:11:58.703071 31.84 29.07 +2013-03-01 09:11:58.703071 31.94 29.71 +2013-03-01 09:11:58.703071 35.32 31.84 +2013-03-01 09:11:58.703071 37.32 31.94 +2013-03-01 09:11:58.703071 38.5 35.32 +2013-03-01 09:11:58.703071 42.08 37.32 +2013-03-01 09:11:58.703071 44.3 38.5 +2013-03-01 09:11:58.703071 44.66 42.08 +2013-03-01 09:11:58.703071 46.84 44.3 +2013-03-01 09:11:58.703071 48.89 44.66 +2013-03-01 09:11:58.703071 49.64 46.84 +2013-03-01 09:11:58.703071 50.28 48.89 +2013-03-01 09:11:58.703071 52.09 49.64 +2013-03-01 09:11:58.703071 53.26 50.28 +2013-03-01 09:11:58.703071 54.09 52.09 +2013-03-01 09:11:58.703071 56.45 53.26 +2013-03-01 09:11:58.703071 56.76 54.09 +2013-03-01 09:11:58.703071 61.41 56.45 +2013-03-01 09:11:58.703071 61.88 56.76 +2013-03-01 09:11:58.703071 63.03 61.41 +2013-03-01 09:11:58.703071 64.55 61.88 +2013-03-01 09:11:58.703071 68.62 63.03 +2013-03-01 09:11:58.703071 76.13 64.55 +2013-03-01 09:11:58.703071 79.05 68.62 +2013-03-01 09:11:58.703071 80.43 76.13 +2013-03-01 09:11:58.703071 81.41 79.05 +2013-03-01 09:11:58.703071 82.85 80.43 +2013-03-01 09:11:58.703071 83.98 81.41 +2013-03-01 09:11:58.703071 84.21 82.85 +2013-03-01 09:11:58.703071 85.55 83.98 +2013-03-01 09:11:58.703071 87.93 84.21 +2013-03-01 09:11:58.703071 88.93 85.55 +2013-03-01 09:11:58.703071 94.27 87.93 +2013-03-01 09:11:58.703071 99.45 88.93 +2013-03-01 09:11:58.703072 0.36 NULL +2013-03-01 09:11:58.703072 0.48 0.36 +2013-03-01 09:11:58.703072 0.79 0.36 +2013-03-01 09:11:58.703072 1.27 0.48 +2013-03-01 09:11:58.703072 4.48 0.79 +2013-03-01 09:11:58.703072 9.0 1.27 +2013-03-01 09:11:58.703072 23.27 4.48 +2013-03-01 09:11:58.703072 25.13 9.0 +2013-03-01 09:11:58.703072 25.34 23.27 +2013-03-01 09:11:58.703072 25.91 25.13 +2013-03-01 09:11:58.703072 29.01 25.34 +2013-03-01 09:11:58.703072 30.47 25.91 +2013-03-01 09:11:58.703072 37.95 29.01 +2013-03-01 09:11:58.703072 39.3 30.47 +2013-03-01 09:11:58.703072 45.91 37.95 +2013-03-01 09:11:58.703072 52.44 39.3 +2013-03-01 09:11:58.703072 54.1 45.91 +2013-03-01 09:11:58.703072 56.7 52.44 +2013-03-01 09:11:58.703072 58.77 54.1 +2013-03-01 09:11:58.703072 62.09 56.7 +2013-03-01 09:11:58.703072 68.2 58.77 +2013-03-01 09:11:58.703072 71.68 62.09 +2013-03-01 09:11:58.703072 79.46 68.2 +2013-03-01 09:11:58.703072 80.02 71.68 +PREHOOK: query: select ts, f, first_value(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k limit 100 +PREHOOK: type: QUERY +PREHOOK: Input: default@over10k +#### A masked pattern was here #### +POSTHOOK: query: select ts, f, first_value(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k limit 100 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@over10k +#### A masked pattern was here #### +2013-03-01 09:11:58.70307 3.17 NULL +2013-03-01 09:11:58.70307 10.89 3.17 +2013-03-01 09:11:58.70307 14.54 3.17 +2013-03-01 09:11:58.70307 14.78 3.17 +2013-03-01 09:11:58.70307 17.85 3.17 +2013-03-01 09:11:58.70307 20.61 3.17 +2013-03-01 09:11:58.70307 28.69 3.17 +2013-03-01 09:11:58.70307 29.22 3.17 +2013-03-01 09:11:58.70307 31.17 3.17 +2013-03-01 09:11:58.70307 38.35 3.17 +2013-03-01 09:11:58.70307 38.61 3.17 +2013-03-01 09:11:58.70307 39.48 3.17 +2013-03-01 09:11:58.70307 40.54 3.17 +2013-03-01 09:11:58.70307 41.6 3.17 +2013-03-01 09:11:58.70307 46.08 3.17 +2013-03-01 09:11:58.70307 54.36 3.17 +2013-03-01 09:11:58.70307 56.94 3.17 +2013-03-01 09:11:58.70307 64.96 3.17 +2013-03-01 09:11:58.70307 73.52 3.17 +2013-03-01 09:11:58.70307 78.58 3.17 +2013-03-01 09:11:58.70307 81.41 3.17 +2013-03-01 09:11:58.70307 84.71 3.17 +2013-03-01 09:11:58.70307 87.43 3.17 +2013-03-01 09:11:58.70307 91.36 3.17 +2013-03-01 09:11:58.70307 92.96 3.17 +2013-03-01 09:11:58.70307 95.04 3.17 +2013-03-01 09:11:58.703071 0.83 NULL +2013-03-01 09:11:58.703071 1.99 0.83 +2013-03-01 09:11:58.703071 3.73 0.83 +2013-03-01 09:11:58.703071 8.86 0.83 +2013-03-01 09:11:58.703071 10.62 0.83 +2013-03-01 09:11:58.703071 11.32 0.83 +2013-03-01 09:11:58.703071 12.83 0.83 +2013-03-01 09:11:58.703071 14.7 0.83 +2013-03-01 09:11:58.703071 14.96 0.83 +2013-03-01 09:11:58.703071 17.58 0.83 +2013-03-01 09:11:58.703071 19.1 0.83 +2013-03-01 09:11:58.703071 21.01 0.83 +2013-03-01 09:11:58.703071 26.95 0.83 +2013-03-01 09:11:58.703071 27.23 0.83 +2013-03-01 09:11:58.703071 29.07 0.83 +2013-03-01 09:11:58.703071 29.71 0.83 +2013-03-01 09:11:58.703071 31.84 0.83 +2013-03-01 09:11:58.703071 31.94 0.83 +2013-03-01 09:11:58.703071 35.32 0.83 +2013-03-01 09:11:58.703071 37.32 0.83 +2013-03-01 09:11:58.703071 38.5 0.83 +2013-03-01 09:11:58.703071 42.08 0.83 +2013-03-01 09:11:58.703071 44.3 0.83 +2013-03-01 09:11:58.703071 44.66 0.83 +2013-03-01 09:11:58.703071 46.84 0.83 +2013-03-01 09:11:58.703071 48.89 0.83 +2013-03-01 09:11:58.703071 49.64 0.83 +2013-03-01 09:11:58.703071 50.28 0.83 +2013-03-01 09:11:58.703071 52.09 0.83 +2013-03-01 09:11:58.703071 53.26 0.83 +2013-03-01 09:11:58.703071 54.09 0.83 +2013-03-01 09:11:58.703071 56.45 0.83 +2013-03-01 09:11:58.703071 56.76 0.83 +2013-03-01 09:11:58.703071 61.41 0.83 +2013-03-01 09:11:58.703071 61.88 0.83 +2013-03-01 09:11:58.703071 63.03 0.83 +2013-03-01 09:11:58.703071 64.55 0.83 +2013-03-01 09:11:58.703071 68.62 0.83 +2013-03-01 09:11:58.703071 76.13 0.83 +2013-03-01 09:11:58.703071 79.05 0.83 +2013-03-01 09:11:58.703071 80.43 0.83 +2013-03-01 09:11:58.703071 81.41 0.83 +2013-03-01 09:11:58.703071 82.85 0.83 +2013-03-01 09:11:58.703071 83.98 0.83 +2013-03-01 09:11:58.703071 84.21 0.83 +2013-03-01 09:11:58.703071 85.55 0.83 +2013-03-01 09:11:58.703071 87.93 0.83 +2013-03-01 09:11:58.703071 88.93 0.83 +2013-03-01 09:11:58.703071 94.27 0.83 +2013-03-01 09:11:58.703071 99.45 0.83 +2013-03-01 09:11:58.703072 0.36 NULL +2013-03-01 09:11:58.703072 0.48 0.36 +2013-03-01 09:11:58.703072 0.79 0.36 +2013-03-01 09:11:58.703072 1.27 0.36 +2013-03-01 09:11:58.703072 4.48 0.36 +2013-03-01 09:11:58.703072 9.0 0.36 +2013-03-01 09:11:58.703072 23.27 0.36 +2013-03-01 09:11:58.703072 25.13 0.36 +2013-03-01 09:11:58.703072 25.34 0.36 +2013-03-01 09:11:58.703072 25.91 0.36 +2013-03-01 09:11:58.703072 29.01 0.36 +2013-03-01 09:11:58.703072 30.47 0.36 +2013-03-01 09:11:58.703072 37.95 0.36 +2013-03-01 09:11:58.703072 39.3 0.36 +2013-03-01 09:11:58.703072 45.91 0.36 +2013-03-01 09:11:58.703072 52.44 0.36 +2013-03-01 09:11:58.703072 54.1 0.36 +2013-03-01 09:11:58.703072 56.7 0.36 +2013-03-01 09:11:58.703072 58.77 0.36 +2013-03-01 09:11:58.703072 62.09 0.36 +2013-03-01 09:11:58.703072 68.2 0.36 +2013-03-01 09:11:58.703072 71.68 0.36 +2013-03-01 09:11:58.703072 79.46 0.36 +2013-03-01 09:11:58.703072 80.02 0.36 +PREHOOK: query: select ts, f, first_value(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k limit 100 +PREHOOK: type: QUERY +PREHOOK: Input: default@over10k +#### A masked pattern was here #### +POSTHOOK: query: select ts, f, first_value(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k limit 100 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@over10k +#### A masked pattern was here #### +2013-03-01 09:11:58.70307 3.17 10.89 +2013-03-01 09:11:58.70307 10.89 14.54 +2013-03-01 09:11:58.70307 14.54 14.78 +2013-03-01 09:11:58.70307 14.78 17.85 +2013-03-01 09:11:58.70307 17.85 20.61 +2013-03-01 09:11:58.70307 20.61 28.69 +2013-03-01 09:11:58.70307 28.69 29.22 +2013-03-01 09:11:58.70307 29.22 31.17 +2013-03-01 09:11:58.70307 31.17 38.35 +2013-03-01 09:11:58.70307 38.35 38.61 +2013-03-01 09:11:58.70307 38.61 39.48 +2013-03-01 09:11:58.70307 39.48 40.54 +2013-03-01 09:11:58.70307 40.54 41.6 +2013-03-01 09:11:58.70307 41.6 46.08 +2013-03-01 09:11:58.70307 46.08 54.36 +2013-03-01 09:11:58.70307 54.36 56.94 +2013-03-01 09:11:58.70307 56.94 64.96 +2013-03-01 09:11:58.70307 64.96 73.52 +2013-03-01 09:11:58.70307 73.52 78.58 +2013-03-01 09:11:58.70307 78.58 81.41 +2013-03-01 09:11:58.70307 81.41 84.71 +2013-03-01 09:11:58.70307 84.71 87.43 +2013-03-01 09:11:58.70307 87.43 91.36 +2013-03-01 09:11:58.70307 91.36 92.96 +2013-03-01 09:11:58.70307 92.96 95.04 +2013-03-01 09:11:58.70307 95.04 NULL +2013-03-01 09:11:58.703071 0.83 1.99 +2013-03-01 09:11:58.703071 1.99 3.73 +2013-03-01 09:11:58.703071 3.73 8.86 +2013-03-01 09:11:58.703071 8.86 10.62 +2013-03-01 09:11:58.703071 10.62 11.32 +2013-03-01 09:11:58.703071 11.32 12.83 +2013-03-01 09:11:58.703071 12.83 14.7 +2013-03-01 09:11:58.703071 14.7 14.96 +2013-03-01 09:11:58.703071 14.96 17.58 +2013-03-01 09:11:58.703071 17.58 19.1 +2013-03-01 09:11:58.703071 19.1 21.01 +2013-03-01 09:11:58.703071 21.01 26.95 +2013-03-01 09:11:58.703071 26.95 27.23 +2013-03-01 09:11:58.703071 27.23 29.07 +2013-03-01 09:11:58.703071 29.07 29.71 +2013-03-01 09:11:58.703071 29.71 31.84 +2013-03-01 09:11:58.703071 31.84 31.94 +2013-03-01 09:11:58.703071 31.94 35.32 +2013-03-01 09:11:58.703071 35.32 37.32 +2013-03-01 09:11:58.703071 37.32 38.5 +2013-03-01 09:11:58.703071 38.5 42.08 +2013-03-01 09:11:58.703071 42.08 44.3 +2013-03-01 09:11:58.703071 44.3 44.66 +2013-03-01 09:11:58.703071 44.66 46.84 +2013-03-01 09:11:58.703071 46.84 48.89 +2013-03-01 09:11:58.703071 48.89 49.64 +2013-03-01 09:11:58.703071 49.64 50.28 +2013-03-01 09:11:58.703071 50.28 52.09 +2013-03-01 09:11:58.703071 52.09 53.26 +2013-03-01 09:11:58.703071 53.26 54.09 +2013-03-01 09:11:58.703071 54.09 56.45 +2013-03-01 09:11:58.703071 56.45 56.76 +2013-03-01 09:11:58.703071 56.76 61.41 +2013-03-01 09:11:58.703071 61.41 61.88 +2013-03-01 09:11:58.703071 61.88 63.03 +2013-03-01 09:11:58.703071 63.03 64.55 +2013-03-01 09:11:58.703071 64.55 68.62 +2013-03-01 09:11:58.703071 68.62 76.13 +2013-03-01 09:11:58.703071 76.13 79.05 +2013-03-01 09:11:58.703071 79.05 80.43 +2013-03-01 09:11:58.703071 80.43 81.41 +2013-03-01 09:11:58.703071 81.41 82.85 +2013-03-01 09:11:58.703071 82.85 83.98 +2013-03-01 09:11:58.703071 83.98 84.21 +2013-03-01 09:11:58.703071 84.21 85.55 +2013-03-01 09:11:58.703071 85.55 87.93 +2013-03-01 09:11:58.703071 87.93 88.93 +2013-03-01 09:11:58.703071 88.93 94.27 +2013-03-01 09:11:58.703071 94.27 99.45 +2013-03-01 09:11:58.703071 99.45 NULL +2013-03-01 09:11:58.703072 0.36 0.48 +2013-03-01 09:11:58.703072 0.48 0.79 +2013-03-01 09:11:58.703072 0.79 1.27 +2013-03-01 09:11:58.703072 1.27 4.48 +2013-03-01 09:11:58.703072 4.48 9.0 +2013-03-01 09:11:58.703072 9.0 23.27 +2013-03-01 09:11:58.703072 23.27 25.13 +2013-03-01 09:11:58.703072 25.13 25.34 +2013-03-01 09:11:58.703072 25.34 25.91 +2013-03-01 09:11:58.703072 25.91 29.01 +2013-03-01 09:11:58.703072 29.01 30.47 +2013-03-01 09:11:58.703072 30.47 37.95 +2013-03-01 09:11:58.703072 37.95 39.3 +2013-03-01 09:11:58.703072 39.3 45.91 +2013-03-01 09:11:58.703072 45.91 52.44 +2013-03-01 09:11:58.703072 52.44 54.1 +2013-03-01 09:11:58.703072 54.1 56.7 +2013-03-01 09:11:58.703072 56.7 58.77 +2013-03-01 09:11:58.703072 58.77 62.09 +2013-03-01 09:11:58.703072 62.09 68.2 +2013-03-01 09:11:58.703072 68.2 71.68 +2013-03-01 09:11:58.703072 71.68 79.46 +2013-03-01 09:11:58.703072 79.46 80.02 +2013-03-01 09:11:58.703072 80.02 81.29 +PREHOOK: query: select ts, f, first_value(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k limit 100 +PREHOOK: type: QUERY +PREHOOK: Input: default@over10k +#### A masked pattern was here #### +POSTHOOK: query: select ts, f, first_value(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k limit 100 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@over10k +#### A masked pattern was here #### +2013-03-01 09:11:58.70307 3.17 3.17 +2013-03-01 09:11:58.70307 10.89 3.17 +2013-03-01 09:11:58.70307 14.54 3.17 +2013-03-01 09:11:58.70307 14.78 3.17 +2013-03-01 09:11:58.70307 17.85 3.17 +2013-03-01 09:11:58.70307 20.61 3.17 +2013-03-01 09:11:58.70307 28.69 3.17 +2013-03-01 09:11:58.70307 29.22 3.17 +2013-03-01 09:11:58.70307 31.17 3.17 +2013-03-01 09:11:58.70307 38.35 3.17 +2013-03-01 09:11:58.70307 38.61 3.17 +2013-03-01 09:11:58.70307 39.48 3.17 +2013-03-01 09:11:58.70307 40.54 3.17 +2013-03-01 09:11:58.70307 41.6 3.17 +2013-03-01 09:11:58.70307 46.08 3.17 +2013-03-01 09:11:58.70307 54.36 3.17 +2013-03-01 09:11:58.70307 56.94 3.17 +2013-03-01 09:11:58.70307 64.96 3.17 +2013-03-01 09:11:58.70307 73.52 3.17 +2013-03-01 09:11:58.70307 78.58 3.17 +2013-03-01 09:11:58.70307 81.41 3.17 +2013-03-01 09:11:58.70307 84.71 3.17 +2013-03-01 09:11:58.70307 87.43 3.17 +2013-03-01 09:11:58.70307 91.36 3.17 +2013-03-01 09:11:58.70307 92.96 3.17 +2013-03-01 09:11:58.70307 95.04 3.17 +2013-03-01 09:11:58.703071 0.83 0.83 +2013-03-01 09:11:58.703071 1.99 0.83 +2013-03-01 09:11:58.703071 3.73 0.83 +2013-03-01 09:11:58.703071 8.86 0.83 +2013-03-01 09:11:58.703071 10.62 0.83 +2013-03-01 09:11:58.703071 11.32 0.83 +2013-03-01 09:11:58.703071 12.83 0.83 +2013-03-01 09:11:58.703071 14.7 0.83 +2013-03-01 09:11:58.703071 14.96 0.83 +2013-03-01 09:11:58.703071 17.58 0.83 +2013-03-01 09:11:58.703071 19.1 0.83 +2013-03-01 09:11:58.703071 21.01 0.83 +2013-03-01 09:11:58.703071 26.95 0.83 +2013-03-01 09:11:58.703071 27.23 0.83 +2013-03-01 09:11:58.703071 29.07 0.83 +2013-03-01 09:11:58.703071 29.71 0.83 +2013-03-01 09:11:58.703071 31.84 0.83 +2013-03-01 09:11:58.703071 31.94 0.83 +2013-03-01 09:11:58.703071 35.32 0.83 +2013-03-01 09:11:58.703071 37.32 0.83 +2013-03-01 09:11:58.703071 38.5 0.83 +2013-03-01 09:11:58.703071 42.08 0.83 +2013-03-01 09:11:58.703071 44.3 0.83 +2013-03-01 09:11:58.703071 44.66 0.83 +2013-03-01 09:11:58.703071 46.84 0.83 +2013-03-01 09:11:58.703071 48.89 0.83 +2013-03-01 09:11:58.703071 49.64 0.83 +2013-03-01 09:11:58.703071 50.28 0.83 +2013-03-01 09:11:58.703071 52.09 0.83 +2013-03-01 09:11:58.703071 53.26 0.83 +2013-03-01 09:11:58.703071 54.09 0.83 +2013-03-01 09:11:58.703071 56.45 0.83 +2013-03-01 09:11:58.703071 56.76 0.83 +2013-03-01 09:11:58.703071 61.41 0.83 +2013-03-01 09:11:58.703071 61.88 0.83 +2013-03-01 09:11:58.703071 63.03 0.83 +2013-03-01 09:11:58.703071 64.55 0.83 +2013-03-01 09:11:58.703071 68.62 0.83 +2013-03-01 09:11:58.703071 76.13 0.83 +2013-03-01 09:11:58.703071 79.05 0.83 +2013-03-01 09:11:58.703071 80.43 0.83 +2013-03-01 09:11:58.703071 81.41 0.83 +2013-03-01 09:11:58.703071 82.85 0.83 +2013-03-01 09:11:58.703071 83.98 0.83 +2013-03-01 09:11:58.703071 84.21 0.83 +2013-03-01 09:11:58.703071 85.55 0.83 +2013-03-01 09:11:58.703071 87.93 0.83 +2013-03-01 09:11:58.703071 88.93 0.83 +2013-03-01 09:11:58.703071 94.27 0.83 +2013-03-01 09:11:58.703071 99.45 0.83 +2013-03-01 09:11:58.703072 0.36 0.36 +2013-03-01 09:11:58.703072 0.48 0.36 +2013-03-01 09:11:58.703072 0.79 0.36 +2013-03-01 09:11:58.703072 1.27 0.36 +2013-03-01 09:11:58.703072 4.48 0.36 +2013-03-01 09:11:58.703072 9.0 0.36 +2013-03-01 09:11:58.703072 23.27 0.36 +2013-03-01 09:11:58.703072 25.13 0.36 +2013-03-01 09:11:58.703072 25.34 0.36 +2013-03-01 09:11:58.703072 25.91 0.36 +2013-03-01 09:11:58.703072 29.01 0.36 +2013-03-01 09:11:58.703072 30.47 0.36 +2013-03-01 09:11:58.703072 37.95 0.36 +2013-03-01 09:11:58.703072 39.3 0.36 +2013-03-01 09:11:58.703072 45.91 0.36 +2013-03-01 09:11:58.703072 52.44 0.36 +2013-03-01 09:11:58.703072 54.1 0.36 +2013-03-01 09:11:58.703072 56.7 0.36 +2013-03-01 09:11:58.703072 58.77 0.36 +2013-03-01 09:11:58.703072 62.09 0.36 +2013-03-01 09:11:58.703072 68.2 0.36 +2013-03-01 09:11:58.703072 71.68 0.36 +2013-03-01 09:11:58.703072 79.46 0.36 +2013-03-01 09:11:58.703072 80.02 0.36 +PREHOOK: query: -- last_value +select ts, f, last_value(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k limit 100 +PREHOOK: type: QUERY +PREHOOK: Input: default@over10k +#### A masked pattern was here #### +POSTHOOK: query: -- last_value +select ts, f, last_value(f) over (partition by ts order by f rows between 2 preceding and 1 preceding) from over10k limit 100 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@over10k +#### A masked pattern was here #### +2013-03-01 09:11:58.70307 3.17 NULL +2013-03-01 09:11:58.70307 10.89 3.17 +2013-03-01 09:11:58.70307 14.54 10.89 +2013-03-01 09:11:58.70307 14.78 14.54 +2013-03-01 09:11:58.70307 17.85 14.78 +2013-03-01 09:11:58.70307 20.61 17.85 +2013-03-01 09:11:58.70307 28.69 20.61 +2013-03-01 09:11:58.70307 29.22 28.69 +2013-03-01 09:11:58.70307 31.17 29.22 +2013-03-01 09:11:58.70307 38.35 31.17 +2013-03-01 09:11:58.70307 38.61 38.35 +2013-03-01 09:11:58.70307 39.48 38.61 +2013-03-01 09:11:58.70307 40.54 39.48 +2013-03-01 09:11:58.70307 41.6 40.54 +2013-03-01 09:11:58.70307 46.08 41.6 +2013-03-01 09:11:58.70307 54.36 46.08 +2013-03-01 09:11:58.70307 56.94 54.36 +2013-03-01 09:11:58.70307 64.96 56.94 +2013-03-01 09:11:58.70307 73.52 64.96 +2013-03-01 09:11:58.70307 78.58 73.52 +2013-03-01 09:11:58.70307 81.41 78.58 +2013-03-01 09:11:58.70307 84.71 81.41 +2013-03-01 09:11:58.70307 87.43 84.71 +2013-03-01 09:11:58.70307 91.36 87.43 +2013-03-01 09:11:58.70307 92.96 91.36 +2013-03-01 09:11:58.70307 95.04 92.96 +2013-03-01 09:11:58.703071 0.83 NULL +2013-03-01 09:11:58.703071 1.99 0.83 +2013-03-01 09:11:58.703071 3.73 1.99 +2013-03-01 09:11:58.703071 8.86 3.73 +2013-03-01 09:11:58.703071 10.62 8.86 +2013-03-01 09:11:58.703071 11.32 10.62 +2013-03-01 09:11:58.703071 12.83 11.32 +2013-03-01 09:11:58.703071 14.7 12.83 +2013-03-01 09:11:58.703071 14.96 14.7 +2013-03-01 09:11:58.703071 17.58 14.96 +2013-03-01 09:11:58.703071 19.1 17.58 +2013-03-01 09:11:58.703071 21.01 19.1 +2013-03-01 09:11:58.703071 26.95 21.01 +2013-03-01 09:11:58.703071 27.23 26.95 +2013-03-01 09:11:58.703071 29.07 27.23 +2013-03-01 09:11:58.703071 29.71 29.07 +2013-03-01 09:11:58.703071 31.84 29.71 +2013-03-01 09:11:58.703071 31.94 31.84 +2013-03-01 09:11:58.703071 35.32 31.94 +2013-03-01 09:11:58.703071 37.32 35.32 +2013-03-01 09:11:58.703071 38.5 37.32 +2013-03-01 09:11:58.703071 42.08 38.5 +2013-03-01 09:11:58.703071 44.3 42.08 +2013-03-01 09:11:58.703071 44.66 44.3 +2013-03-01 09:11:58.703071 46.84 44.66 +2013-03-01 09:11:58.703071 48.89 46.84 +2013-03-01 09:11:58.703071 49.64 48.89 +2013-03-01 09:11:58.703071 50.28 49.64 +2013-03-01 09:11:58.703071 52.09 50.28 +2013-03-01 09:11:58.703071 53.26 52.09 +2013-03-01 09:11:58.703071 54.09 53.26 +2013-03-01 09:11:58.703071 56.45 54.09 +2013-03-01 09:11:58.703071 56.76 56.45 +2013-03-01 09:11:58.703071 61.41 56.76 +2013-03-01 09:11:58.703071 61.88 61.41 +2013-03-01 09:11:58.703071 63.03 61.88 +2013-03-01 09:11:58.703071 64.55 63.03 +2013-03-01 09:11:58.703071 68.62 64.55 +2013-03-01 09:11:58.703071 76.13 68.62 +2013-03-01 09:11:58.703071 79.05 76.13 +2013-03-01 09:11:58.703071 80.43 79.05 +2013-03-01 09:11:58.703071 81.41 80.43 +2013-03-01 09:11:58.703071 82.85 81.41 +2013-03-01 09:11:58.703071 83.98 82.85 +2013-03-01 09:11:58.703071 84.21 83.98 +2013-03-01 09:11:58.703071 85.55 84.21 +2013-03-01 09:11:58.703071 87.93 85.55 +2013-03-01 09:11:58.703071 88.93 87.93 +2013-03-01 09:11:58.703071 94.27 88.93 +2013-03-01 09:11:58.703071 99.45 94.27 +2013-03-01 09:11:58.703072 0.36 NULL +2013-03-01 09:11:58.703072 0.48 0.36 +2013-03-01 09:11:58.703072 0.79 0.48 +2013-03-01 09:11:58.703072 1.27 0.79 +2013-03-01 09:11:58.703072 4.48 1.27 +2013-03-01 09:11:58.703072 9.0 4.48 +2013-03-01 09:11:58.703072 23.27 9.0 +2013-03-01 09:11:58.703072 25.13 23.27 +2013-03-01 09:11:58.703072 25.34 25.13 +2013-03-01 09:11:58.703072 25.91 25.34 +2013-03-01 09:11:58.703072 29.01 25.91 +2013-03-01 09:11:58.703072 30.47 29.01 +2013-03-01 09:11:58.703072 37.95 30.47 +2013-03-01 09:11:58.703072 39.3 37.95 +2013-03-01 09:11:58.703072 45.91 39.3 +2013-03-01 09:11:58.703072 52.44 45.91 +2013-03-01 09:11:58.703072 54.1 52.44 +2013-03-01 09:11:58.703072 56.7 54.1 +2013-03-01 09:11:58.703072 58.77 56.7 +2013-03-01 09:11:58.703072 62.09 58.77 +2013-03-01 09:11:58.703072 68.2 62.09 +2013-03-01 09:11:58.703072 71.68 68.2 +2013-03-01 09:11:58.703072 79.46 71.68 +2013-03-01 09:11:58.703072 80.02 79.46 +PREHOOK: query: select ts, f, last_value(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k limit 100 +PREHOOK: type: QUERY +PREHOOK: Input: default@over10k +#### A masked pattern was here #### +POSTHOOK: query: select ts, f, last_value(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k limit 100 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@over10k +#### A masked pattern was here #### +2013-03-01 09:11:58.70307 3.17 NULL +2013-03-01 09:11:58.70307 10.89 3.17 +2013-03-01 09:11:58.70307 14.54 10.89 +2013-03-01 09:11:58.70307 14.78 14.54 +2013-03-01 09:11:58.70307 17.85 14.78 +2013-03-01 09:11:58.70307 20.61 17.85 +2013-03-01 09:11:58.70307 28.69 20.61 +2013-03-01 09:11:58.70307 29.22 28.69 +2013-03-01 09:11:58.70307 31.17 29.22 +2013-03-01 09:11:58.70307 38.35 31.17 +2013-03-01 09:11:58.70307 38.61 38.35 +2013-03-01 09:11:58.70307 39.48 38.61 +2013-03-01 09:11:58.70307 40.54 39.48 +2013-03-01 09:11:58.70307 41.6 40.54 +2013-03-01 09:11:58.70307 46.08 41.6 +2013-03-01 09:11:58.70307 54.36 46.08 +2013-03-01 09:11:58.70307 56.94 54.36 +2013-03-01 09:11:58.70307 64.96 56.94 +2013-03-01 09:11:58.70307 73.52 64.96 +2013-03-01 09:11:58.70307 78.58 73.52 +2013-03-01 09:11:58.70307 81.41 78.58 +2013-03-01 09:11:58.70307 84.71 81.41 +2013-03-01 09:11:58.70307 87.43 84.71 +2013-03-01 09:11:58.70307 91.36 87.43 +2013-03-01 09:11:58.70307 92.96 91.36 +2013-03-01 09:11:58.70307 95.04 92.96 +2013-03-01 09:11:58.703071 0.83 NULL +2013-03-01 09:11:58.703071 1.99 0.83 +2013-03-01 09:11:58.703071 3.73 1.99 +2013-03-01 09:11:58.703071 8.86 3.73 +2013-03-01 09:11:58.703071 10.62 8.86 +2013-03-01 09:11:58.703071 11.32 10.62 +2013-03-01 09:11:58.703071 12.83 11.32 +2013-03-01 09:11:58.703071 14.7 12.83 +2013-03-01 09:11:58.703071 14.96 14.7 +2013-03-01 09:11:58.703071 17.58 14.96 +2013-03-01 09:11:58.703071 19.1 17.58 +2013-03-01 09:11:58.703071 21.01 19.1 +2013-03-01 09:11:58.703071 26.95 21.01 +2013-03-01 09:11:58.703071 27.23 26.95 +2013-03-01 09:11:58.703071 29.07 27.23 +2013-03-01 09:11:58.703071 29.71 29.07 +2013-03-01 09:11:58.703071 31.84 29.71 +2013-03-01 09:11:58.703071 31.94 31.84 +2013-03-01 09:11:58.703071 35.32 31.94 +2013-03-01 09:11:58.703071 37.32 35.32 +2013-03-01 09:11:58.703071 38.5 37.32 +2013-03-01 09:11:58.703071 42.08 38.5 +2013-03-01 09:11:58.703071 44.3 42.08 +2013-03-01 09:11:58.703071 44.66 44.3 +2013-03-01 09:11:58.703071 46.84 44.66 +2013-03-01 09:11:58.703071 48.89 46.84 +2013-03-01 09:11:58.703071 49.64 48.89 +2013-03-01 09:11:58.703071 50.28 49.64 +2013-03-01 09:11:58.703071 52.09 50.28 +2013-03-01 09:11:58.703071 53.26 52.09 +2013-03-01 09:11:58.703071 54.09 53.26 +2013-03-01 09:11:58.703071 56.45 54.09 +2013-03-01 09:11:58.703071 56.76 56.45 +2013-03-01 09:11:58.703071 61.41 56.76 +2013-03-01 09:11:58.703071 61.88 61.41 +2013-03-01 09:11:58.703071 63.03 61.88 +2013-03-01 09:11:58.703071 64.55 63.03 +2013-03-01 09:11:58.703071 68.62 64.55 +2013-03-01 09:11:58.703071 76.13 68.62 +2013-03-01 09:11:58.703071 79.05 76.13 +2013-03-01 09:11:58.703071 80.43 79.05 +2013-03-01 09:11:58.703071 81.41 80.43 +2013-03-01 09:11:58.703071 82.85 81.41 +2013-03-01 09:11:58.703071 83.98 82.85 +2013-03-01 09:11:58.703071 84.21 83.98 +2013-03-01 09:11:58.703071 85.55 84.21 +2013-03-01 09:11:58.703071 87.93 85.55 +2013-03-01 09:11:58.703071 88.93 87.93 +2013-03-01 09:11:58.703071 94.27 88.93 +2013-03-01 09:11:58.703071 99.45 94.27 +2013-03-01 09:11:58.703072 0.36 NULL +2013-03-01 09:11:58.703072 0.48 0.36 +2013-03-01 09:11:58.703072 0.79 0.48 +2013-03-01 09:11:58.703072 1.27 0.79 +2013-03-01 09:11:58.703072 4.48 1.27 +2013-03-01 09:11:58.703072 9.0 4.48 +2013-03-01 09:11:58.703072 23.27 9.0 +2013-03-01 09:11:58.703072 25.13 23.27 +2013-03-01 09:11:58.703072 25.34 25.13 +2013-03-01 09:11:58.703072 25.91 25.34 +2013-03-01 09:11:58.703072 29.01 25.91 +2013-03-01 09:11:58.703072 30.47 29.01 +2013-03-01 09:11:58.703072 37.95 30.47 +2013-03-01 09:11:58.703072 39.3 37.95 +2013-03-01 09:11:58.703072 45.91 39.3 +2013-03-01 09:11:58.703072 52.44 45.91 +2013-03-01 09:11:58.703072 54.1 52.44 +2013-03-01 09:11:58.703072 56.7 54.1 +2013-03-01 09:11:58.703072 58.77 56.7 +2013-03-01 09:11:58.703072 62.09 58.77 +2013-03-01 09:11:58.703072 68.2 62.09 +2013-03-01 09:11:58.703072 71.68 68.2 +2013-03-01 09:11:58.703072 79.46 71.68 +2013-03-01 09:11:58.703072 80.02 79.46 +PREHOOK: query: select ts, f, last_value(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k limit 100 +PREHOOK: type: QUERY +PREHOOK: Input: default@over10k +#### A masked pattern was here #### +POSTHOOK: query: select ts, f, last_value(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k limit 100 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@over10k +#### A masked pattern was here #### +2013-03-01 09:11:58.70307 3.17 14.54 +2013-03-01 09:11:58.70307 10.89 14.78 +2013-03-01 09:11:58.70307 14.54 17.85 +2013-03-01 09:11:58.70307 14.78 20.61 +2013-03-01 09:11:58.70307 17.85 28.69 +2013-03-01 09:11:58.70307 20.61 29.22 +2013-03-01 09:11:58.70307 28.69 31.17 +2013-03-01 09:11:58.70307 29.22 38.35 +2013-03-01 09:11:58.70307 31.17 38.61 +2013-03-01 09:11:58.70307 38.35 39.48 +2013-03-01 09:11:58.70307 38.61 40.54 +2013-03-01 09:11:58.70307 39.48 41.6 +2013-03-01 09:11:58.70307 40.54 46.08 +2013-03-01 09:11:58.70307 41.6 54.36 +2013-03-01 09:11:58.70307 46.08 56.94 +2013-03-01 09:11:58.70307 54.36 64.96 +2013-03-01 09:11:58.70307 56.94 73.52 +2013-03-01 09:11:58.70307 64.96 78.58 +2013-03-01 09:11:58.70307 73.52 81.41 +2013-03-01 09:11:58.70307 78.58 84.71 +2013-03-01 09:11:58.70307 81.41 87.43 +2013-03-01 09:11:58.70307 84.71 91.36 +2013-03-01 09:11:58.70307 87.43 92.96 +2013-03-01 09:11:58.70307 91.36 95.04 +2013-03-01 09:11:58.70307 92.96 95.04 +2013-03-01 09:11:58.70307 95.04 NULL +2013-03-01 09:11:58.703071 0.83 3.73 +2013-03-01 09:11:58.703071 1.99 8.86 +2013-03-01 09:11:58.703071 3.73 10.62 +2013-03-01 09:11:58.703071 8.86 11.32 +2013-03-01 09:11:58.703071 10.62 12.83 +2013-03-01 09:11:58.703071 11.32 14.7 +2013-03-01 09:11:58.703071 12.83 14.96 +2013-03-01 09:11:58.703071 14.7 17.58 +2013-03-01 09:11:58.703071 14.96 19.1 +2013-03-01 09:11:58.703071 17.58 21.01 +2013-03-01 09:11:58.703071 19.1 26.95 +2013-03-01 09:11:58.703071 21.01 27.23 +2013-03-01 09:11:58.703071 26.95 29.07 +2013-03-01 09:11:58.703071 27.23 29.71 +2013-03-01 09:11:58.703071 29.07 31.84 +2013-03-01 09:11:58.703071 29.71 31.94 +2013-03-01 09:11:58.703071 31.84 35.32 +2013-03-01 09:11:58.703071 31.94 37.32 +2013-03-01 09:11:58.703071 35.32 38.5 +2013-03-01 09:11:58.703071 37.32 42.08 +2013-03-01 09:11:58.703071 38.5 44.3 +2013-03-01 09:11:58.703071 42.08 44.66 +2013-03-01 09:11:58.703071 44.3 46.84 +2013-03-01 09:11:58.703071 44.66 48.89 +2013-03-01 09:11:58.703071 46.84 49.64 +2013-03-01 09:11:58.703071 48.89 50.28 +2013-03-01 09:11:58.703071 49.64 52.09 +2013-03-01 09:11:58.703071 50.28 53.26 +2013-03-01 09:11:58.703071 52.09 54.09 +2013-03-01 09:11:58.703071 53.26 56.45 +2013-03-01 09:11:58.703071 54.09 56.76 +2013-03-01 09:11:58.703071 56.45 61.41 +2013-03-01 09:11:58.703071 56.76 61.88 +2013-03-01 09:11:58.703071 61.41 63.03 +2013-03-01 09:11:58.703071 61.88 64.55 +2013-03-01 09:11:58.703071 63.03 68.62 +2013-03-01 09:11:58.703071 64.55 76.13 +2013-03-01 09:11:58.703071 68.62 79.05 +2013-03-01 09:11:58.703071 76.13 80.43 +2013-03-01 09:11:58.703071 79.05 81.41 +2013-03-01 09:11:58.703071 80.43 82.85 +2013-03-01 09:11:58.703071 81.41 83.98 +2013-03-01 09:11:58.703071 82.85 84.21 +2013-03-01 09:11:58.703071 83.98 85.55 +2013-03-01 09:11:58.703071 84.21 87.93 +2013-03-01 09:11:58.703071 85.55 88.93 +2013-03-01 09:11:58.703071 87.93 94.27 +2013-03-01 09:11:58.703071 88.93 99.45 +2013-03-01 09:11:58.703071 94.27 99.45 +2013-03-01 09:11:58.703071 99.45 NULL +2013-03-01 09:11:58.703072 0.36 0.79 +2013-03-01 09:11:58.703072 0.48 1.27 +2013-03-01 09:11:58.703072 0.79 4.48 +2013-03-01 09:11:58.703072 1.27 9.0 +2013-03-01 09:11:58.703072 4.48 23.27 +2013-03-01 09:11:58.703072 9.0 25.13 +2013-03-01 09:11:58.703072 23.27 25.34 +2013-03-01 09:11:58.703072 25.13 25.91 +2013-03-01 09:11:58.703072 25.34 29.01 +2013-03-01 09:11:58.703072 25.91 30.47 +2013-03-01 09:11:58.703072 29.01 37.95 +2013-03-01 09:11:58.703072 30.47 39.3 +2013-03-01 09:11:58.703072 37.95 45.91 +2013-03-01 09:11:58.703072 39.3 52.44 +2013-03-01 09:11:58.703072 45.91 54.1 +2013-03-01 09:11:58.703072 52.44 56.7 +2013-03-01 09:11:58.703072 54.1 58.77 +2013-03-01 09:11:58.703072 56.7 62.09 +2013-03-01 09:11:58.703072 58.77 68.2 +2013-03-01 09:11:58.703072 62.09 71.68 +2013-03-01 09:11:58.703072 68.2 79.46 +2013-03-01 09:11:58.703072 71.68 80.02 +2013-03-01 09:11:58.703072 79.46 81.29 +2013-03-01 09:11:58.703072 80.02 86.98 +PREHOOK: query: select ts, f, last_value(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k limit 100 +PREHOOK: type: QUERY +PREHOOK: Input: default@over10k +#### A masked pattern was here #### +POSTHOOK: query: select ts, f, last_value(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k limit 100 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@over10k +#### A masked pattern was here #### +2013-03-01 09:11:58.70307 3.17 10.89 +2013-03-01 09:11:58.70307 10.89 14.54 +2013-03-01 09:11:58.70307 14.54 14.78 +2013-03-01 09:11:58.70307 14.78 17.85 +2013-03-01 09:11:58.70307 17.85 20.61 +2013-03-01 09:11:58.70307 20.61 28.69 +2013-03-01 09:11:58.70307 28.69 29.22 +2013-03-01 09:11:58.70307 29.22 31.17 +2013-03-01 09:11:58.70307 31.17 38.35 +2013-03-01 09:11:58.70307 38.35 38.61 +2013-03-01 09:11:58.70307 38.61 39.48 +2013-03-01 09:11:58.70307 39.48 40.54 +2013-03-01 09:11:58.70307 40.54 41.6 +2013-03-01 09:11:58.70307 41.6 46.08 +2013-03-01 09:11:58.70307 46.08 54.36 +2013-03-01 09:11:58.70307 54.36 56.94 +2013-03-01 09:11:58.70307 56.94 64.96 +2013-03-01 09:11:58.70307 64.96 73.52 +2013-03-01 09:11:58.70307 73.52 78.58 +2013-03-01 09:11:58.70307 78.58 81.41 +2013-03-01 09:11:58.70307 81.41 84.71 +2013-03-01 09:11:58.70307 84.71 87.43 +2013-03-01 09:11:58.70307 87.43 91.36 +2013-03-01 09:11:58.70307 91.36 92.96 +2013-03-01 09:11:58.70307 92.96 95.04 +2013-03-01 09:11:58.70307 95.04 95.04 +2013-03-01 09:11:58.703071 0.83 1.99 +2013-03-01 09:11:58.703071 1.99 3.73 +2013-03-01 09:11:58.703071 3.73 8.86 +2013-03-01 09:11:58.703071 8.86 10.62 +2013-03-01 09:11:58.703071 10.62 11.32 +2013-03-01 09:11:58.703071 11.32 12.83 +2013-03-01 09:11:58.703071 12.83 14.7 +2013-03-01 09:11:58.703071 14.7 14.96 +2013-03-01 09:11:58.703071 14.96 17.58 +2013-03-01 09:11:58.703071 17.58 19.1 +2013-03-01 09:11:58.703071 19.1 21.01 +2013-03-01 09:11:58.703071 21.01 26.95 +2013-03-01 09:11:58.703071 26.95 27.23 +2013-03-01 09:11:58.703071 27.23 29.07 +2013-03-01 09:11:58.703071 29.07 29.71 +2013-03-01 09:11:58.703071 29.71 31.84 +2013-03-01 09:11:58.703071 31.84 31.94 +2013-03-01 09:11:58.703071 31.94 35.32 +2013-03-01 09:11:58.703071 35.32 37.32 +2013-03-01 09:11:58.703071 37.32 38.5 +2013-03-01 09:11:58.703071 38.5 42.08 +2013-03-01 09:11:58.703071 42.08 44.3 +2013-03-01 09:11:58.703071 44.3 44.66 +2013-03-01 09:11:58.703071 44.66 46.84 +2013-03-01 09:11:58.703071 46.84 48.89 +2013-03-01 09:11:58.703071 48.89 49.64 +2013-03-01 09:11:58.703071 49.64 50.28 +2013-03-01 09:11:58.703071 50.28 52.09 +2013-03-01 09:11:58.703071 52.09 53.26 +2013-03-01 09:11:58.703071 53.26 54.09 +2013-03-01 09:11:58.703071 54.09 56.45 +2013-03-01 09:11:58.703071 56.45 56.76 +2013-03-01 09:11:58.703071 56.76 61.41 +2013-03-01 09:11:58.703071 61.41 61.88 +2013-03-01 09:11:58.703071 61.88 63.03 +2013-03-01 09:11:58.703071 63.03 64.55 +2013-03-01 09:11:58.703071 64.55 68.62 +2013-03-01 09:11:58.703071 68.62 76.13 +2013-03-01 09:11:58.703071 76.13 79.05 +2013-03-01 09:11:58.703071 79.05 80.43 +2013-03-01 09:11:58.703071 80.43 81.41 +2013-03-01 09:11:58.703071 81.41 82.85 +2013-03-01 09:11:58.703071 82.85 83.98 +2013-03-01 09:11:58.703071 83.98 84.21 +2013-03-01 09:11:58.703071 84.21 85.55 +2013-03-01 09:11:58.703071 85.55 87.93 +2013-03-01 09:11:58.703071 87.93 88.93 +2013-03-01 09:11:58.703071 88.93 94.27 +2013-03-01 09:11:58.703071 94.27 99.45 +2013-03-01 09:11:58.703071 99.45 99.45 +2013-03-01 09:11:58.703072 0.36 0.48 +2013-03-01 09:11:58.703072 0.48 0.79 +2013-03-01 09:11:58.703072 0.79 1.27 +2013-03-01 09:11:58.703072 1.27 4.48 +2013-03-01 09:11:58.703072 4.48 9.0 +2013-03-01 09:11:58.703072 9.0 23.27 +2013-03-01 09:11:58.703072 23.27 25.13 +2013-03-01 09:11:58.703072 25.13 25.34 +2013-03-01 09:11:58.703072 25.34 25.91 +2013-03-01 09:11:58.703072 25.91 29.01 +2013-03-01 09:11:58.703072 29.01 30.47 +2013-03-01 09:11:58.703072 30.47 37.95 +2013-03-01 09:11:58.703072 37.95 39.3 +2013-03-01 09:11:58.703072 39.3 45.91 +2013-03-01 09:11:58.703072 45.91 52.44 +2013-03-01 09:11:58.703072 52.44 54.1 +2013-03-01 09:11:58.703072 54.1 56.7 +2013-03-01 09:11:58.703072 56.7 58.77 +2013-03-01 09:11:58.703072 58.77 62.09 +2013-03-01 09:11:58.703072 62.09 68.2 +2013-03-01 09:11:58.703072 68.2 71.68 +2013-03-01 09:11:58.703072 71.68 79.46 +2013-03-01 09:11:58.703072 79.46 80.02 +2013-03-01 09:11:58.703072 80.02 81.29
