http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.89.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.89.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.89.query.sqlpp new file mode 100644 index 0000000..07c6357 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.89.query.sqlpp @@ -0,0 +1,29 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +FROM ( FROM tenk1 WHERE unique1 < 10 SELECT VALUE tenk1 ORDER BY four, unique2 DESC LIMIT 10 ) s +SELECT unique1, four, + first_value(unique1) over (ORDER BY four rows between current row and 2 following exclude current row) AS `first_value` +ORDER BY four, unique2 DESC
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.9.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.9.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.9.query.sqlpp new file mode 100644 index 0000000..4ed0560 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.9.query.sqlpp @@ -0,0 +1,29 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +FROM tenk1 +WHERE unique2 < 10 +SELECT dense_rank() OVER (PARTITION BY four ORDER BY ten) AS `dense_rank`, ten, four +ORDER BY four, ten http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.90.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.90.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.90.query.sqlpp new file mode 100644 index 0000000..3751d87 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.90.query.sqlpp @@ -0,0 +1,29 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +FROM ( FROM tenk1 WHERE unique1 < 10 SELECT VALUE tenk1 ORDER BY four, unique2 DESC LIMIT 10 ) s +SELECT unique1, four, + first_value(unique1) over (ORDER BY four rows between current row and 2 following exclude group) AS `first_value` +ORDER BY four, unique2 DESC http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.91.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.91.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.91.query.sqlpp new file mode 100644 index 0000000..c7e3266 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.91.query.sqlpp @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +FROM ( FROM tenk1 WHERE unique1 < 10 SELECT VALUE tenk1 ORDER BY four, unique2 DESC LIMIT 10 ) s +SELECT unique1, four, + first_value(unique1) over (ORDER BY four rows between current row and 2 following exclude ties) AS `first_value` +ORDER BY four, unique2 DESC + http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.92.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.92.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.92.query.sqlpp new file mode 100644 index 0000000..3073cc9 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.92.query.sqlpp @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +FROM ( FROM tenk1 WHERE unique1 < 10 SELECT VALUE tenk1 ORDER BY four, unique2 DESC LIMIT 10 ) s +SELECT unique1, four, + last_value(unique1) over (ORDER BY four rows between current row and 2 following exclude current row) AS `last_value` +ORDER BY four, unique2 DESC + + http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.93.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.93.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.93.query.sqlpp new file mode 100644 index 0000000..88f239b --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.93.query.sqlpp @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +FROM ( FROM tenk1 WHERE unique1 < 10 SELECT VALUE tenk1 ORDER BY four, unique2 DESC LIMIT 10 ) s +SELECT unique1, four, + last_value(unique1) over (ORDER BY four rows between current row and 2 following exclude group) AS `last_value` +ORDER BY four, unique2 DESC + + http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.94.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.94.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.94.query.sqlpp new file mode 100644 index 0000000..967de6d --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.94.query.sqlpp @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +FROM ( FROM tenk1 WHERE unique1 < 10 SELECT VALUE tenk1 ORDER BY four, unique2 DESC LIMIT 10 ) s +SELECT unique1, four, + last_value(unique1) over (ORDER BY four rows between current row and 2 following exclude ties) AS `last_value` +ORDER BY four, unique2 DESC + + http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.95.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.95.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.95.query.sqlpp new file mode 100644 index 0000000..6c99283 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.95.query.sqlpp @@ -0,0 +1,32 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +FROM ( FROM tenk1 WHERE unique1 < 10 SELECT VALUE tenk1 ORDER BY four, unique2 DESC LIMIT 10 ) s +SELECT unique1, four, + first_value(unique1) over w AS (order by four range between current row and unbounded following) AS `first_value`, + nth_value(unique1, 2) over w AS (order by four range between current row and unbounded following) AS nth_2, + last_value(unique1) over w AS (order by four range between current row and unbounded following) AS `last_value` +ORDER BY four, unique2 DESC + http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.96.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.96.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.96.query.sqlpp new file mode 100644 index 0000000..45ce34e --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.96.query.sqlpp @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +from empsalary +select salary, + first_value(salary) over(order by salary range between 1000 preceding and 1000 following) AS `first_value`, + lead(salary) over(order by salary) AS `lead`, + nth_value(salary, 1) over(order by salary range between 1000 preceding and 1000 following) AS `nth_value` +order by salary http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.97.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.97.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.97.query.sqlpp new file mode 100644 index 0000000..81108eb --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.97.query.sqlpp @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +from empsalary +select salary, + last_value(salary) over(order by salary range between 1000 preceding and 1000 following) as `last_value`, + lag(salary) over(order by salary) as `lag` +order by salary http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.98.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.98.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.98.query.sqlpp new file mode 100644 index 0000000..a76883e --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.98.query.sqlpp @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +from empsalary +select salary, + first_value(salary) over(order by salary range between 1000 following and 3000 following exclude current row) as `first_value`, + lead(salary) over(order by salary) as `lead`, + nth_value(salary, 1) over(order by salary range between 1000 following and 3000 following exclude ties) as `nth_value` +order by salary \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.99.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.99.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.99.query.sqlpp new file mode 100644 index 0000000..95f828e --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/window/pg_win/pg_win.99.query.sqlpp @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Description : Core window functions tests + * Expected Res : SUCCESS + */ + +use test; + +from empsalary +select salary, + last_value(salary) over(order by salary range between 1000 following and 3000 following exclude group) as `last_value`, + lag(salary) over(order by salary) as `lag` +order by salary http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/count_dataset/count_dataset.1.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/count_dataset/count_dataset.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/count_dataset/count_dataset.1.adm index a653416..486b421 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/count_dataset/count_dataset.1.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate-sql/count_dataset/count_dataset.1.adm @@ -1,24 +1,24 @@ -distribute result [$$23] +distribute result [$$24] -- DISTRIBUTE_RESULT |UNPARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |UNPARTITIONED| - aggregate [$$23] <- [agg-sql-sum($$26)] + aggregate [$$24] <- [agg-sql-sum($$27)] -- AGGREGATE |UNPARTITIONED| - aggregate [$$26] <- [agg-sql-count(1)] + aggregate [$$27] <- [agg-sql-count(1)] -- AGGREGATE |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$24(ASC) ] |PARTITIONED| - project ([$$24]) + -- SORT_MERGE_EXCHANGE [$$25(ASC) ] |PARTITIONED| + project ([$$25]) -- STREAM_PROJECT |PARTITIONED| - select (and(ge($$22, 1), le($$22, 10))) + select (and(ge($$23, 1), le($$23, 10))) -- STREAM_SELECT |PARTITIONED| - project ([$$24, $$22]) + project ([$$25, $$23]) -- STREAM_PROJECT |PARTITIONED| - assign [$$22] <- [$$Tweet.getField(1)] + assign [$$23] <- [$$Tweet.getField(1)] -- ASSIGN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$24, $$Tweet] <- Twitter.Tweet + data-scan []<-[$$25, $$Tweet] <- Twitter.Tweet -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate/count_dataset/count_dataset.1.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate/count_dataset/count_dataset.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate/count_dataset/count_dataset.1.adm index b74e65f..42728fe 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate/count_dataset/count_dataset.1.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/aggregate/count_dataset/count_dataset.1.adm @@ -1,24 +1,24 @@ -distribute result [$$23] +distribute result [$$24] -- DISTRIBUTE_RESULT |UNPARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |UNPARTITIONED| - aggregate [$$23] <- [agg-sum($$26)] + aggregate [$$24] <- [agg-sum($$27)] -- AGGREGATE |UNPARTITIONED| - aggregate [$$26] <- [agg-count(1)] + aggregate [$$27] <- [agg-count(1)] -- AGGREGATE |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$24(ASC) ] |PARTITIONED| - project ([$$24]) + -- SORT_MERGE_EXCHANGE [$$25(ASC) ] |PARTITIONED| + project ([$$25]) -- STREAM_PROJECT |PARTITIONED| - select (and(ge($$22, 1), le($$22, 10))) + select (and(ge($$23, 1), le($$23, 10))) -- STREAM_SELECT |PARTITIONED| - project ([$$24, $$22]) + project ([$$25, $$23]) -- STREAM_PROJECT |PARTITIONED| - assign [$$22] <- [$$Tweet.getField(1)] + assign [$$23] <- [$$Tweet.getField(1)] -- ASSIGN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$24, $$Tweet] <- Twitter.Tweet + data-scan []<-[$$25, $$Tweet] <- Twitter.Tweet -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access/explain_field_access.1.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access/explain_field_access.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access/explain_field_access.1.adm index 4e079d0..f7790a0 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access/explain_field_access.1.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access/explain_field_access.1.adm @@ -1,46 +1,42 @@ -distribute result [$$40] +distribute result [$$44] -- DISTRIBUTE_RESULT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$40]) + project ([$$44]) -- STREAM_PROJECT |PARTITIONED| - assign [$$40] <- [{"deptId": $#1, "star_cost": $$43}] + assign [$$44] <- [{"deptId": $#1, "star_cost": $$47}] -- ASSIGN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - group by ([$#1 := $$48]) decor ([]) { - aggregate [$$43] <- [agg-global-sql-sum($$47)] + group by ([$#1 := $$52]) decor ([]) { + aggregate [$$47] <- [agg-global-sql-sum($$51)] -- AGGREGATE |LOCAL| nested tuple source -- NESTED_TUPLE_SOURCE |LOCAL| } - -- SORT_GROUP_BY[$$48] |PARTITIONED| + -- SORT_GROUP_BY[$$52] |PARTITIONED| exchange - -- HASH_PARTITION_EXCHANGE [$$48] |PARTITIONED| - group by ([$$48 := $$41]) decor ([]) { - aggregate [$$47] <- [agg-local-sql-sum($$38)] + -- HASH_PARTITION_EXCHANGE [$$52] |PARTITIONED| + group by ([$$52 := $$45]) decor ([]) { + aggregate [$$51] <- [agg-local-sql-sum($$42)] -- AGGREGATE |LOCAL| nested tuple source -- NESTED_TUPLE_SOURCE |LOCAL| } - -- SORT_GROUP_BY[$$41] |PARTITIONED| + -- SORT_GROUP_BY[$$45] |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$38, $$41]) + project ([$$42, $$45]) -- STREAM_PROJECT |PARTITIONED| - assign [$$41] <- [substring($$45.getField("department_id"), 0)] + assign [$$45, $$42] <- [substring($$e.getField("dept").getField("department_id"), 0), $$e.getField("salary")] -- ASSIGN |PARTITIONED| - project ([$$38, $$45]) + project ([$$e]) -- STREAM_PROJECT |PARTITIONED| - assign [$$38, $$45] <- [$$e.getField("salary"), $$e.getField("dept")] - -- ASSIGN |PARTITIONED| - project ([$$e]) - -- STREAM_PROJECT |PARTITIONED| + exchange + -- ONE_TO_ONE_EXCHANGE |PARTITIONED| + data-scan []<-[$$46, $$e] <- gby.Employee + -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$42, $$e] <- gby.Employee - -- DATASOURCE_SCAN |PARTITIONED| - exchange - -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - empty-tuple-source - -- EMPTY_TUPLE_SOURCE |PARTITIONED| + empty-tuple-source + -- EMPTY_TUPLE_SOURCE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access_closed/explain_field_access_closed.1.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access_closed/explain_field_access_closed.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access_closed/explain_field_access_closed.1.adm index 2477020..7bfd96b 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access_closed/explain_field_access_closed.1.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/explain/explain_field_access_closed/explain_field_access_closed.1.adm @@ -1,40 +1,40 @@ -distribute result [$$39] +distribute result [$$43] -- DISTRIBUTE_RESULT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$39]) + project ([$$43]) -- STREAM_PROJECT |PARTITIONED| - assign [$$39] <- [{"deptId": $#1, "star_cost": $$42}] + assign [$$43] <- [{"deptId": $#1, "star_cost": $$46}] -- ASSIGN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - group by ([$#1 := $$46]) decor ([]) { - aggregate [$$42] <- [agg-global-sql-sum($$45)] + group by ([$#1 := $$50]) decor ([]) { + aggregate [$$46] <- [agg-global-sql-sum($$49)] -- AGGREGATE |LOCAL| nested tuple source -- NESTED_TUPLE_SOURCE |LOCAL| } - -- SORT_GROUP_BY[$$46] |PARTITIONED| + -- SORT_GROUP_BY[$$50] |PARTITIONED| exchange - -- HASH_PARTITION_EXCHANGE [$$46] |PARTITIONED| - group by ([$$46 := $$40]) decor ([]) { - aggregate [$$45] <- [agg-local-sql-sum($$37)] + -- HASH_PARTITION_EXCHANGE [$$50] |PARTITIONED| + group by ([$$50 := $$44]) decor ([]) { + aggregate [$$49] <- [agg-local-sql-sum($$41)] -- AGGREGATE |LOCAL| nested tuple source -- NESTED_TUPLE_SOURCE |LOCAL| } - -- SORT_GROUP_BY[$$40] |PARTITIONED| + -- SORT_GROUP_BY[$$44] |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$37, $$40]) + project ([$$41, $$44]) -- STREAM_PROJECT |PARTITIONED| - assign [$$40, $$37] <- [substring($$e.getField(1), 0), $$e.getField(2)] + assign [$$44, $$41] <- [substring($$e.getField(1), 0), $$e.getField(2)] -- ASSIGN |PARTITIONED| project ([$$e]) -- STREAM_PROJECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$41, $$e] <- gby.Employee + data-scan []<-[$$45, $$e] <- gby.Employee -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.3.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.3.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.3.adm index 9c4866f..7a8668b 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.3.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.3.adm @@ -7,28 +7,28 @@ distribute result [$$c] project ([$$c]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$15(ASC), $$16(ASC) ] |PARTITIONED| + -- SORT_MERGE_EXCHANGE [$$16(ASC), $$17(ASC) ] |PARTITIONED| limit 10 -- STREAM_LIMIT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$15, $$16, $$c] <- index-search("LineItem", 0, "test", "LineItem", FALSE, FALSE, 2, $$21, $$22, 2, $$21, $$22, TRUE, TRUE, TRUE) condition (and(lt($$c.getField(2), 150), lt($$c.getField(5), 10000))) limit 10 + unnest-map [$$16, $$17, $$c] <- index-search("LineItem", 0, "test", "LineItem", FALSE, FALSE, 2, $$22, $$23, 2, $$22, $$23, TRUE, TRUE, TRUE) condition (and(lt($$c.getField(2), 150), lt($$c.getField(5), 10000))) limit 10 -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - order (ASC, $$21) (ASC, $$22) - -- STABLE_SORT [$$21(ASC), $$22(ASC)] |PARTITIONED| + order (ASC, $$22) (ASC, $$23) + -- STABLE_SORT [$$22(ASC), $$23(ASC)] |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$21, $$22]) + project ([$$22, $$23]) -- STREAM_PROJECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$20, $$21, $$22] <- index-search("idx_LineItem_suppkey", 0, "test", "LineItem", FALSE, FALSE, 0, 1, $$19, TRUE, FALSE, FALSE) + unnest-map [$$21, $$22, $$23] <- index-search("idx_LineItem_suppkey", 0, "test", "LineItem", FALSE, FALSE, 0, 1, $$20, TRUE, FALSE, FALSE) -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - assign [$$19] <- [150] + assign [$$20] <- [150] -- ASSIGN |PARTITIONED| empty-tuple-source -- EMPTY_TUPLE_SOURCE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.5.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.5.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.5.adm index 7d9ef47..45e0602 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.5.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup-select/push-limit-to-primary-lookup-select.5.adm @@ -1,40 +1,40 @@ -distribute result [$$17] +distribute result [$$18] -- DISTRIBUTE_RESULT |UNPARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |UNPARTITIONED| limit 5 -- STREAM_LIMIT |UNPARTITIONED| - project ([$$17]) + project ([$$18]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$19(ASC), $$20(ASC) ] |PARTITIONED| - project ([$$19, $$20, $$17]) + -- SORT_MERGE_EXCHANGE [$$20(ASC), $$21(ASC) ] |PARTITIONED| + project ([$$20, $$21, $$18]) -- STREAM_PROJECT |PARTITIONED| - assign [$$17] <- [{"shipdate": substring($$c.getField(10), 0, 4), "suppkey": gt($$18, 0)}] + assign [$$18] <- [{"shipdate": substring($$c.getField(10), 0, 4), "suppkey": gt($$19, 0)}] -- ASSIGN |PARTITIONED| limit 5 -- STREAM_LIMIT |PARTITIONED| - assign [$$18] <- [$$c.getField(2)] + assign [$$19] <- [$$c.getField(2)] -- ASSIGN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$19, $$20, $$c] <- index-search("LineItem", 0, "test", "LineItem", FALSE, FALSE, 2, $$24, $$25, 2, $$24, $$25, TRUE, TRUE, TRUE) condition (lt($$c.getField(2), 150)) limit 5 + unnest-map [$$20, $$21, $$c] <- index-search("LineItem", 0, "test", "LineItem", FALSE, FALSE, 2, $$25, $$26, 2, $$25, $$26, TRUE, TRUE, TRUE) condition (lt($$c.getField(2), 150)) limit 5 -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - order (ASC, $$24) (ASC, $$25) - -- STABLE_SORT [$$24(ASC), $$25(ASC)] |PARTITIONED| + order (ASC, $$25) (ASC, $$26) + -- STABLE_SORT [$$25(ASC), $$26(ASC)] |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$24, $$25]) + project ([$$25, $$26]) -- STREAM_PROJECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$23, $$24, $$25] <- index-search("idx_LineItem_suppkey", 0, "test", "LineItem", FALSE, FALSE, 0, 1, $$22, TRUE, FALSE, FALSE) + unnest-map [$$24, $$25, $$26] <- index-search("idx_LineItem_suppkey", 0, "test", "LineItem", FALSE, FALSE, 0, 1, $$23, TRUE, FALSE, FALSE) -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - assign [$$22] <- [150] + assign [$$23] <- [150] -- ASSIGN |PARTITIONED| empty-tuple-source -- EMPTY_TUPLE_SOURCE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.3.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.3.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.3.adm index 29357ae..e741aec 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.3.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.3.adm @@ -7,28 +7,28 @@ distribute result [$$c] project ([$$c]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$12(ASC), $$13(ASC) ] |PARTITIONED| + -- SORT_MERGE_EXCHANGE [$$13(ASC), $$14(ASC) ] |PARTITIONED| limit 10 -- STREAM_LIMIT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$12, $$13, $$c] <- index-search("LineItem", 0, "test", "LineItem", FALSE, FALSE, 2, $$17, $$18, 2, $$17, $$18, TRUE, TRUE, TRUE) condition (lt($$c.getField(2), 150)) limit 10 + unnest-map [$$13, $$14, $$c] <- index-search("LineItem", 0, "test", "LineItem", FALSE, FALSE, 2, $$18, $$19, 2, $$18, $$19, TRUE, TRUE, TRUE) condition (lt($$c.getField(2), 150)) limit 10 -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - order (ASC, $$17) (ASC, $$18) - -- STABLE_SORT [$$17(ASC), $$18(ASC)] |PARTITIONED| + order (ASC, $$18) (ASC, $$19) + -- STABLE_SORT [$$18(ASC), $$19(ASC)] |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$17, $$18]) + project ([$$18, $$19]) -- STREAM_PROJECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$16, $$17, $$18] <- index-search("idx_LineItem_suppkey", 0, "test", "LineItem", FALSE, FALSE, 0, 1, $$15, TRUE, FALSE, FALSE) + unnest-map [$$17, $$18, $$19] <- index-search("idx_LineItem_suppkey", 0, "test", "LineItem", FALSE, FALSE, 0, 1, $$16, TRUE, FALSE, FALSE) -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - assign [$$15] <- [150] + assign [$$16] <- [150] -- ASSIGN |PARTITIONED| empty-tuple-source -- EMPTY_TUPLE_SOURCE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.5.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.5.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.5.adm index d070b2b..b64b9c5 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.5.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-lookup/push-limit-to-primary-lookup.5.adm @@ -7,28 +7,28 @@ distribute result [$$c] project ([$$c]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$14(ASC), $$15(ASC) ] |PARTITIONED| + -- SORT_MERGE_EXCHANGE [$$15(ASC), $$16(ASC) ] |PARTITIONED| limit 10 -- STREAM_LIMIT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$14, $$15, $$c] <- index-search("LineItem", 0, "test", "LineItem", FALSE, FALSE, 2, $$19, $$20, 2, $$19, $$20, TRUE, TRUE, TRUE) condition (lt($$c.getField(2), 150)) limit 10 + unnest-map [$$15, $$16, $$c] <- index-search("LineItem", 0, "test", "LineItem", FALSE, FALSE, 2, $$20, $$21, 2, $$20, $$21, TRUE, TRUE, TRUE) condition (lt($$c.getField(2), 150)) limit 10 -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - order (ASC, $$19) (ASC, $$20) - -- STABLE_SORT [$$19(ASC), $$20(ASC)] |PARTITIONED| + order (ASC, $$20) (ASC, $$21) + -- STABLE_SORT [$$20(ASC), $$21(ASC)] |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$19, $$20]) + project ([$$20, $$21]) -- STREAM_PROJECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$18, $$19, $$20] <- index-search("idx_LineItem_suppkey", 0, "test", "LineItem", FALSE, FALSE, 0, 1, $$17, TRUE, FALSE, FALSE) + unnest-map [$$19, $$20, $$21] <- index-search("idx_LineItem_suppkey", 0, "test", "LineItem", FALSE, FALSE, 0, 1, $$18, TRUE, FALSE, FALSE) -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - assign [$$17] <- [150] + assign [$$18] <- [150] -- ASSIGN |PARTITIONED| empty-tuple-source -- EMPTY_TUPLE_SOURCE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.3.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.3.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.3.adm index b60a0ee..82e42e8 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.3.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.3.adm @@ -7,12 +7,12 @@ distribute result [$$paper] project ([$$paper]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$12(ASC) ] |PARTITIONED| + -- SORT_MERGE_EXCHANGE [$$13(ASC) ] |PARTITIONED| limit 10 -- STREAM_LIMIT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$12, $$paper] <- test.DBLP1 condition (contains($$paper.getField(1), "kimL89")) limit 10 + data-scan []<-[$$13, $$paper] <- test.DBLP1 condition (contains($$paper.getField(1), "kimL89")) limit 10 -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.5.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.5.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.5.adm index b83be67..9fd4ea8 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.5.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.5.adm @@ -1,4 +1,4 @@ -distribute result [$$31] +distribute result [$$33] -- DISTRIBUTE_RESULT |UNPARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |UNPARTITIONED| @@ -6,57 +6,57 @@ distribute result [$$31] -- STREAM_LIMIT |UNPARTITIONED| exchange -- RANDOM_MERGE_EXCHANGE |PARTITIONED| - project ([$$31]) + project ([$$33]) -- STREAM_PROJECT |PARTITIONED| - assign [$$31] <- [{"dblpid": $$32}] + assign [$$33] <- [{"dblpid": $$34}] -- ASSIGN |PARTITIONED| limit 2 -- STREAM_LIMIT |PARTITIONED| - project ([$$32]) + project ([$$34]) -- STREAM_PROJECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - join (eq($$32, $$35)) - -- HYBRID_HASH_JOIN [$$32][$$35] |PARTITIONED| + join (eq($$34, $$37)) + -- HYBRID_HASH_JOIN [$$34][$$37] |PARTITIONED| exchange - -- HASH_PARTITION_EXCHANGE [$$32] |PARTITIONED| - project ([$$32]) + -- HASH_PARTITION_EXCHANGE [$$34] |PARTITIONED| + project ([$$34]) -- STREAM_PROJECT |PARTITIONED| - assign [$$32] <- [$$d.getField(1)] + assign [$$34] <- [$$d.getField(1)] -- ASSIGN |PARTITIONED| project ([$$d]) -- STREAM_PROJECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$33, $$d] <- test.DBLP1 + data-scan []<-[$$35, $$d] <- test.DBLP1 -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| empty-tuple-source -- EMPTY_TUPLE_SOURCE |PARTITIONED| exchange - -- HASH_PARTITION_EXCHANGE [$$35] |PARTITIONED| - project ([$$35]) + -- HASH_PARTITION_EXCHANGE [$$37] |PARTITIONED| + project ([$$37]) -- STREAM_PROJECT |UNPARTITIONED| - assign [$$35] <- [get-item($$24, 0).getField(0).getField(1)] + assign [$$37] <- [get-item($$26, 0).getField(0).getField(1)] -- ASSIGN |UNPARTITIONED| - aggregate [$$24] <- [listify($$23)] + aggregate [$$26] <- [listify($$25)] -- AGGREGATE |UNPARTITIONED| limit 1 -- STREAM_LIMIT |UNPARTITIONED| - project ([$$23]) + project ([$$25]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$34(ASC) ] |PARTITIONED| - project ([$$34, $$23]) + -- SORT_MERGE_EXCHANGE [$$36(ASC) ] |PARTITIONED| + project ([$$36, $$25]) -- STREAM_PROJECT |PARTITIONED| - assign [$$23] <- [{"d": $$d}] + assign [$$25] <- [{"d": $$d}] -- ASSIGN |PARTITIONED| limit 1 -- STREAM_LIMIT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$34, $$d] <- test.DBLP1 condition (ends-with($$d.getField(1), "Blakeley95")) limit 1 + data-scan []<-[$$36, $$d] <- test.DBLP1 condition (ends-with($$d.getField(1), "Blakeley95")) limit 1 -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.6.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.6.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.6.adm index 94608d0..8ffb399 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.6.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.6.adm @@ -1,26 +1,26 @@ -distribute result [$$16] +distribute result [$$17] -- DISTRIBUTE_RESULT |UNPARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |UNPARTITIONED| limit 1 -- STREAM_LIMIT |UNPARTITIONED| - project ([$$16]) + project ([$$17]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$18(ASC) ] |PARTITIONED| - project ([$$18, $$16]) + -- SORT_MERGE_EXCHANGE [$$19(ASC) ] |PARTITIONED| + project ([$$19, $$17]) -- STREAM_PROJECT |PARTITIONED| - assign [$$16] <- [{"$1": substring($$17, 0, 21)}] + assign [$$17] <- [{"$1": substring($$18, 0, 21)}] -- ASSIGN |PARTITIONED| limit 1 -- STREAM_LIMIT |PARTITIONED| - project ([$$18, $$17]) + project ([$$19, $$18]) -- STREAM_PROJECT |PARTITIONED| - assign [$$17] <- [$$DBLP1.getField(1)] + assign [$$18] <- [$$DBLP1.getField(1)] -- ASSIGN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$18, $$DBLP1] <- test.DBLP1 condition (gt($$DBLP1.getField(1), "series")) limit 1 + data-scan []<-[$$19, $$DBLP1] <- test.DBLP1 condition (gt($$DBLP1.getField(1), "series")) limit 1 -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.8.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.8.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.8.adm index 131b860..bc86e3a 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.8.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan-select/push-limit-to-primary-scan-select.8.adm @@ -1,26 +1,26 @@ -distribute result [$$19] +distribute result [$$20] -- DISTRIBUTE_RESULT |UNPARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |UNPARTITIONED| limit 2 -- STREAM_LIMIT |UNPARTITIONED| - project ([$$19]) + project ([$$20]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$22(ASC) ] |PARTITIONED| + -- SORT_MERGE_EXCHANGE [$$23(ASC) ] |PARTITIONED| limit 2 -- STREAM_LIMIT |PARTITIONED| - project ([$$22, $$19]) + project ([$$23, $$20]) -- STREAM_PROJECT |PARTITIONED| - assign [$$19] <- [$$23.getField("lang")] + assign [$$20] <- [$$24.getField("lang")] -- ASSIGN |PARTITIONED| - project ([$$22, $$23]) + project ([$$23, $$24]) -- STREAM_PROJECT |PARTITIONED| - assign [$$23] <- [$$t.getField("user")] + assign [$$24] <- [$$t.getField("user")] -- ASSIGN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$22, $$t] <- test.TweetMessages condition (and(ge($$t.getField("user").getField("friends_count"), 0), le($$t.getField("user").getField("friends_count"), 150))) limit 2 + data-scan []<-[$$23, $$t] <- test.TweetMessages condition (and(ge($$t.getField("user").getField("friends_count"), 0), le($$t.getField("user").getField("friends_count"), 150))) limit 2 -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.3.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.3.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.3.adm index daeeeb5..a810489 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.3.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.3.adm @@ -7,12 +7,12 @@ distribute result [$$paper] project ([$$paper]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$10(ASC) ] |PARTITIONED| + -- SORT_MERGE_EXCHANGE [$$11(ASC) ] |PARTITIONED| limit 10 -- STREAM_LIMIT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$10, $$paper] <- test.DBLP1 limit 10 + data-scan []<-[$$11, $$paper] <- test.DBLP1 limit 10 -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.5.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.5.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.5.adm index ee3e565..41880a5 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.5.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/limit/push-limit-to-primary-scan/push-limit-to-primary-scan.5.adm @@ -7,12 +7,12 @@ distribute result [$$paper] project ([$$paper]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$12(ASC) ] |PARTITIONED| + -- SORT_MERGE_EXCHANGE [$$13(ASC) ] |PARTITIONED| limit 10 -- STREAM_LIMIT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - data-scan []<-[$$12, $$paper] <- test.DBLP1 limit 10 + data-scan []<-[$$13, $$paper] <- test.DBLP1 limit 10 -- DATASOURCE_SCAN |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/list/enforcing_item_type/enforcing_item_type.1.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/list/enforcing_item_type/enforcing_item_type.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/list/enforcing_item_type/enforcing_item_type.1.adm index fbe0345..81de56f 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/list/enforcing_item_type/enforcing_item_type.1.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/list/enforcing_item_type/enforcing_item_type.1.adm @@ -1,12 +1,12 @@ -distribute result [$$18] +distribute result [$$19] -- DISTRIBUTE_RESULT |UNPARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |UNPARTITIONED| - project ([$$18]) + project ([$$19]) -- STREAM_PROJECT |UNPARTITIONED| - assign [$$18] <- [{"id": get-item($$t, 0), "v": get-item($$t, 1)}] + assign [$$19] <- [{"id": get-item($$t, 0), "v": get-item($$t, 1)}] -- ASSIGN |UNPARTITIONED| unnest $$t <- scan-collection(ordered-list-constructor(ordered-list-constructor(29, cast({ f1: "a", f2: 3 })))) -- UNNEST |UNPARTITIONED| empty-tuple-source - -- EMPTY_TUPLE_SOURCE |UNPARTITIONED| \ No newline at end of file + -- EMPTY_TUPLE_SOURCE |UNPARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.13.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.13.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.13.adm index 2a155f9..73492d2 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.13.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.13.adm @@ -5,28 +5,28 @@ distribute result [$$l] project ([$$l]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$14(ASC), $$15(ASC) ] |PARTITIONED| + -- SORT_MERGE_EXCHANGE [$$15(ASC), $$16(ASC) ] |PARTITIONED| select (eq($$l.getField(10), "1994-01-20")) -- STREAM_SELECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$14, $$15, $$l] <- index-search("LineItem", 0, "tpch", "LineItem", FALSE, FALSE, 2, $$22, $$23, 2, $$22, $$23, TRUE, TRUE, TRUE) + unnest-map [$$15, $$16, $$l] <- index-search("LineItem", 0, "tpch", "LineItem", FALSE, FALSE, 2, $$23, $$24, 2, $$23, $$24, TRUE, TRUE, TRUE) -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - order (ASC, $$22) (ASC, $$23) - -- STABLE_SORT [$$22(ASC), $$23(ASC)] |PARTITIONED| + order (ASC, $$23) (ASC, $$24) + -- STABLE_SORT [$$23(ASC), $$24(ASC)] |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$22, $$23]) + project ([$$23, $$24]) -- STREAM_PROJECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$21, $$22, $$23] <- index-search("lineitem_shipdateIx", 0, "tpch", "LineItem", FALSE, FALSE, 1, $$19, 1, $$20, TRUE, TRUE, TRUE) + unnest-map [$$22, $$23, $$24] <- index-search("lineitem_shipdateIx", 0, "tpch", "LineItem", FALSE, FALSE, 1, $$20, 1, $$21, TRUE, TRUE, TRUE) -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - assign [$$19, $$20] <- ["1994-01-20", "1994-01-20"] + assign [$$20, $$21] <- ["1994-01-20", "1994-01-20"] -- ASSIGN |PARTITIONED| empty-tuple-source -- EMPTY_TUPLE_SOURCE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.8.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.8.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.8.adm index 2a155f9..73492d2 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.8.adm +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/rebalance/single_dataset_with_index/single_dataset_with_index.8.adm @@ -5,28 +5,28 @@ distribute result [$$l] project ([$$l]) -- STREAM_PROJECT |PARTITIONED| exchange - -- SORT_MERGE_EXCHANGE [$$14(ASC), $$15(ASC) ] |PARTITIONED| + -- SORT_MERGE_EXCHANGE [$$15(ASC), $$16(ASC) ] |PARTITIONED| select (eq($$l.getField(10), "1994-01-20")) -- STREAM_SELECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$14, $$15, $$l] <- index-search("LineItem", 0, "tpch", "LineItem", FALSE, FALSE, 2, $$22, $$23, 2, $$22, $$23, TRUE, TRUE, TRUE) + unnest-map [$$15, $$16, $$l] <- index-search("LineItem", 0, "tpch", "LineItem", FALSE, FALSE, 2, $$23, $$24, 2, $$23, $$24, TRUE, TRUE, TRUE) -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - order (ASC, $$22) (ASC, $$23) - -- STABLE_SORT [$$22(ASC), $$23(ASC)] |PARTITIONED| + order (ASC, $$23) (ASC, $$24) + -- STABLE_SORT [$$23(ASC), $$24(ASC)] |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - project ([$$22, $$23]) + project ([$$23, $$24]) -- STREAM_PROJECT |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - unnest-map [$$21, $$22, $$23] <- index-search("lineitem_shipdateIx", 0, "tpch", "LineItem", FALSE, FALSE, 1, $$19, 1, $$20, TRUE, TRUE, TRUE) + unnest-map [$$22, $$23, $$24] <- index-search("lineitem_shipdateIx", 0, "tpch", "LineItem", FALSE, FALSE, 1, $$20, 1, $$21, TRUE, TRUE, TRUE) -- BTREE_SEARCH |PARTITIONED| exchange -- ONE_TO_ONE_EXCHANGE |PARTITIONED| - assign [$$19, $$20] <- ["1994-01-20", "1994-01-20"] + assign [$$20, $$21] <- ["1994-01-20", "1994-01-20"] -- ASSIGN |PARTITIONED| empty-tuple-source -- EMPTY_TUPLE_SOURCE |PARTITIONED| http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/misc_01/misc_01.6.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/misc_01/misc_01.6.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/misc_01/misc_01.6.adm new file mode 100644 index 0000000..421034a --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/misc_01/misc_01.6.adm @@ -0,0 +1,4 @@ +{ "c1": 1, "sum": 4 } +{ "c1": 2, "sum": 6 } +{ "c1": 3, "sum": 4 } +{ "c1": 4, "sum": 6 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.10.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.10.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.10.adm new file mode 100644 index 0000000..a80b303 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.10.adm @@ -0,0 +1,10 @@ +{ "percent_rank": 0.0, "ten": 0, "four": 0 } +{ "percent_rank": 0.0, "ten": 0, "four": 0 } +{ "percent_rank": 1.0, "ten": 4, "four": 0 } +{ "percent_rank": 0.0, "ten": 1, "four": 1 } +{ "percent_rank": 0.0, "ten": 1, "four": 1 } +{ "percent_rank": 0.6667, "ten": 7, "four": 1 } +{ "percent_rank": 1.0, "ten": 9, "four": 1 } +{ "percent_rank": 0.0, "ten": 0, "four": 2 } +{ "percent_rank": 0.0, "ten": 1, "four": 3 } +{ "percent_rank": 1.0, "ten": 3, "four": 3 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.100.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.100.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.100.adm new file mode 100644 index 0000000..f52d836 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.100.adm @@ -0,0 +1,10 @@ +{ "enroll_date": date("2006-10-01"), "salary": 5000, "first_value": 5000, "last_value": 5200 } +{ "enroll_date": date("2006-10-01"), "salary": 6000, "first_value": 6000, "last_value": 5200 } +{ "enroll_date": date("2006-12-23"), "salary": 3900, "first_value": 5000, "last_value": 3500 } +{ "enroll_date": date("2007-08-01"), "salary": 4800, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-01"), "salary": 5200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-08"), "salary": 4800, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-15"), "salary": 5200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-12-10"), "salary": 3500, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2008-01-01"), "salary": 4200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2008-01-01"), "salary": 4500, "first_value": 5000, "last_value": 4500 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.101.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.101.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.101.adm new file mode 100644 index 0000000..374d759 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.101.adm @@ -0,0 +1,10 @@ +{ "enroll_date": date("2006-10-01"), "salary": 5000, "first_value": 5000, "last_value": 5200 } +{ "enroll_date": date("2006-10-01"), "salary": 6000, "first_value": 6000, "last_value": 5200 } +{ "enroll_date": date("2006-12-23"), "salary": 3900, "first_value": 5000, "last_value": 3500 } +{ "enroll_date": date("2007-08-01"), "salary": 4800, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-01"), "salary": 5200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-08"), "salary": 4800, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-15"), "salary": 5200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-12-10"), "salary": 3500, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2008-01-01"), "salary": 4200, "first_value": 5000, "last_value": 4200 } +{ "enroll_date": date("2008-01-01"), "salary": 4500, "first_value": 5000, "last_value": 4500 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.102.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.102.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.102.adm new file mode 100644 index 0000000..c041317 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.102.adm @@ -0,0 +1,10 @@ +{ "enroll_date": date("2006-10-01"), "salary": 5000, "first_value": 3900, "last_value": 5200 } +{ "enroll_date": date("2006-10-01"), "salary": 6000, "first_value": 3900, "last_value": 5200 } +{ "enroll_date": date("2006-12-23"), "salary": 3900, "first_value": 5000, "last_value": 3500 } +{ "enroll_date": date("2007-08-01"), "salary": 4800, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-01"), "salary": 5200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-08"), "salary": 4800, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-15"), "salary": 5200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-12-10"), "salary": 3500, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2008-01-01"), "salary": 4200, "first_value": 5000, "last_value": 3500 } +{ "enroll_date": date("2008-01-01"), "salary": 4500, "first_value": 5000, "last_value": 3500 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.103.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.103.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.103.adm new file mode 100644 index 0000000..0713c9e --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.103.adm @@ -0,0 +1,10 @@ +{ "enroll_date": date("2006-10-01"), "salary": 5000, "first_value": 6000, "last_value": 5200 } +{ "enroll_date": date("2006-10-01"), "salary": 6000, "first_value": 5000, "last_value": 5200 } +{ "enroll_date": date("2006-12-23"), "salary": 3900, "first_value": 5000, "last_value": 3500 } +{ "enroll_date": date("2007-08-01"), "salary": 4800, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-01"), "salary": 5200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-08"), "salary": 4800, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-08-15"), "salary": 5200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2007-12-10"), "salary": 3500, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2008-01-01"), "salary": 4200, "first_value": 5000, "last_value": 4500 } +{ "enroll_date": date("2008-01-01"), "salary": 4500, "first_value": 5000, "last_value": 4200 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.104.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.104.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.104.adm new file mode 100644 index 0000000..26f956b --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.104.adm @@ -0,0 +1,6 @@ +{ "x": null, "y": 42, "first_value": 42, "last_value": 42 } +{ "x": 1, "y": 1, "first_value": 1, "last_value": 3 } +{ "x": 2, "y": 2, "first_value": 1, "last_value": 4 } +{ "x": 3, "y": 3, "first_value": 1, "last_value": 5 } +{ "x": 4, "y": 4, "first_value": 2, "last_value": 5 } +{ "x": 5, "y": 5, "first_value": 3, "last_value": 5 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.105.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.105.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.105.adm new file mode 100644 index 0000000..4fba5a6 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.105.adm @@ -0,0 +1,6 @@ +{ "x": 5, "y": 5, "first_value": 5, "last_value": 3 } +{ "x": 4, "y": 4, "first_value": 5, "last_value": 2 } +{ "x": 3, "y": 3, "first_value": 5, "last_value": 1 } +{ "x": 2, "y": 2, "first_value": 4, "last_value": 1 } +{ "x": 1, "y": 1, "first_value": 3, "last_value": 1 } +{ "x": null, "y": 42, "first_value": 42, "last_value": 42 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.106.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.106.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.106.adm new file mode 100644 index 0000000..8214780 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.106.adm @@ -0,0 +1,3 @@ +{ "x": 32764, "last_value": 32766 } +{ "x": 32765, "last_value": 32766 } +{ "x": 32766, "last_value": 32766 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.107.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.107.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.107.adm new file mode 100644 index 0000000..ff8d4fb --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.107.adm @@ -0,0 +1,3 @@ +{ "x": -32764, "last_value": -32766 } +{ "x": -32765, "last_value": -32766 } +{ "x": -32766, "last_value": -32766 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.108.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.108.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.108.adm new file mode 100644 index 0000000..eaacf51 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.108.adm @@ -0,0 +1,3 @@ +{ "x": 2147483644, "last_value": 2147483646 } +{ "x": 2147483645, "last_value": 2147483646 } +{ "x": 2147483646, "last_value": 2147483646 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.109.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.109.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.109.adm new file mode 100644 index 0000000..946b4fb --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.109.adm @@ -0,0 +1,3 @@ +{ "x": -2147483644, "last_value": -2147483646 } +{ "x": -2147483645, "last_value": -2147483646 } +{ "x": -2147483646, "last_value": -2147483646 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.11.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.11.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.11.adm new file mode 100644 index 0000000..4e7d772 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.11.adm @@ -0,0 +1,10 @@ +{ "ntile": 1, "ten": 0, "four": 0 } +{ "ntile": 1, "ten": 0, "four": 0 } +{ "ntile": 1, "ten": 0, "four": 2 } +{ "ntile": 1, "ten": 1, "four": 1 } +{ "ntile": 2, "ten": 1, "four": 1 } +{ "ntile": 2, "ten": 1, "four": 3 } +{ "ntile": 2, "ten": 3, "four": 3 } +{ "ntile": 3, "ten": 4, "four": 0 } +{ "ntile": 3, "ten": 7, "four": 1 } +{ "ntile": 3, "ten": 9, "four": 1 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.110.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.110.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.110.adm new file mode 100644 index 0000000..d68b69c --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.110.adm @@ -0,0 +1,10 @@ +{ "id": 0, "f_float4": -INF, "first_value": 0, "last_value": 0 } +{ "id": 1, "f_float4": -3.0, "first_value": 1, "last_value": 1 } +{ "id": 2, "f_float4": -1.0, "first_value": 2, "last_value": 3 } +{ "id": 3, "f_float4": 0.0, "first_value": 2, "last_value": 3 } +{ "id": 4, "f_float4": 1.1, "first_value": 4, "last_value": 6 } +{ "id": 5, "f_float4": 1.12, "first_value": 4, "last_value": 6 } +{ "id": 6, "f_float4": 2.0, "first_value": 4, "last_value": 6 } +{ "id": 7, "f_float4": 100.0, "first_value": 7, "last_value": 7 } +{ "id": 8, "f_float4": INF, "first_value": 8, "last_value": 8 } +{ "id": 9, "f_float4": NaN, "first_value": 9, "last_value": 9 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.111.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.111.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.111.adm new file mode 100644 index 0000000..8186273 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.111.adm @@ -0,0 +1,10 @@ +{ "id": 0, "f_float4": -INF, "first_value": 0, "last_value": 0 } +{ "id": 1, "f_float4": -3.0, "first_value": 1, "last_value": 1 } +{ "id": 2, "f_float4": -1.0, "first_value": 2, "last_value": 3 } +{ "id": 3, "f_float4": 0.0, "first_value": 2, "last_value": 4 } +{ "id": 4, "f_float4": 1.1, "first_value": 4, "last_value": 6 } +{ "id": 5, "f_float4": 1.12, "first_value": 4, "last_value": 6 } +{ "id": 6, "f_float4": 2.0, "first_value": 4, "last_value": 6 } +{ "id": 7, "f_float4": 100.0, "first_value": 7, "last_value": 7 } +{ "id": 8, "f_float4": INF, "first_value": 8, "last_value": 8 } +{ "id": 9, "f_float4": NaN, "first_value": 9, "last_value": 9 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.112.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.112.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.112.adm new file mode 100644 index 0000000..f65c24b --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.112.adm @@ -0,0 +1,10 @@ +{ "id": 0, "f_float8": -INF, "first_value": 0, "last_value": 0 } +{ "id": 1, "f_float8": -3.0, "first_value": 1, "last_value": 1 } +{ "id": 2, "f_float8": -1.0, "first_value": 2, "last_value": 3 } +{ "id": 3, "f_float8": 0.0, "first_value": 2, "last_value": 4 } +{ "id": 4, "f_float8": 1.1, "first_value": 4, "last_value": 6 } +{ "id": 5, "f_float8": 1.12, "first_value": 4, "last_value": 6 } +{ "id": 6, "f_float8": 2.0, "first_value": 4, "last_value": 6 } +{ "id": 7, "f_float8": 100.0, "first_value": 7, "last_value": 7 } +{ "id": 8, "f_float8": INF, "first_value": 8, "last_value": 8 } +{ "id": 9, "f_float8": NaN, "first_value": 9, "last_value": 9 } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/f2c18aa9/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.113.adm ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.113.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.113.adm new file mode 100644 index 0000000..3b7f6d7 --- /dev/null +++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/window/pg_win/pg_win.113.adm @@ -0,0 +1,10 @@ +{ "id": 1, "f_timetz": time("11:00:00.000Z"), "first_value": 1, "last_value": 3 } +{ "id": 2, "f_timetz": time("12:00:00.000Z"), "first_value": 1, "last_value": 4 } +{ "id": 3, "f_timetz": time("13:00:00.000Z"), "first_value": 2, "last_value": 5 } +{ "id": 4, "f_timetz": time("14:00:00.000Z"), "first_value": 3, "last_value": 6 } +{ "id": 5, "f_timetz": time("15:00:00.000Z"), "first_value": 4, "last_value": 7 } +{ "id": 6, "f_timetz": time("16:00:00.000Z"), "first_value": 5, "last_value": 8 } +{ "id": 7, "f_timetz": time("17:00:00.000Z"), "first_value": 6, "last_value": 9 } +{ "id": 8, "f_timetz": time("18:00:00.000Z"), "first_value": 7, "last_value": 10 } +{ "id": 9, "f_timetz": time("19:00:00.000Z"), "first_value": 8, "last_value": 10 } +{ "id": 10, "f_timetz": time("20:00:00.000Z"), "first_value": 9, "last_value": 10 } \ No newline at end of file
