@@ -77,7 +77,7 @@ Expected output:
7777``` json
7878{
7979 "calcite" : {
80- "logical" : " LogicalSystemLimit(fetch=[10000], type=[QUERY_SIZE_LIMIT])\n LogicalProject(name=[$0], country=[$1], state=[$2], month=[$3], year=[$4], age=[$5])\n LogicalFilter(condition=[>($5, 30 )])\n CalciteLogicalIndexScan(table=[[OpenSearch, state_country]])\n " ,
80+ "logical" : " LogicalSystemLimit(fetch=[10000], type=[QUERY_SIZE_LIMIT])\n LogicalProject(name=[$0], country=[$1], state=[$2], month=[$3], year=[$4], age=[$5])\n LogicalFilter(condition=[>($5, SAFE_CAST(30:BIGINT) )])\n CalciteLogicalIndexScan(table=[[OpenSearch, state_country]])\n " ,
8181 "physical" : " CalciteEnumerableIndexScan(table=[[OpenSearch, state_country]], PushDownContext=[[PROJECT->[name, country, state, month, year, age], FILTER->>($5, 30), LIMIT->10000], OpenSearchRequestBuilder(sourceBuilder={\" from\" :0,\" size\" :10000,\" timeout\" :\" 1m\" ,\" query\" :{\" range\" :{\" age\" :{\" from\" :30,\" to\" :null,\" include_lower\" :false,\" include_upper\" :true,\" boost\" :1.0}}},\" _source\" :{\" includes\" :[\" name\" ,\" country\" ,\" state\" ,\" month\" ,\" year\" ,\" age\" ],\" excludes\" :[]}}, requestedTotalSize=10000, pageSize=null, startFrom=0)])\n "
8282 }
8383}
@@ -119,7 +119,7 @@ Expected output:
119119``` json
120120{
121121 "calcite" : {
122- "logical" : " LogicalSystemLimit(fetch=[10000], type=[QUERY_SIZE_LIMIT])\n LogicalProject(name=[$0], country=[$1], state=[$2], month=[$3], year=[$4], age=[$5])\n LogicalFilter(condition=[>($5, 30 )])\n CalciteLogicalIndexScan(table=[[OpenSearch, state_country]])\n " ,
122+ "logical" : " LogicalSystemLimit(fetch=[10000], type=[QUERY_SIZE_LIMIT])\n LogicalProject(name=[$0], country=[$1], state=[$2], month=[$3], year=[$4], age=[$5])\n LogicalFilter(condition=[>($5, SAFE_CAST(30:BIGINT) )])\n CalciteLogicalIndexScan(table=[[OpenSearch, state_country]])\n " ,
123123 "physical" : " CalciteEnumerableIndexScan(table=[[OpenSearch, state_country]], PushDownContext=[[PROJECT->[name, country, state, month, year, age], FILTER->>($5, 30), LIMIT->10000], OpenSearchRequestBuilder(sourceBuilder={\" from\" :0,\" size\" :10000,\" timeout\" :\" 1m\" ,\" query\" :{\" range\" :{\" age\" :{\" from\" :30,\" to\" :null,\" include_lower\" :false,\" include_upper\" :true,\" boost\" :1.0}}},\" _source\" :{\" includes\" :[\" name\" ,\" country\" ,\" state\" ,\" month\" ,\" year\" ,\" age\" ],\" excludes\" :[]}}, requestedTotalSize=10000, pageSize=null, startFrom=0)])\n " ,
124124 "extended" : " public org.apache.calcite.linq4j.Enumerable bind(final org.apache.calcite.DataContext root) {\n final org.opensearch.sql.opensearch.storage.scan.CalciteEnumerableIndexScan v1stashed = (org.opensearch.sql.opensearch.storage.scan.CalciteEnumerableIndexScan) root.get(\" v1stashed\" );\n return v1stashed.scan();\n }\n\n\n public Class getElementType() {\n return java.lang.Object[].class;\n }\n\n\n "
125125 }
@@ -146,7 +146,7 @@ calcite:
146146 logical : |
147147 LogicalSystemLimit(fetch=[10000], type=[QUERY_SIZE_LIMIT])
148148 LogicalProject(name=[$0], country=[$1], state=[$2], month=[$3], year=[$4], age=[$5])
149- LogicalFilter(condition=[>($5, 30 )])
149+ LogicalFilter(condition=[>($5, SAFE_CAST(30:BIGINT) )])
150150 CalciteLogicalIndexScan(table=[[OpenSearch, state_country]])
151151 physical : |
152152 CalciteEnumerableIndexScan(table=[[OpenSearch, state_country]], PushDownContext=[[PROJECT->[name, country, state, month, year, age], FILTER->>($5, 30), LIMIT->10000], OpenSearchRequestBuilder(sourceBuilder={"from":0,"size":10000,"timeout":"1m","query":{"range":{"age":{"from":30,"to":null,"include_lower":false,"include_upper":true,"boost":1.0}}},"_source":{"includes":["name","country","state","month","year","age"],"excludes":[]}}, requestedTotalSize=10000, pageSize=null, startFrom=0)])
0 commit comments