You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by xu...@apache.org on 2015/05/29 06:48:01 UTC
[82/84] [abbrv] hive git commit: HIVE-10826 : Support min()/max()
functions over x preceding and y preceding windowing (Aihua Xu via Ashutosh
Chauhan)
HIVE-10826 : Support min()/max() functions over x preceding and y preceding windowing (Aihua Xu via Ashutosh Chauhan)
Signed-off-by: Ashutosh Chauhan <ha...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/2564a92b
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/2564a92b
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/2564a92b
Branch: refs/heads/spark
Commit: 2564a92b2921b2cee956cc67a996173b15fcf98e
Parents: 7368cfd
Author: Aihua Xu <ai...@gmail.com>
Authored: Wed May 27 09:26:00 2015 -0700
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Thu May 28 17:04:48 2015 -0700
----------------------------------------------------------------------
.../hive/ql/udf/generic/GenericUDAFMax.java | 45 +-
.../hive/ql/udf/generic/GenericUDAFMin.java | 8 +-
.../clientpositive/windowing_windowspec2.q | 12 +
.../clientpositive/windowing_windowspec2.q.out | 868 +++++++++++++++++++
4 files changed, 911 insertions(+), 22 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/2564a92b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMax.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMax.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMax.java
index 6b7808a..33600f2 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMax.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMax.java
@@ -130,9 +130,7 @@ public class GenericUDAFMax extends AbstractGenericUDAFResolver {
@Override
public GenericUDAFEvaluator getWindowingEvaluator(WindowFrameDef wFrmDef) {
- BoundaryDef start = wFrmDef.getStart();
- BoundaryDef end = wFrmDef.getEnd();
- return new MaxStreamingFixedWindow(this, start.getAmt(), end.getAmt());
+ return new MaxStreamingFixedWindow(this, wFrmDef);
}
}
@@ -168,7 +166,7 @@ public class GenericUDAFMax extends AbstractGenericUDAFResolver {
public State(AggregationBuffer buf) {
super(buf);
- maxChain = new ArrayDeque<Object[]>(numPreceding + numFollowing + 1);
+ maxChain = new ArrayDeque<Object[]>(wFrameDef.isStartUnbounded() ? 1 : wFrameDef.getWindowSize());
}
@Override
@@ -180,7 +178,7 @@ public class GenericUDAFMax extends AbstractGenericUDAFResolver {
if (underlying == -1) {
return -1;
}
- if (numPreceding == BoundarySpec.UNBOUNDED_AMOUNT) {
+ if (wFrameDef.isStartUnbounded()) {
return -1;
}
/*
@@ -189,7 +187,7 @@ public class GenericUDAFMax 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);
}
@@ -202,8 +200,8 @@ public class GenericUDAFMax extends AbstractGenericUDAFResolver {
}
public MaxStreamingFixedWindow(GenericUDAFEvaluator wrappedEval,
- int numPreceding, int numFollowing) {
- super(wrappedEval, numPreceding, numFollowing);
+ WindowFrameDef wFrmDef) {
+ super(wrappedEval, wFrmDef);
}
@Override
@@ -235,26 +233,32 @@ public class GenericUDAFMax extends AbstractGenericUDAFResolver {
}
}
+ // We need to insert 'null' before processing first row for the case: X preceding and y preceding
+ if (s.numRows == 0) {
+ for (int i = wFrameDef.getEnd().getRelativeOffset(); i < 0; i++) {
+ s.results.add(null);
+ }
+ }
+
/*
* add row to chain. except in case of UNB preceding: - only 1 max needs
* to be tracked. - current max will never become out of range. It can
* only be replaced by a larger max.
*/
- if (numPreceding != BoundarySpec.UNBOUNDED_AMOUNT
- || s.maxChain.isEmpty()) {
+ if (!wFrameDef.isStartUnbounded() || s.maxChain.isEmpty()) {
o = o == null ? null : ObjectInspectorUtils.copyToStandardObject(o,
inputOI(), ObjectInspectorCopyOption.JAVA);
s.maxChain.addLast(new Object[] { o, s.numRows });
}
- if (s.numRows >= numFollowing) {
+ if (s.numRows >= wFrameDef.getEnd().getRelativeOffset()) {
s.results.add(s.maxChain.getFirst()[0]);
}
s.numRows++;
int fIdx = (Integer) s.maxChain.getFirst()[1];
- if (numPreceding != BoundarySpec.UNBOUNDED_AMOUNT
- && s.numRows > fIdx + numPreceding + numFollowing) {
+ if (!wFrameDef.isStartUnbounded()
+ && s.numRows >= fIdx + wFrameDef.getWindowSize()) {
s.maxChain.removeFirst();
}
}
@@ -277,19 +281,26 @@ public class GenericUDAFMax extends AbstractGenericUDAFResolver {
public Object terminate(AggregationBuffer agg) throws HiveException {
State s = (State) agg;
- Object[] r = s.maxChain.getFirst();
+ Object[] r = s.maxChain.isEmpty() ? null : s.maxChain.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[0]);
s.numRows++;
int fIdx = (Integer) r[1];
- if (numPreceding != BoundarySpec.UNBOUNDED_AMOUNT
- && s.numRows - numFollowing + i > fIdx + numPreceding
+ if (!wFrameDef.isStartUnbounded()
+ && s.numRows + i >= fIdx + wFrameDef.getWindowSize()
&& !s.maxChain.isEmpty()) {
s.maxChain.removeFirst();
r = !s.maxChain.isEmpty() ? s.maxChain.getFirst() : r;
}
}
+ 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/2564a92b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMin.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMin.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMin.java
index d931d52..816350f 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMin.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFMin.java
@@ -125,9 +125,7 @@ public class GenericUDAFMin extends AbstractGenericUDAFResolver {
@Override
public GenericUDAFEvaluator getWindowingEvaluator(WindowFrameDef wFrmDef) {
- BoundaryDef start = wFrmDef.getStart();
- BoundaryDef end = wFrmDef.getEnd();
- return new MinStreamingFixedWindow(this, start.getAmt(), end.getAmt());
+ return new MinStreamingFixedWindow(this, wFrmDef);
}
}
@@ -135,8 +133,8 @@ public class GenericUDAFMin extends AbstractGenericUDAFResolver {
static class MinStreamingFixedWindow extends MaxStreamingFixedWindow {
public MinStreamingFixedWindow(GenericUDAFEvaluator wrappedEval,
- int numPreceding, int numFollowing) {
- super(wrappedEval, numPreceding, numFollowing);
+ WindowFrameDef wFrmDef) {
+ super(wrappedEval, wFrmDef);
}
protected ObjectInspector inputOI() {
http://git-wip-us.apache.org/repos/asf/hive/blob/2564a92b/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 d85cea9..e77c4eb 100644
--- a/ql/src/test/queries/clientpositive/windowing_windowspec2.q
+++ b/ql/src/test/queries/clientpositive/windowing_windowspec2.q
@@ -28,3 +28,15 @@ select ts, f, count(f) over (partition by ts order by f rows between 2 preceding
select ts, f, count(f) over (partition by ts order by f rows between unbounded preceding and 1 preceding) from over10k limit 100;
select ts, f, count(f) over (partition by ts order by f rows between 1 following and 2 following) from over10k limit 100;
select ts, f, count(f) over (partition by ts order by f rows between unbounded preceding and 1 following) from over10k limit 100;
+
+-- max
+select ts, f, max(f) over (partition by ts order by t rows between 2 preceding and 1 preceding) from over10k limit 100;
+select ts, f, max(f) over (partition by ts order by t rows between unbounded preceding and 1 preceding) from over10k limit 100;
+select ts, f, max(f) over (partition by ts order by t rows between 1 following and 2 following) from over10k limit 100;
+select ts, f, max(f) over (partition by ts order by t rows between unbounded preceding and 1 following) from over10k limit 100;
+
+-- min
+select ts, f, min(f) over (partition by ts order by t rows between 2 preceding and 1 preceding) from over10k limit 100;
+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;
http://git-wip-us.apache.org/repos/asf/hive/blob/2564a92b/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 bf91639..b187f35 100644
--- a/ql/src/test/results/clientpositive/windowing_windowspec2.q.out
+++ b/ql/src/test/results/clientpositive/windowing_windowspec2.q.out
@@ -912,3 +912,871 @@ POSTHOOK: Input: default@over10k
2013-03-01 09:11:58.703072 71.68 23
2013-03-01 09:11:58.703072 79.46 24
2013-03-01 09:11:58.703072 80.02 25
+PREHOOK: query: -- max
+select ts, f, max(f) over (partition by ts order by t 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: -- max
+select ts, f, max(f) over (partition by ts order by t 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 14.54 NULL
+2013-03-01 09:11:58.70307 29.22 14.54
+2013-03-01 09:11:58.70307 39.48 29.22
+2013-03-01 09:11:58.70307 17.85 39.48
+2013-03-01 09:11:58.70307 31.17 39.48
+2013-03-01 09:11:58.70307 56.94 31.17
+2013-03-01 09:11:58.70307 78.58 56.94
+2013-03-01 09:11:58.70307 38.61 78.58
+2013-03-01 09:11:58.70307 14.78 78.58
+2013-03-01 09:11:58.70307 91.36 38.61
+2013-03-01 09:11:58.70307 28.69 91.36
+2013-03-01 09:11:58.70307 73.52 91.36
+2013-03-01 09:11:58.70307 92.96 73.52
+2013-03-01 09:11:58.70307 95.04 92.96
+2013-03-01 09:11:58.70307 41.6 95.04
+2013-03-01 09:11:58.70307 64.96 95.04
+2013-03-01 09:11:58.70307 84.71 64.96
+2013-03-01 09:11:58.70307 81.41 84.71
+2013-03-01 09:11:58.70307 10.89 84.71
+2013-03-01 09:11:58.70307 20.61 81.41
+2013-03-01 09:11:58.70307 54.36 20.61
+2013-03-01 09:11:58.70307 87.43 54.36
+2013-03-01 09:11:58.70307 46.08 87.43
+2013-03-01 09:11:58.70307 40.54 87.43
+2013-03-01 09:11:58.70307 38.35 46.08
+2013-03-01 09:11:58.70307 3.17 40.54
+2013-03-01 09:11:58.703071 0.83 NULL
+2013-03-01 09:11:58.703071 56.76 0.83
+2013-03-01 09:11:58.703071 99.45 56.76
+2013-03-01 09:11:58.703071 79.05 99.45
+2013-03-01 09:11:58.703071 14.96 99.45
+2013-03-01 09:11:58.703071 85.55 79.05
+2013-03-01 09:11:58.703071 14.7 85.55
+2013-03-01 09:11:58.703071 81.41 85.55
+2013-03-01 09:11:58.703071 87.93 81.41
+2013-03-01 09:11:58.703071 26.95 87.93
+2013-03-01 09:11:58.703071 37.32 87.93
+2013-03-01 09:11:58.703071 68.62 37.32
+2013-03-01 09:11:58.703071 80.43 68.62
+2013-03-01 09:11:58.703071 54.09 80.43
+2013-03-01 09:11:58.703071 42.08 80.43
+2013-03-01 09:11:58.703071 64.55 54.09
+2013-03-01 09:11:58.703071 48.89 64.55
+2013-03-01 09:11:58.703071 56.45 64.55
+2013-03-01 09:11:58.703071 1.99 56.45
+2013-03-01 09:11:58.703071 94.27 56.45
+2013-03-01 09:11:58.703071 35.32 94.27
+2013-03-01 09:11:58.703071 10.62 94.27
+2013-03-01 09:11:58.703071 52.09 35.32
+2013-03-01 09:11:58.703071 63.03 52.09
+2013-03-01 09:11:58.703071 76.13 63.03
+2013-03-01 09:11:58.703071 44.3 76.13
+2013-03-01 09:11:58.703071 44.66 76.13
+2013-03-01 09:11:58.703071 17.58 44.66
+2013-03-01 09:11:58.703071 11.32 44.66
+2013-03-01 09:11:58.703071 38.5 17.58
+2013-03-01 09:11:58.703071 82.85 38.5
+2013-03-01 09:11:58.703071 49.64 82.85
+2013-03-01 09:11:58.703071 27.23 82.85
+2013-03-01 09:11:58.703071 83.98 49.64
+2013-03-01 09:11:58.703071 31.84 83.98
+2013-03-01 09:11:58.703071 50.28 83.98
+2013-03-01 09:11:58.703071 3.73 50.28
+2013-03-01 09:11:58.703071 53.26 50.28
+2013-03-01 09:11:58.703071 29.71 53.26
+2013-03-01 09:11:58.703071 8.86 53.26
+2013-03-01 09:11:58.703071 21.01 29.71
+2013-03-01 09:11:58.703071 84.21 21.01
+2013-03-01 09:11:58.703071 19.1 84.21
+2013-03-01 09:11:58.703071 31.94 84.21
+2013-03-01 09:11:58.703071 88.93 31.94
+2013-03-01 09:11:58.703071 12.83 88.93
+2013-03-01 09:11:58.703071 29.07 88.93
+2013-03-01 09:11:58.703071 61.88 29.07
+2013-03-01 09:11:58.703071 61.41 61.88
+2013-03-01 09:11:58.703071 46.84 61.88
+2013-03-01 09:11:58.703072 95.01 NULL
+2013-03-01 09:11:58.703072 62.09 95.01
+2013-03-01 09:11:58.703072 29.01 95.01
+2013-03-01 09:11:58.703072 79.46 62.09
+2013-03-01 09:11:58.703072 4.48 79.46
+2013-03-01 09:11:58.703072 99.26 79.46
+2013-03-01 09:11:58.703072 58.77 99.26
+2013-03-01 09:11:58.703072 86.98 99.26
+2013-03-01 09:11:58.703072 30.47 86.98
+2013-03-01 09:11:58.703072 68.2 86.98
+2013-03-01 09:11:58.703072 52.44 68.2
+2013-03-01 09:11:58.703072 0.79 68.2
+2013-03-01 09:11:58.703072 25.34 52.44
+2013-03-01 09:11:58.703072 81.29 25.34
+2013-03-01 09:11:58.703072 71.68 81.29
+2013-03-01 09:11:58.703072 1.27 81.29
+2013-03-01 09:11:58.703072 56.7 71.68
+2013-03-01 09:11:58.703072 39.3 56.7
+2013-03-01 09:11:58.703072 25.91 56.7
+2013-03-01 09:11:58.703072 88.08 39.3
+2013-03-01 09:11:58.703072 0.48 88.08
+2013-03-01 09:11:58.703072 88.83 88.08
+2013-03-01 09:11:58.703072 9.0 88.83
+2013-03-01 09:11:58.703072 54.1 88.83
+PREHOOK: query: select ts, f, max(f) over (partition by ts order by t 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, max(f) over (partition by ts order by t 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 14.54 NULL
+2013-03-01 09:11:58.70307 29.22 14.54
+2013-03-01 09:11:58.70307 39.48 29.22
+2013-03-01 09:11:58.70307 17.85 39.48
+2013-03-01 09:11:58.70307 31.17 39.48
+2013-03-01 09:11:58.70307 56.94 39.48
+2013-03-01 09:11:58.70307 78.58 56.94
+2013-03-01 09:11:58.70307 38.61 78.58
+2013-03-01 09:11:58.70307 14.78 78.58
+2013-03-01 09:11:58.70307 91.36 78.58
+2013-03-01 09:11:58.70307 28.69 91.36
+2013-03-01 09:11:58.70307 73.52 91.36
+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.70307 41.6 95.04
+2013-03-01 09:11:58.70307 64.96 95.04
+2013-03-01 09:11:58.70307 84.71 95.04
+2013-03-01 09:11:58.70307 81.41 95.04
+2013-03-01 09:11:58.70307 10.89 95.04
+2013-03-01 09:11:58.70307 20.61 95.04
+2013-03-01 09:11:58.70307 54.36 95.04
+2013-03-01 09:11:58.70307 87.43 95.04
+2013-03-01 09:11:58.70307 46.08 95.04
+2013-03-01 09:11:58.70307 40.54 95.04
+2013-03-01 09:11:58.70307 38.35 95.04
+2013-03-01 09:11:58.70307 3.17 95.04
+2013-03-01 09:11:58.703071 0.83 NULL
+2013-03-01 09:11:58.703071 56.76 0.83
+2013-03-01 09:11:58.703071 99.45 56.76
+2013-03-01 09:11:58.703071 79.05 99.45
+2013-03-01 09:11:58.703071 14.96 99.45
+2013-03-01 09:11:58.703071 85.55 99.45
+2013-03-01 09:11:58.703071 14.7 99.45
+2013-03-01 09:11:58.703071 81.41 99.45
+2013-03-01 09:11:58.703071 87.93 99.45
+2013-03-01 09:11:58.703071 26.95 99.45
+2013-03-01 09:11:58.703071 37.32 99.45
+2013-03-01 09:11:58.703071 68.62 99.45
+2013-03-01 09:11:58.703071 80.43 99.45
+2013-03-01 09:11:58.703071 54.09 99.45
+2013-03-01 09:11:58.703071 42.08 99.45
+2013-03-01 09:11:58.703071 64.55 99.45
+2013-03-01 09:11:58.703071 48.89 99.45
+2013-03-01 09:11:58.703071 56.45 99.45
+2013-03-01 09:11:58.703071 1.99 99.45
+2013-03-01 09:11:58.703071 94.27 99.45
+2013-03-01 09:11:58.703071 35.32 99.45
+2013-03-01 09:11:58.703071 10.62 99.45
+2013-03-01 09:11:58.703071 52.09 99.45
+2013-03-01 09:11:58.703071 63.03 99.45
+2013-03-01 09:11:58.703071 76.13 99.45
+2013-03-01 09:11:58.703071 44.3 99.45
+2013-03-01 09:11:58.703071 44.66 99.45
+2013-03-01 09:11:58.703071 17.58 99.45
+2013-03-01 09:11:58.703071 11.32 99.45
+2013-03-01 09:11:58.703071 38.5 99.45
+2013-03-01 09:11:58.703071 82.85 99.45
+2013-03-01 09:11:58.703071 49.64 99.45
+2013-03-01 09:11:58.703071 27.23 99.45
+2013-03-01 09:11:58.703071 83.98 99.45
+2013-03-01 09:11:58.703071 31.84 99.45
+2013-03-01 09:11:58.703071 50.28 99.45
+2013-03-01 09:11:58.703071 3.73 99.45
+2013-03-01 09:11:58.703071 53.26 99.45
+2013-03-01 09:11:58.703071 29.71 99.45
+2013-03-01 09:11:58.703071 8.86 99.45
+2013-03-01 09:11:58.703071 21.01 99.45
+2013-03-01 09:11:58.703071 84.21 99.45
+2013-03-01 09:11:58.703071 19.1 99.45
+2013-03-01 09:11:58.703071 31.94 99.45
+2013-03-01 09:11:58.703071 88.93 99.45
+2013-03-01 09:11:58.703071 12.83 99.45
+2013-03-01 09:11:58.703071 29.07 99.45
+2013-03-01 09:11:58.703071 61.88 99.45
+2013-03-01 09:11:58.703071 61.41 99.45
+2013-03-01 09:11:58.703071 46.84 99.45
+2013-03-01 09:11:58.703072 95.01 NULL
+2013-03-01 09:11:58.703072 62.09 95.01
+2013-03-01 09:11:58.703072 29.01 95.01
+2013-03-01 09:11:58.703072 79.46 95.01
+2013-03-01 09:11:58.703072 4.48 95.01
+2013-03-01 09:11:58.703072 99.26 95.01
+2013-03-01 09:11:58.703072 58.77 99.26
+2013-03-01 09:11:58.703072 86.98 99.26
+2013-03-01 09:11:58.703072 30.47 99.26
+2013-03-01 09:11:58.703072 68.2 99.26
+2013-03-01 09:11:58.703072 52.44 99.26
+2013-03-01 09:11:58.703072 0.79 99.26
+2013-03-01 09:11:58.703072 25.34 99.26
+2013-03-01 09:11:58.703072 81.29 99.26
+2013-03-01 09:11:58.703072 71.68 99.26
+2013-03-01 09:11:58.703072 1.27 99.26
+2013-03-01 09:11:58.703072 56.7 99.26
+2013-03-01 09:11:58.703072 39.3 99.26
+2013-03-01 09:11:58.703072 25.91 99.26
+2013-03-01 09:11:58.703072 88.08 99.26
+2013-03-01 09:11:58.703072 0.48 99.26
+2013-03-01 09:11:58.703072 88.83 99.26
+2013-03-01 09:11:58.703072 9.0 99.26
+2013-03-01 09:11:58.703072 54.1 99.26
+PREHOOK: query: select ts, f, max(f) over (partition by ts order by t 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, max(f) over (partition by ts order by t 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 14.54 39.48
+2013-03-01 09:11:58.70307 29.22 39.48
+2013-03-01 09:11:58.70307 39.48 31.17
+2013-03-01 09:11:58.70307 17.85 56.94
+2013-03-01 09:11:58.70307 31.17 78.58
+2013-03-01 09:11:58.70307 56.94 78.58
+2013-03-01 09:11:58.70307 78.58 38.61
+2013-03-01 09:11:58.70307 38.61 91.36
+2013-03-01 09:11:58.70307 14.78 91.36
+2013-03-01 09:11:58.70307 91.36 73.52
+2013-03-01 09:11:58.70307 28.69 92.96
+2013-03-01 09:11:58.70307 73.52 95.04
+2013-03-01 09:11:58.70307 92.96 95.04
+2013-03-01 09:11:58.70307 95.04 64.96
+2013-03-01 09:11:58.70307 41.6 84.71
+2013-03-01 09:11:58.70307 64.96 84.71
+2013-03-01 09:11:58.70307 84.71 81.41
+2013-03-01 09:11:58.70307 81.41 20.61
+2013-03-01 09:11:58.70307 10.89 54.36
+2013-03-01 09:11:58.70307 20.61 87.43
+2013-03-01 09:11:58.70307 54.36 87.43
+2013-03-01 09:11:58.70307 87.43 46.08
+2013-03-01 09:11:58.70307 46.08 40.54
+2013-03-01 09:11:58.70307 40.54 38.35
+2013-03-01 09:11:58.70307 38.35 3.17
+2013-03-01 09:11:58.70307 3.17 NULL
+2013-03-01 09:11:58.703071 0.83 99.45
+2013-03-01 09:11:58.703071 56.76 99.45
+2013-03-01 09:11:58.703071 99.45 79.05
+2013-03-01 09:11:58.703071 79.05 85.55
+2013-03-01 09:11:58.703071 14.96 85.55
+2013-03-01 09:11:58.703071 85.55 81.41
+2013-03-01 09:11:58.703071 14.7 87.93
+2013-03-01 09:11:58.703071 81.41 87.93
+2013-03-01 09:11:58.703071 87.93 37.32
+2013-03-01 09:11:58.703071 26.95 68.62
+2013-03-01 09:11:58.703071 37.32 80.43
+2013-03-01 09:11:58.703071 68.62 80.43
+2013-03-01 09:11:58.703071 80.43 54.09
+2013-03-01 09:11:58.703071 54.09 64.55
+2013-03-01 09:11:58.703071 42.08 64.55
+2013-03-01 09:11:58.703071 64.55 56.45
+2013-03-01 09:11:58.703071 48.89 56.45
+2013-03-01 09:11:58.703071 56.45 94.27
+2013-03-01 09:11:58.703071 1.99 94.27
+2013-03-01 09:11:58.703071 94.27 35.32
+2013-03-01 09:11:58.703071 35.32 52.09
+2013-03-01 09:11:58.703071 10.62 63.03
+2013-03-01 09:11:58.703071 52.09 76.13
+2013-03-01 09:11:58.703071 63.03 76.13
+2013-03-01 09:11:58.703071 76.13 44.66
+2013-03-01 09:11:58.703071 44.3 44.66
+2013-03-01 09:11:58.703071 44.66 17.58
+2013-03-01 09:11:58.703071 17.58 38.5
+2013-03-01 09:11:58.703071 11.32 82.85
+2013-03-01 09:11:58.703071 38.5 82.85
+2013-03-01 09:11:58.703071 82.85 49.64
+2013-03-01 09:11:58.703071 49.64 83.98
+2013-03-01 09:11:58.703071 27.23 83.98
+2013-03-01 09:11:58.703071 83.98 50.28
+2013-03-01 09:11:58.703071 31.84 50.28
+2013-03-01 09:11:58.703071 50.28 53.26
+2013-03-01 09:11:58.703071 3.73 53.26
+2013-03-01 09:11:58.703071 53.26 29.71
+2013-03-01 09:11:58.703071 29.71 21.01
+2013-03-01 09:11:58.703071 8.86 84.21
+2013-03-01 09:11:58.703071 21.01 84.21
+2013-03-01 09:11:58.703071 84.21 31.94
+2013-03-01 09:11:58.703071 19.1 88.93
+2013-03-01 09:11:58.703071 31.94 88.93
+2013-03-01 09:11:58.703071 88.93 29.07
+2013-03-01 09:11:58.703071 12.83 61.88
+2013-03-01 09:11:58.703071 29.07 61.88
+2013-03-01 09:11:58.703071 61.88 61.41
+2013-03-01 09:11:58.703071 61.41 46.84
+2013-03-01 09:11:58.703071 46.84 NULL
+2013-03-01 09:11:58.703072 95.01 62.09
+2013-03-01 09:11:58.703072 62.09 79.46
+2013-03-01 09:11:58.703072 29.01 79.46
+2013-03-01 09:11:58.703072 79.46 99.26
+2013-03-01 09:11:58.703072 4.48 99.26
+2013-03-01 09:11:58.703072 99.26 86.98
+2013-03-01 09:11:58.703072 58.77 86.98
+2013-03-01 09:11:58.703072 86.98 68.2
+2013-03-01 09:11:58.703072 30.47 68.2
+2013-03-01 09:11:58.703072 68.2 52.44
+2013-03-01 09:11:58.703072 52.44 25.34
+2013-03-01 09:11:58.703072 0.79 81.29
+2013-03-01 09:11:58.703072 25.34 81.29
+2013-03-01 09:11:58.703072 81.29 71.68
+2013-03-01 09:11:58.703072 71.68 56.7
+2013-03-01 09:11:58.703072 1.27 56.7
+2013-03-01 09:11:58.703072 56.7 39.3
+2013-03-01 09:11:58.703072 39.3 88.08
+2013-03-01 09:11:58.703072 25.91 88.08
+2013-03-01 09:11:58.703072 88.08 88.83
+2013-03-01 09:11:58.703072 0.48 88.83
+2013-03-01 09:11:58.703072 88.83 54.1
+2013-03-01 09:11:58.703072 9.0 54.1
+2013-03-01 09:11:58.703072 54.1 45.91
+PREHOOK: query: select ts, f, max(f) over (partition by ts order by t 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, max(f) over (partition by ts order by t 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 14.54 29.22
+2013-03-01 09:11:58.70307 29.22 39.48
+2013-03-01 09:11:58.70307 39.48 39.48
+2013-03-01 09:11:58.70307 17.85 39.48
+2013-03-01 09:11:58.70307 31.17 56.94
+2013-03-01 09:11:58.70307 56.94 78.58
+2013-03-01 09:11:58.70307 78.58 78.58
+2013-03-01 09:11:58.70307 38.61 78.58
+2013-03-01 09:11:58.70307 14.78 91.36
+2013-03-01 09:11:58.70307 91.36 91.36
+2013-03-01 09:11:58.70307 28.69 91.36
+2013-03-01 09:11:58.70307 73.52 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.70307 41.6 95.04
+2013-03-01 09:11:58.70307 64.96 95.04
+2013-03-01 09:11:58.70307 84.71 95.04
+2013-03-01 09:11:58.70307 81.41 95.04
+2013-03-01 09:11:58.70307 10.89 95.04
+2013-03-01 09:11:58.70307 20.61 95.04
+2013-03-01 09:11:58.70307 54.36 95.04
+2013-03-01 09:11:58.70307 87.43 95.04
+2013-03-01 09:11:58.70307 46.08 95.04
+2013-03-01 09:11:58.70307 40.54 95.04
+2013-03-01 09:11:58.70307 38.35 95.04
+2013-03-01 09:11:58.70307 3.17 95.04
+2013-03-01 09:11:58.703071 0.83 56.76
+2013-03-01 09:11:58.703071 56.76 99.45
+2013-03-01 09:11:58.703071 99.45 99.45
+2013-03-01 09:11:58.703071 79.05 99.45
+2013-03-01 09:11:58.703071 14.96 99.45
+2013-03-01 09:11:58.703071 85.55 99.45
+2013-03-01 09:11:58.703071 14.7 99.45
+2013-03-01 09:11:58.703071 81.41 99.45
+2013-03-01 09:11:58.703071 87.93 99.45
+2013-03-01 09:11:58.703071 26.95 99.45
+2013-03-01 09:11:58.703071 37.32 99.45
+2013-03-01 09:11:58.703071 68.62 99.45
+2013-03-01 09:11:58.703071 80.43 99.45
+2013-03-01 09:11:58.703071 54.09 99.45
+2013-03-01 09:11:58.703071 42.08 99.45
+2013-03-01 09:11:58.703071 64.55 99.45
+2013-03-01 09:11:58.703071 48.89 99.45
+2013-03-01 09:11:58.703071 56.45 99.45
+2013-03-01 09:11:58.703071 1.99 99.45
+2013-03-01 09:11:58.703071 94.27 99.45
+2013-03-01 09:11:58.703071 35.32 99.45
+2013-03-01 09:11:58.703071 10.62 99.45
+2013-03-01 09:11:58.703071 52.09 99.45
+2013-03-01 09:11:58.703071 63.03 99.45
+2013-03-01 09:11:58.703071 76.13 99.45
+2013-03-01 09:11:58.703071 44.3 99.45
+2013-03-01 09:11:58.703071 44.66 99.45
+2013-03-01 09:11:58.703071 17.58 99.45
+2013-03-01 09:11:58.703071 11.32 99.45
+2013-03-01 09:11:58.703071 38.5 99.45
+2013-03-01 09:11:58.703071 82.85 99.45
+2013-03-01 09:11:58.703071 49.64 99.45
+2013-03-01 09:11:58.703071 27.23 99.45
+2013-03-01 09:11:58.703071 83.98 99.45
+2013-03-01 09:11:58.703071 31.84 99.45
+2013-03-01 09:11:58.703071 50.28 99.45
+2013-03-01 09:11:58.703071 3.73 99.45
+2013-03-01 09:11:58.703071 53.26 99.45
+2013-03-01 09:11:58.703071 29.71 99.45
+2013-03-01 09:11:58.703071 8.86 99.45
+2013-03-01 09:11:58.703071 21.01 99.45
+2013-03-01 09:11:58.703071 84.21 99.45
+2013-03-01 09:11:58.703071 19.1 99.45
+2013-03-01 09:11:58.703071 31.94 99.45
+2013-03-01 09:11:58.703071 88.93 99.45
+2013-03-01 09:11:58.703071 12.83 99.45
+2013-03-01 09:11:58.703071 29.07 99.45
+2013-03-01 09:11:58.703071 61.88 99.45
+2013-03-01 09:11:58.703071 61.41 99.45
+2013-03-01 09:11:58.703071 46.84 99.45
+2013-03-01 09:11:58.703072 95.01 95.01
+2013-03-01 09:11:58.703072 62.09 95.01
+2013-03-01 09:11:58.703072 29.01 95.01
+2013-03-01 09:11:58.703072 79.46 95.01
+2013-03-01 09:11:58.703072 4.48 99.26
+2013-03-01 09:11:58.703072 99.26 99.26
+2013-03-01 09:11:58.703072 58.77 99.26
+2013-03-01 09:11:58.703072 86.98 99.26
+2013-03-01 09:11:58.703072 30.47 99.26
+2013-03-01 09:11:58.703072 68.2 99.26
+2013-03-01 09:11:58.703072 52.44 99.26
+2013-03-01 09:11:58.703072 0.79 99.26
+2013-03-01 09:11:58.703072 25.34 99.26
+2013-03-01 09:11:58.703072 81.29 99.26
+2013-03-01 09:11:58.703072 71.68 99.26
+2013-03-01 09:11:58.703072 1.27 99.26
+2013-03-01 09:11:58.703072 56.7 99.26
+2013-03-01 09:11:58.703072 39.3 99.26
+2013-03-01 09:11:58.703072 25.91 99.26
+2013-03-01 09:11:58.703072 88.08 99.26
+2013-03-01 09:11:58.703072 0.48 99.26
+2013-03-01 09:11:58.703072 88.83 99.26
+2013-03-01 09:11:58.703072 9.0 99.26
+2013-03-01 09:11:58.703072 54.1 99.26
+PREHOOK: query: -- min
+select ts, f, min(f) over (partition by ts order by t 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: -- min
+select ts, f, min(f) over (partition by ts order by t 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 14.54 NULL
+2013-03-01 09:11:58.70307 29.22 14.54
+2013-03-01 09:11:58.70307 39.48 14.54
+2013-03-01 09:11:58.70307 17.85 29.22
+2013-03-01 09:11:58.70307 31.17 17.85
+2013-03-01 09:11:58.70307 56.94 17.85
+2013-03-01 09:11:58.70307 78.58 31.17
+2013-03-01 09:11:58.70307 38.61 56.94
+2013-03-01 09:11:58.70307 14.78 38.61
+2013-03-01 09:11:58.70307 91.36 14.78
+2013-03-01 09:11:58.70307 28.69 14.78
+2013-03-01 09:11:58.70307 73.52 28.69
+2013-03-01 09:11:58.70307 92.96 28.69
+2013-03-01 09:11:58.70307 95.04 73.52
+2013-03-01 09:11:58.70307 41.6 92.96
+2013-03-01 09:11:58.70307 64.96 41.6
+2013-03-01 09:11:58.70307 84.71 41.6
+2013-03-01 09:11:58.70307 81.41 64.96
+2013-03-01 09:11:58.70307 10.89 81.41
+2013-03-01 09:11:58.70307 20.61 10.89
+2013-03-01 09:11:58.70307 54.36 10.89
+2013-03-01 09:11:58.70307 87.43 20.61
+2013-03-01 09:11:58.70307 46.08 54.36
+2013-03-01 09:11:58.70307 40.54 46.08
+2013-03-01 09:11:58.70307 38.35 40.54
+2013-03-01 09:11:58.70307 3.17 38.35
+2013-03-01 09:11:58.703071 0.83 NULL
+2013-03-01 09:11:58.703071 56.76 0.83
+2013-03-01 09:11:58.703071 99.45 0.83
+2013-03-01 09:11:58.703071 79.05 56.76
+2013-03-01 09:11:58.703071 14.96 79.05
+2013-03-01 09:11:58.703071 85.55 14.96
+2013-03-01 09:11:58.703071 14.7 14.96
+2013-03-01 09:11:58.703071 81.41 14.7
+2013-03-01 09:11:58.703071 87.93 14.7
+2013-03-01 09:11:58.703071 26.95 81.41
+2013-03-01 09:11:58.703071 37.32 26.95
+2013-03-01 09:11:58.703071 68.62 26.95
+2013-03-01 09:11:58.703071 80.43 37.32
+2013-03-01 09:11:58.703071 54.09 68.62
+2013-03-01 09:11:58.703071 42.08 54.09
+2013-03-01 09:11:58.703071 64.55 42.08
+2013-03-01 09:11:58.703071 48.89 42.08
+2013-03-01 09:11:58.703071 56.45 48.89
+2013-03-01 09:11:58.703071 1.99 48.89
+2013-03-01 09:11:58.703071 94.27 1.99
+2013-03-01 09:11:58.703071 35.32 1.99
+2013-03-01 09:11:58.703071 10.62 35.32
+2013-03-01 09:11:58.703071 52.09 10.62
+2013-03-01 09:11:58.703071 63.03 10.62
+2013-03-01 09:11:58.703071 76.13 52.09
+2013-03-01 09:11:58.703071 44.3 63.03
+2013-03-01 09:11:58.703071 44.66 44.3
+2013-03-01 09:11:58.703071 17.58 44.3
+2013-03-01 09:11:58.703071 11.32 17.58
+2013-03-01 09:11:58.703071 38.5 11.32
+2013-03-01 09:11:58.703071 82.85 11.32
+2013-03-01 09:11:58.703071 49.64 38.5
+2013-03-01 09:11:58.703071 27.23 49.64
+2013-03-01 09:11:58.703071 83.98 27.23
+2013-03-01 09:11:58.703071 31.84 27.23
+2013-03-01 09:11:58.703071 50.28 31.84
+2013-03-01 09:11:58.703071 3.73 31.84
+2013-03-01 09:11:58.703071 53.26 3.73
+2013-03-01 09:11:58.703071 29.71 3.73
+2013-03-01 09:11:58.703071 8.86 29.71
+2013-03-01 09:11:58.703071 21.01 8.86
+2013-03-01 09:11:58.703071 84.21 8.86
+2013-03-01 09:11:58.703071 19.1 21.01
+2013-03-01 09:11:58.703071 31.94 19.1
+2013-03-01 09:11:58.703071 88.93 19.1
+2013-03-01 09:11:58.703071 12.83 31.94
+2013-03-01 09:11:58.703071 29.07 12.83
+2013-03-01 09:11:58.703071 61.88 12.83
+2013-03-01 09:11:58.703071 61.41 29.07
+2013-03-01 09:11:58.703071 46.84 61.41
+2013-03-01 09:11:58.703072 95.01 NULL
+2013-03-01 09:11:58.703072 62.09 95.01
+2013-03-01 09:11:58.703072 29.01 62.09
+2013-03-01 09:11:58.703072 79.46 29.01
+2013-03-01 09:11:58.703072 4.48 29.01
+2013-03-01 09:11:58.703072 99.26 4.48
+2013-03-01 09:11:58.703072 58.77 4.48
+2013-03-01 09:11:58.703072 86.98 58.77
+2013-03-01 09:11:58.703072 30.47 58.77
+2013-03-01 09:11:58.703072 68.2 30.47
+2013-03-01 09:11:58.703072 52.44 30.47
+2013-03-01 09:11:58.703072 0.79 52.44
+2013-03-01 09:11:58.703072 25.34 0.79
+2013-03-01 09:11:58.703072 81.29 0.79
+2013-03-01 09:11:58.703072 71.68 25.34
+2013-03-01 09:11:58.703072 1.27 71.68
+2013-03-01 09:11:58.703072 56.7 1.27
+2013-03-01 09:11:58.703072 39.3 1.27
+2013-03-01 09:11:58.703072 25.91 39.3
+2013-03-01 09:11:58.703072 88.08 25.91
+2013-03-01 09:11:58.703072 0.48 25.91
+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 9.0
+PREHOOK: query: select ts, f, min(f) over (partition by ts order by t 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, min(f) over (partition by ts order by t 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 14.54 NULL
+2013-03-01 09:11:58.70307 29.22 14.54
+2013-03-01 09:11:58.70307 39.48 14.54
+2013-03-01 09:11:58.70307 17.85 14.54
+2013-03-01 09:11:58.70307 31.17 14.54
+2013-03-01 09:11:58.70307 56.94 14.54
+2013-03-01 09:11:58.70307 78.58 14.54
+2013-03-01 09:11:58.70307 38.61 14.54
+2013-03-01 09:11:58.70307 14.78 14.54
+2013-03-01 09:11:58.70307 91.36 14.54
+2013-03-01 09:11:58.70307 28.69 14.54
+2013-03-01 09:11:58.70307 73.52 14.54
+2013-03-01 09:11:58.70307 92.96 14.54
+2013-03-01 09:11:58.70307 95.04 14.54
+2013-03-01 09:11:58.70307 41.6 14.54
+2013-03-01 09:11:58.70307 64.96 14.54
+2013-03-01 09:11:58.70307 84.71 14.54
+2013-03-01 09:11:58.70307 81.41 14.54
+2013-03-01 09:11:58.70307 10.89 14.54
+2013-03-01 09:11:58.70307 20.61 10.89
+2013-03-01 09:11:58.70307 54.36 10.89
+2013-03-01 09:11:58.70307 87.43 10.89
+2013-03-01 09:11:58.70307 46.08 10.89
+2013-03-01 09:11:58.70307 40.54 10.89
+2013-03-01 09:11:58.70307 38.35 10.89
+2013-03-01 09:11:58.70307 3.17 10.89
+2013-03-01 09:11:58.703071 0.83 NULL
+2013-03-01 09:11:58.703071 56.76 0.83
+2013-03-01 09:11:58.703071 99.45 0.83
+2013-03-01 09:11:58.703071 79.05 0.83
+2013-03-01 09:11:58.703071 14.96 0.83
+2013-03-01 09:11:58.703071 85.55 0.83
+2013-03-01 09:11:58.703071 14.7 0.83
+2013-03-01 09:11:58.703071 81.41 0.83
+2013-03-01 09:11:58.703071 87.93 0.83
+2013-03-01 09:11:58.703071 26.95 0.83
+2013-03-01 09:11:58.703071 37.32 0.83
+2013-03-01 09:11:58.703071 68.62 0.83
+2013-03-01 09:11:58.703071 80.43 0.83
+2013-03-01 09:11:58.703071 54.09 0.83
+2013-03-01 09:11:58.703071 42.08 0.83
+2013-03-01 09:11:58.703071 64.55 0.83
+2013-03-01 09:11:58.703071 48.89 0.83
+2013-03-01 09:11:58.703071 56.45 0.83
+2013-03-01 09:11:58.703071 1.99 0.83
+2013-03-01 09:11:58.703071 94.27 0.83
+2013-03-01 09:11:58.703071 35.32 0.83
+2013-03-01 09:11:58.703071 10.62 0.83
+2013-03-01 09:11:58.703071 52.09 0.83
+2013-03-01 09:11:58.703071 63.03 0.83
+2013-03-01 09:11:58.703071 76.13 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 17.58 0.83
+2013-03-01 09:11:58.703071 11.32 0.83
+2013-03-01 09:11:58.703071 38.5 0.83
+2013-03-01 09:11:58.703071 82.85 0.83
+2013-03-01 09:11:58.703071 49.64 0.83
+2013-03-01 09:11:58.703071 27.23 0.83
+2013-03-01 09:11:58.703071 83.98 0.83
+2013-03-01 09:11:58.703071 31.84 0.83
+2013-03-01 09:11:58.703071 50.28 0.83
+2013-03-01 09:11:58.703071 3.73 0.83
+2013-03-01 09:11:58.703071 53.26 0.83
+2013-03-01 09:11:58.703071 29.71 0.83
+2013-03-01 09:11:58.703071 8.86 0.83
+2013-03-01 09:11:58.703071 21.01 0.83
+2013-03-01 09:11:58.703071 84.21 0.83
+2013-03-01 09:11:58.703071 19.1 0.83
+2013-03-01 09:11:58.703071 31.94 0.83
+2013-03-01 09:11:58.703071 88.93 0.83
+2013-03-01 09:11:58.703071 12.83 0.83
+2013-03-01 09:11:58.703071 29.07 0.83
+2013-03-01 09:11:58.703071 61.88 0.83
+2013-03-01 09:11:58.703071 61.41 0.83
+2013-03-01 09:11:58.703071 46.84 0.83
+2013-03-01 09:11:58.703072 95.01 NULL
+2013-03-01 09:11:58.703072 62.09 95.01
+2013-03-01 09:11:58.703072 29.01 62.09
+2013-03-01 09:11:58.703072 79.46 29.01
+2013-03-01 09:11:58.703072 4.48 29.01
+2013-03-01 09:11:58.703072 99.26 4.48
+2013-03-01 09:11:58.703072 58.77 4.48
+2013-03-01 09:11:58.703072 86.98 4.48
+2013-03-01 09:11:58.703072 30.47 4.48
+2013-03-01 09:11:58.703072 68.2 4.48
+2013-03-01 09:11:58.703072 52.44 4.48
+2013-03-01 09:11:58.703072 0.79 4.48
+2013-03-01 09:11:58.703072 25.34 0.79
+2013-03-01 09:11:58.703072 81.29 0.79
+2013-03-01 09:11:58.703072 71.68 0.79
+2013-03-01 09:11:58.703072 1.27 0.79
+2013-03-01 09:11:58.703072 56.7 0.79
+2013-03-01 09:11:58.703072 39.3 0.79
+2013-03-01 09:11:58.703072 25.91 0.79
+2013-03-01 09:11:58.703072 88.08 0.79
+2013-03-01 09:11:58.703072 0.48 0.79
+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: select ts, f, min(f) over (partition by ts order by t 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, min(f) over (partition by ts order by t 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 14.54 29.22
+2013-03-01 09:11:58.70307 29.22 17.85
+2013-03-01 09:11:58.70307 39.48 17.85
+2013-03-01 09:11:58.70307 17.85 31.17
+2013-03-01 09:11:58.70307 31.17 56.94
+2013-03-01 09:11:58.70307 56.94 38.61
+2013-03-01 09:11:58.70307 78.58 14.78
+2013-03-01 09:11:58.70307 38.61 14.78
+2013-03-01 09:11:58.70307 14.78 28.69
+2013-03-01 09:11:58.70307 91.36 28.69
+2013-03-01 09:11:58.70307 28.69 73.52
+2013-03-01 09:11:58.70307 73.52 92.96
+2013-03-01 09:11:58.70307 92.96 41.6
+2013-03-01 09:11:58.70307 95.04 41.6
+2013-03-01 09:11:58.70307 41.6 64.96
+2013-03-01 09:11:58.70307 64.96 81.41
+2013-03-01 09:11:58.70307 84.71 10.89
+2013-03-01 09:11:58.70307 81.41 10.89
+2013-03-01 09:11:58.70307 10.89 20.61
+2013-03-01 09:11:58.70307 20.61 54.36
+2013-03-01 09:11:58.70307 54.36 46.08
+2013-03-01 09:11:58.70307 87.43 40.54
+2013-03-01 09:11:58.70307 46.08 38.35
+2013-03-01 09:11:58.70307 40.54 3.17
+2013-03-01 09:11:58.70307 38.35 3.17
+2013-03-01 09:11:58.70307 3.17 NULL
+2013-03-01 09:11:58.703071 0.83 56.76
+2013-03-01 09:11:58.703071 56.76 79.05
+2013-03-01 09:11:58.703071 99.45 14.96
+2013-03-01 09:11:58.703071 79.05 14.96
+2013-03-01 09:11:58.703071 14.96 14.7
+2013-03-01 09:11:58.703071 85.55 14.7
+2013-03-01 09:11:58.703071 14.7 81.41
+2013-03-01 09:11:58.703071 81.41 26.95
+2013-03-01 09:11:58.703071 87.93 26.95
+2013-03-01 09:11:58.703071 26.95 37.32
+2013-03-01 09:11:58.703071 37.32 68.62
+2013-03-01 09:11:58.703071 68.62 54.09
+2013-03-01 09:11:58.703071 80.43 42.08
+2013-03-01 09:11:58.703071 54.09 42.08
+2013-03-01 09:11:58.703071 42.08 48.89
+2013-03-01 09:11:58.703071 64.55 48.89
+2013-03-01 09:11:58.703071 48.89 1.99
+2013-03-01 09:11:58.703071 56.45 1.99
+2013-03-01 09:11:58.703071 1.99 35.32
+2013-03-01 09:11:58.703071 94.27 10.62
+2013-03-01 09:11:58.703071 35.32 10.62
+2013-03-01 09:11:58.703071 10.62 52.09
+2013-03-01 09:11:58.703071 52.09 63.03
+2013-03-01 09:11:58.703071 63.03 44.3
+2013-03-01 09:11:58.703071 76.13 44.3
+2013-03-01 09:11:58.703071 44.3 17.58
+2013-03-01 09:11:58.703071 44.66 11.32
+2013-03-01 09:11:58.703071 17.58 11.32
+2013-03-01 09:11:58.703071 11.32 38.5
+2013-03-01 09:11:58.703071 38.5 49.64
+2013-03-01 09:11:58.703071 82.85 27.23
+2013-03-01 09:11:58.703071 49.64 27.23
+2013-03-01 09:11:58.703071 27.23 31.84
+2013-03-01 09:11:58.703071 83.98 31.84
+2013-03-01 09:11:58.703071 31.84 3.73
+2013-03-01 09:11:58.703071 50.28 3.73
+2013-03-01 09:11:58.703071 3.73 29.71
+2013-03-01 09:11:58.703071 53.26 8.86
+2013-03-01 09:11:58.703071 29.71 8.86
+2013-03-01 09:11:58.703071 8.86 21.01
+2013-03-01 09:11:58.703071 21.01 19.1
+2013-03-01 09:11:58.703071 84.21 19.1
+2013-03-01 09:11:58.703071 19.1 31.94
+2013-03-01 09:11:58.703071 31.94 12.83
+2013-03-01 09:11:58.703071 88.93 12.83
+2013-03-01 09:11:58.703071 12.83 29.07
+2013-03-01 09:11:58.703071 29.07 61.41
+2013-03-01 09:11:58.703071 61.88 46.84
+2013-03-01 09:11:58.703071 61.41 46.84
+2013-03-01 09:11:58.703071 46.84 NULL
+2013-03-01 09:11:58.703072 95.01 29.01
+2013-03-01 09:11:58.703072 62.09 29.01
+2013-03-01 09:11:58.703072 29.01 4.48
+2013-03-01 09:11:58.703072 79.46 4.48
+2013-03-01 09:11:58.703072 4.48 58.77
+2013-03-01 09:11:58.703072 99.26 58.77
+2013-03-01 09:11:58.703072 58.77 30.47
+2013-03-01 09:11:58.703072 86.98 30.47
+2013-03-01 09:11:58.703072 30.47 52.44
+2013-03-01 09:11:58.703072 68.2 0.79
+2013-03-01 09:11:58.703072 52.44 0.79
+2013-03-01 09:11:58.703072 0.79 25.34
+2013-03-01 09:11:58.703072 25.34 71.68
+2013-03-01 09:11:58.703072 81.29 1.27
+2013-03-01 09:11:58.703072 71.68 1.27
+2013-03-01 09:11:58.703072 1.27 39.3
+2013-03-01 09:11:58.703072 56.7 25.91
+2013-03-01 09:11:58.703072 39.3 25.91
+2013-03-01 09:11:58.703072 25.91 0.48
+2013-03-01 09:11:58.703072 88.08 0.48
+2013-03-01 09:11:58.703072 0.48 9.0
+2013-03-01 09:11:58.703072 88.83 9.0
+2013-03-01 09:11:58.703072 9.0 45.91
+2013-03-01 09:11:58.703072 54.1 0.36
+PREHOOK: query: select ts, f, min(f) over (partition by ts order by t 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, min(f) over (partition by ts order by t 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 14.54 14.54
+2013-03-01 09:11:58.70307 29.22 14.54
+2013-03-01 09:11:58.70307 39.48 14.54
+2013-03-01 09:11:58.70307 17.85 14.54
+2013-03-01 09:11:58.70307 31.17 14.54
+2013-03-01 09:11:58.70307 56.94 14.54
+2013-03-01 09:11:58.70307 78.58 14.54
+2013-03-01 09:11:58.70307 38.61 14.54
+2013-03-01 09:11:58.70307 14.78 14.54
+2013-03-01 09:11:58.70307 91.36 14.54
+2013-03-01 09:11:58.70307 28.69 14.54
+2013-03-01 09:11:58.70307 73.52 14.54
+2013-03-01 09:11:58.70307 92.96 14.54
+2013-03-01 09:11:58.70307 95.04 14.54
+2013-03-01 09:11:58.70307 41.6 14.54
+2013-03-01 09:11:58.70307 64.96 14.54
+2013-03-01 09:11:58.70307 84.71 14.54
+2013-03-01 09:11:58.70307 81.41 10.89
+2013-03-01 09:11:58.70307 10.89 10.89
+2013-03-01 09:11:58.70307 20.61 10.89
+2013-03-01 09:11:58.70307 54.36 10.89
+2013-03-01 09:11:58.70307 87.43 10.89
+2013-03-01 09:11:58.70307 46.08 10.89
+2013-03-01 09:11:58.70307 40.54 10.89
+2013-03-01 09:11:58.70307 38.35 3.17
+2013-03-01 09:11:58.70307 3.17 3.17
+2013-03-01 09:11:58.703071 0.83 0.83
+2013-03-01 09:11:58.703071 56.76 0.83
+2013-03-01 09:11:58.703071 99.45 0.83
+2013-03-01 09:11:58.703071 79.05 0.83
+2013-03-01 09:11:58.703071 14.96 0.83
+2013-03-01 09:11:58.703071 85.55 0.83
+2013-03-01 09:11:58.703071 14.7 0.83
+2013-03-01 09:11:58.703071 81.41 0.83
+2013-03-01 09:11:58.703071 87.93 0.83
+2013-03-01 09:11:58.703071 26.95 0.83
+2013-03-01 09:11:58.703071 37.32 0.83
+2013-03-01 09:11:58.703071 68.62 0.83
+2013-03-01 09:11:58.703071 80.43 0.83
+2013-03-01 09:11:58.703071 54.09 0.83
+2013-03-01 09:11:58.703071 42.08 0.83
+2013-03-01 09:11:58.703071 64.55 0.83
+2013-03-01 09:11:58.703071 48.89 0.83
+2013-03-01 09:11:58.703071 56.45 0.83
+2013-03-01 09:11:58.703071 1.99 0.83
+2013-03-01 09:11:58.703071 94.27 0.83
+2013-03-01 09:11:58.703071 35.32 0.83
+2013-03-01 09:11:58.703071 10.62 0.83
+2013-03-01 09:11:58.703071 52.09 0.83
+2013-03-01 09:11:58.703071 63.03 0.83
+2013-03-01 09:11:58.703071 76.13 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 17.58 0.83
+2013-03-01 09:11:58.703071 11.32 0.83
+2013-03-01 09:11:58.703071 38.5 0.83
+2013-03-01 09:11:58.703071 82.85 0.83
+2013-03-01 09:11:58.703071 49.64 0.83
+2013-03-01 09:11:58.703071 27.23 0.83
+2013-03-01 09:11:58.703071 83.98 0.83
+2013-03-01 09:11:58.703071 31.84 0.83
+2013-03-01 09:11:58.703071 50.28 0.83
+2013-03-01 09:11:58.703071 3.73 0.83
+2013-03-01 09:11:58.703071 53.26 0.83
+2013-03-01 09:11:58.703071 29.71 0.83
+2013-03-01 09:11:58.703071 8.86 0.83
+2013-03-01 09:11:58.703071 21.01 0.83
+2013-03-01 09:11:58.703071 84.21 0.83
+2013-03-01 09:11:58.703071 19.1 0.83
+2013-03-01 09:11:58.703071 31.94 0.83
+2013-03-01 09:11:58.703071 88.93 0.83
+2013-03-01 09:11:58.703071 12.83 0.83
+2013-03-01 09:11:58.703071 29.07 0.83
+2013-03-01 09:11:58.703071 61.88 0.83
+2013-03-01 09:11:58.703071 61.41 0.83
+2013-03-01 09:11:58.703071 46.84 0.83
+2013-03-01 09:11:58.703072 95.01 62.09
+2013-03-01 09:11:58.703072 62.09 29.01
+2013-03-01 09:11:58.703072 29.01 29.01
+2013-03-01 09:11:58.703072 79.46 4.48
+2013-03-01 09:11:58.703072 4.48 4.48
+2013-03-01 09:11:58.703072 99.26 4.48
+2013-03-01 09:11:58.703072 58.77 4.48
+2013-03-01 09:11:58.703072 86.98 4.48
+2013-03-01 09:11:58.703072 30.47 4.48
+2013-03-01 09:11:58.703072 68.2 4.48
+2013-03-01 09:11:58.703072 52.44 0.79
+2013-03-01 09:11:58.703072 0.79 0.79
+2013-03-01 09:11:58.703072 25.34 0.79
+2013-03-01 09:11:58.703072 81.29 0.79
+2013-03-01 09:11:58.703072 71.68 0.79
+2013-03-01 09:11:58.703072 1.27 0.79
+2013-03-01 09:11:58.703072 56.7 0.79
+2013-03-01 09:11:58.703072 39.3 0.79
+2013-03-01 09:11:58.703072 25.91 0.79
+2013-03-01 09:11:58.703072 88.08 0.48
+2013-03-01 09:11:58.703072 0.48 0.48
+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