>From Ian Maxon <ima...@apache.org>:
Ian Maxon has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20377?usp=email )
Change subject: [NO ISSUE] Fix result for pushdown test
......................................................................
[NO ISSUE] Fix result for pushdown test
Change-Id: Ied9fe760c198c3fb3da3ebc5b10ab7c31fa84b32
---
M asterixdb/asterix-app/src/test/resources/runtimets/only_sqlpp.xml
M
asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.004.plan
M
asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.005.plan
M
asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.006.plan
M
asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.007.plan
5 files changed, 167 insertions(+), 162 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/77/20377/1
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/only_sqlpp.xml
b/asterixdb/asterix-app/src/test/resources/runtimets/only_sqlpp.xml
index 334dd52..24bbbdb 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/only_sqlpp.xml
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/only_sqlpp.xml
@@ -19,5 +19,10 @@
!-->
<test-suite xmlns="urn:xml.testframework.asterix.apache.org"
ResultOffsetPath="results" QueryOffsetPath="queries_sqlpp"
QueryFileExtension=".sqlpp">
<test-group name="failed">
+ <test-case FilePath="column">
+ <compilation-unit name="pushdown/same-datasource-diff-scan">
+ <output-dir
compare="Text">pushdown/same-datasource-diff-scan</output-dir>
+ </compilation-unit>
+ </test-case>
</test-group>
</test-suite>
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.004.plan
b/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.004.plan
index 7a0cdde..593dc1e 100644
---
a/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.004.plan
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.004.plan
@@ -1,64 +1,64 @@
-distribute result [$$70] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+distribute result [$$70] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- DISTRIBUTE_RESULT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$70]) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ project ([$$70]) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- SORT_MERGE_EXCHANGE [$$139(ASC) ] |PARTITIONED|
- order (ASC, $$139) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ order (ASC, $$139) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- STABLE_SORT [$$139(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost:
0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- distinct ([$$70]) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ distinct ([$$70]) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- PRE_SORTED_DISTINCT_BY |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- order (ASC, $$70) [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ order (ASC, $$70) [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- STABLE_SORT [$$70(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- HASH_PARTITION_EXCHANGE [$$70] |PARTITIONED|
- union ($$53, $$63, $$70) ($$74, $$76, $$139) [cardinality:
0.0, op-cost: 0.0, total-cost: 0.0]
+ union ($$53, $$63, $$70) ($$74, $$76, $$139) [cardinality:
0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- UNION_ALL |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$53] <- [{"user_id": $$74}] project: [$$53,
$$74] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$53] <- [{"user_id": $$74}] project: [$$53,
$$74] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- select (and(ge($$72, 20), le($$72, 50))) project:
[$$74] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ select (and(ge($$72, 20), le($$72, 50))) project:
[$$74] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_SELECT |PARTITIONED|
- assign [$$72] <- [$$ds1.getField("val")] project:
[$$74, $$72] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$72] <- [$$ds1.getField("val")] project:
[$$74, $$72] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- data-scan []<-[$$74, $$ds1] <- test.ds1
project ({val:any}) filter on: and(ge($$ds1.getField("val"), 20),
le($$ds1.getField("val"), 50)) range-filter on: and(ge($$ds1.getField("val"),
20), le($$ds1.getField("val"), 50)) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ data-scan []<-[$$74, $$ds1] <- test.ds1
project ({val:any}) filter on: and(ge($$ds1.getField("val"), 20),
le($$ds1.getField("val"), 50)) range-filter on: and(ge($$ds1.getField("val"),
20), le($$ds1.getField("val"), 50)) [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- empty-tuple-source [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ empty-tuple-source [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- EMPTY_TUPLE_SOURCE |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$63] <- [{"user_id": $$76}] project: [$$63,
$$76] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$63] <- [{"user_id": $$76}] project: [$$63,
$$76] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- project ([$$76]) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ project ([$$76]) [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- unnest-map [$$76, $$ds1] <- index-search("ds1",
0, "Default", "test", "ds1", true, true, 1, $$75, 1, $$75, true, true, true)
project ({}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ unnest-map [$$76, $$ds1] <- index-search("ds1",
0, "Default", "test", "ds1", true, true, 1, $$75, 1, $$75, true, true, true)
project ({}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- BTREE_SEARCH |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- order (ASC, $$75) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ order (ASC, $$75) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STABLE_SORT [$$75(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$75]) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ project ([$$75]) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size:
0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- data-scan []<-[$$75, $$c] <-
test.ds_contains project ({}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ data-scan []<-[$$75, $$c] <-
test.ds_contains project ({}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE
|PARTITIONED|
- empty-tuple-source [cardinality:
0.0, op-cost: 0.0, total-cost: 0.0]
+ empty-tuple-source [cardinality:
0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- EMPTY_TUPLE_SOURCE
|PARTITIONED|
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.005.plan
b/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.005.plan
index 5319f89..2f3ef10 100644
---
a/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.005.plan
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.005.plan
@@ -1,94 +1,94 @@
-distribute result [$$103] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+distribute result [$$103] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- DISTRIBUTE_RESULT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$103]) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ project ([$$103]) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- SORT_MERGE_EXCHANGE [$$233(ASC) ] |PARTITIONED|
- order (ASC, $$233) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ order (ASC, $$233) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- STABLE_SORT [$$233(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost:
0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- distinct ([$$103]) [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ distinct ([$$103]) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- PRE_SORTED_DISTINCT_BY |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- order (ASC, $$103) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ order (ASC, $$103) [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- STABLE_SORT [$$103(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- HASH_PARTITION_EXCHANGE [$$103] |PARTITIONED|
- union ($$155, $$95, $$103) ($$234, $$112, $$233)
[cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ union ($$155, $$95, $$103) ($$234, $$112, $$233)
[cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- UNION_ALL |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- union ($$75, $$85, $$155) ($$108, $$110, $$234)
[cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ union ($$75, $$85, $$155) ($$108, $$110, $$234)
[cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- UNION_ALL |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$75] <- [{"user_id": $$108}] project:
[$$75, $$108] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$75] <- [{"user_id": $$108}] project:
[$$75, $$108] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- select (and(ge($$105, 20), le($$105, 50)))
project: [$$108] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ select (and(ge($$105, 20), le($$105, 50)))
project: [$$108] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost:
0.0]
-- STREAM_SELECT |PARTITIONED|
- assign [$$105] <- [$$ds1.getField("val")]
project: [$$108, $$105] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$105] <- [$$ds1.getField("val")]
project: [$$108, $$105] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- data-scan []<-[$$108, $$ds1] <- test.ds1
project ({val:any}) filter on: and(ge($$ds1.getField("val"), 20),
le($$ds1.getField("val"), 50)) range-filter on: and(ge($$ds1.getField("val"),
20), le($$ds1.getField("val"), 50)) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ data-scan []<-[$$108, $$ds1] <- test.ds1
project ({val:any}) filter on: and(ge($$ds1.getField("val"), 20),
le($$ds1.getField("val"), 50)) range-filter on: and(ge($$ds1.getField("val"),
20), le($$ds1.getField("val"), 50)) [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size:
0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- empty-tuple-source [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ empty-tuple-source [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- EMPTY_TUPLE_SOURCE |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$85] <- [{"user_id": $$110}] project:
[$$85, $$110] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$85] <- [{"user_id": $$110}] project:
[$$85, $$110] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- project ([$$110]) [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ project ([$$110]) [cardinality: 0.0, doc-size:
0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- unnest-map [$$110, $$ds1] <-
index-search("ds1", 0, "Default", "test", "ds1", true, true, 1, $$109, 1,
$$109, true, true, true) project ({}) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ unnest-map [$$110, $$ds1] <-
index-search("ds1", 0, "Default", "test", "ds1", true, true, 1, $$109, 1,
$$109, true, true, true) project ({}) [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- BTREE_SEARCH |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- order (ASC, $$109) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ order (ASC, $$109) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STABLE_SORT [$$109(ASC)]
|PARTITIONED|
- exchange [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size:
0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$109]) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ project ([$$109]) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE
|PARTITIONED|
- data-scan []<-[$$109, $$c] <-
test.ds_contains project ({}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ data-scan []<-[$$109, $$c] <-
test.ds_contains project ({}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE
|PARTITIONED|
- empty-tuple-source
[cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ empty-tuple-source
[cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- EMPTY_TUPLE_SOURCE
|PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$95] <- [{"user_id": $$112}] project: [$$95,
$$112] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$95] <- [{"user_id": $$112}] project: [$$95,
$$112] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- project ([$$112]) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ project ([$$112]) [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- unnest-map [$$112, $$ds1] <- index-search("ds1",
0, "Default", "test", "ds1", true, true, 1, $$111, 1, $$111, true, true, true)
project ({}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ unnest-map [$$112, $$ds1] <- index-search("ds1",
0, "Default", "test", "ds1", true, true, 1, $$111, 1, $$111, true, true, true)
project ({}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- BTREE_SEARCH |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- order (ASC, $$111) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ order (ASC, $$111) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STABLE_SORT [$$111(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$111]) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ project ([$$111]) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size:
0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- data-scan []<-[$$111, $$d] <-
test.ds_disjoint project ({}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ data-scan []<-[$$111, $$d] <-
test.ds_disjoint project ({}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE
|PARTITIONED|
- empty-tuple-source [cardinality:
0.0, op-cost: 0.0, total-cost: 0.0]
- -- EMPTY_TUPLE_SOURCE
|PARTITIONED|
\ No newline at end of file
+ empty-tuple-source [cardinality:
0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
+ -- EMPTY_TUPLE_SOURCE
|PARTITIONED|
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.006.plan
b/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.006.plan
index ab08e51..5afc25b 100644
---
a/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.006.plan
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.006.plan
@@ -1,96 +1,96 @@
-distribute result [$$105] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+distribute result [$$105] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- DISTRIBUTE_RESULT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$105]) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ project ([$$105]) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- SORT_MERGE_EXCHANGE [$$236(ASC) ] |PARTITIONED|
- order (ASC, $$236) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ order (ASC, $$236) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- STABLE_SORT [$$236(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost:
0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- distinct ([$$105]) [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ distinct ([$$105]) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- PRE_SORTED_DISTINCT_BY |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- order (ASC, $$105) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ order (ASC, $$105) [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- STABLE_SORT [$$105(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- HASH_PARTITION_EXCHANGE [$$105] |PARTITIONED|
- union ($$157, $$97, $$105) ($$237, $$114, $$236)
[cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ union ($$157, $$97, $$105) ($$237, $$114, $$236)
[cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- UNION_ALL |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- union ($$75, $$87, $$157) ($$110, $$112, $$237)
[cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ union ($$75, $$87, $$157) ($$110, $$112, $$237)
[cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- UNION_ALL |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$75] <- [{"user_id": $$110}] project:
[$$75, $$110] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$75] <- [{"user_id": $$110}] project:
[$$75, $$110] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- select (and(ge($$107, 20), le($$107, 50)))
project: [$$110] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ select (and(ge($$107, 20), le($$107, 50)))
project: [$$110] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost:
0.0]
-- STREAM_SELECT |PARTITIONED|
- assign [$$107] <- [$$ds1.getField("val")]
project: [$$110, $$107] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$107] <- [$$ds1.getField("val")]
project: [$$110, $$107] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- data-scan []<-[$$110, $$ds1] <- test.ds1
project ({val:any}) filter on: and(ge($$ds1.getField("val"), 20),
le($$ds1.getField("val"), 50)) range-filter on: and(ge($$ds1.getField("val"),
20), le($$ds1.getField("val"), 50)) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ data-scan []<-[$$110, $$ds1] <- test.ds1
project ({val:any}) filter on: and(ge($$ds1.getField("val"), 20),
le($$ds1.getField("val"), 50)) range-filter on: and(ge($$ds1.getField("val"),
20), le($$ds1.getField("val"), 50)) [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size:
0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- empty-tuple-source [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ empty-tuple-source [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- EMPTY_TUPLE_SOURCE |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$87] <- [{"user_id": $$112}] project:
[$$87, $$112] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$87] <- [{"user_id": $$112}] project:
[$$87, $$112] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- select (eq($$ds1.getField("val"), 1)) project:
[$$112] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ select (eq($$ds1.getField("val"), 1)) project:
[$$112] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_SELECT |PARTITIONED|
- project ([$$112, $$ds1]) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ project ([$$112, $$ds1]) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- unnest-map [$$112, $$ds1] <-
index-search("ds1", 0, "Default", "test", "ds1", true, true, 1, $$111, 1,
$$111, true, true, true) project ({val:any}) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ unnest-map [$$112, $$ds1] <-
index-search("ds1", 0, "Default", "test", "ds1", true, true, 1, $$111, 1,
$$111, true, true, true) project ({val:any}) [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- BTREE_SEARCH |PARTITIONED|
- exchange [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size:
0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- order (ASC, $$111) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ order (ASC, $$111) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STABLE_SORT [$$111(ASC)]
|PARTITIONED|
- exchange [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$111]) [cardinality:
0.0, op-cost: 0.0, total-cost: 0.0]
+ project ([$$111]) [cardinality:
0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE
|PARTITIONED|
- data-scan []<-[$$111, $$c] <-
test.ds_contains project ({}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ data-scan []<-[$$111, $$c] <-
test.ds_contains project ({}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- DATASOURCE_SCAN
|PARTITIONED|
- exchange [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE
|PARTITIONED|
- empty-tuple-source
[cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ empty-tuple-source
[cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- EMPTY_TUPLE_SOURCE
|PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$97] <- [{"user_id": $$114}] project: [$$97,
$$114] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$97] <- [{"user_id": $$114}] project: [$$97,
$$114] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- project ([$$114]) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ project ([$$114]) [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- unnest-map [$$114, $$ds1] <- index-search("ds1",
0, "Default", "test", "ds1", true, true, 1, $$113, 1, $$113, true, true, true)
project ({val:any}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ unnest-map [$$114, $$ds1] <- index-search("ds1",
0, "Default", "test", "ds1", true, true, 1, $$113, 1, $$113, true, true, true)
project ({val:any}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost:
0.0]
-- BTREE_SEARCH |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- order (ASC, $$113) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ order (ASC, $$113) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STABLE_SORT [$$113(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$113]) [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ project ([$$113]) [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size:
0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- data-scan []<-[$$113, $$d] <-
test.ds_disjoint project ({}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ data-scan []<-[$$113, $$d] <-
test.ds_disjoint project ({}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE
|PARTITIONED|
- empty-tuple-source [cardinality:
0.0, op-cost: 0.0, total-cost: 0.0]
- -- EMPTY_TUPLE_SOURCE
|PARTITIONED|
\ No newline at end of file
+ empty-tuple-source [cardinality:
0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
+ -- EMPTY_TUPLE_SOURCE
|PARTITIONED|
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.007.plan
b/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.007.plan
index e362b57..cecd2f7 100644
---
a/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.007.plan
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/column/pushdown/same-datasource-diff-scan/same-datasource-diff-scan.007.plan
@@ -1,64 +1,64 @@
-distribute result [$$70] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+distribute result [$$70] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- DISTRIBUTE_RESULT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- distinct ([$$70]) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ distinct ([$$70]) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- PRE_SORTED_DISTINCT_BY |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- order (ASC, $$70) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ order (ASC, $$70) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- STABLE_SORT [$$70(ASC)] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost:
0.0]
-- HASH_PARTITION_EXCHANGE [$$70] |PARTITIONED|
- union ($$102, $$118, $$70) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ union ($$102, $$118, $$70) [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- UNION_ALL |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$102] <- [{"user_id": $$73}] project: [$$102]
[cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$102] <- [{"user_id": $$73}] project: [$$102]
[cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- select (and(ge($$71, 20), le($$71, 50))) project: [$$73]
[cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ select (and(ge($$71, 20), le($$71, 50))) project: [$$73]
[cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- STREAM_SELECT |PARTITIONED|
- assign [$$71] <- [$$ds1.getField("val")] project: [$$73,
$$71] [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$71] <- [$$ds1.getField("val")] project: [$$73,
$$71] [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- data-scan []<-[$$73, $$ds1] <- test.ds1 project
({val:any}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ data-scan []<-[$$73, $$ds1] <- test.ds1 project
({val:any}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- empty-tuple-source [cardinality: 0.0, op-cost:
0.0, total-cost: 0.0]
+ empty-tuple-source [cardinality: 0.0, doc-size:
0.0, op-cost: 0.0, total-cost: 0.0]
-- EMPTY_TUPLE_SOURCE |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- assign [$$118] <- [{"user_id": $$75}] project: [$$118]
[cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ assign [$$118] <- [{"user_id": $$75}] project: [$$118]
[cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- ASSIGN |PARTITIONED|
- project ([$$75]) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ project ([$$75]) [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0,
total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- join (eq($$74, $$75)) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ join (eq($$74, $$75)) [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- HYBRID_HASH_JOIN [$$74][$$75] |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$74]) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ project ([$$74]) [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- data-scan []<-[$$74, $$c] <- test.ds_contains
project ({}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ data-scan []<-[$$74, $$c] <- test.ds_contains
project ({}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- empty-tuple-source [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
+ empty-tuple-source [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- EMPTY_TUPLE_SOURCE |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0, total-cost:
0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0, op-cost:
0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- project ([$$75]) [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ project ([$$75]) [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- STREAM_PROJECT |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- data-scan []<-[$$75, $$ds1] <- test.ds1 project
({val:any}) [cardinality: 0.0, op-cost: 0.0, total-cost: 0.0]
+ data-scan []<-[$$75, $$ds1] <- test.ds1 project
({val:any}) [cardinality: 0.0, doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
-- DATASOURCE_SCAN |PARTITIONED|
- exchange [cardinality: 0.0, op-cost: 0.0,
total-cost: 0.0]
+ exchange [cardinality: 0.0, doc-size: 0.0,
op-cost: 0.0, total-cost: 0.0]
-- ONE_TO_ONE_EXCHANGE |PARTITIONED|
- empty-tuple-source [cardinality: 0.0,
op-cost: 0.0, total-cost: 0.0]
- -- EMPTY_TUPLE_SOURCE |PARTITIONED|
\ No newline at end of file
+ empty-tuple-source [cardinality: 0.0,
doc-size: 0.0, op-cost: 0.0, total-cost: 0.0]
+ -- EMPTY_TUPLE_SOURCE |PARTITIONED|
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20377?usp=email
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings?usp=email
Gerrit-MessageType: newchange
Gerrit-Project: asterixdb
Gerrit-Branch: phoenix
Gerrit-Change-Id: Ied9fe760c198c3fb3da3ebc5b10ab7c31fa84b32
Gerrit-Change-Number: 20377
Gerrit-PatchSet: 1
Gerrit-Owner: Ian Maxon <ima...@apache.org>
