The JDBC specification [1] defines the mapping between JDBC/SQL types to Java types (check TABLE B-1 JDBC Types Mapped to Java Types).
Best, Stamatis [1] https://jcp.org/aboutJava/communityprocess/mrel/jsr221/index3.html On Thu, Feb 24, 2022 at 1:48 PM xiaobo <[email protected]> wrote: > What we want to do is mapping Java LocalTime to SQL Time, from the csv > adapter example we know that we should pass a long value for SQL Time, but > we can't convert a Java LocalTime to Java Date to call it's getTime method > like the CSV adapter, then what value should we calculate from Java > LocalTime for SQL Time. > > > > > ------------------ Original ------------------ > From: "xiaobo ";<[email protected]>; > Send time: Thursday, Feb 24, 2022 12:26 PM > To: "dev"<[email protected]>; > > Subject: Re: dynamic reflective schema > > > > our adapter now supports > string,boolean,bigdecimal,long,localdate,localdatetime, and we want to > support localtime too, what value should we convert from localtime data , > the total seconds since the start of a day? > > > ---Original--- > From: "xiaobo "<[email protected]> > Date: Thu, Feb 24, 2022 12:20 PM > To: "dev"<[email protected]>; > Subject: Re: dynamic reflective schema > > yes, we call the > getRowType(RelDataTypeFactory typeFactory) method in scan method , is this > the correct way? > > > > ---Original--- > From: "Gavin Ray"<[email protected]> > Date: Thu, Feb 24, 2022 00:21 AM > To: "dev"<[email protected]>; > Subject: Re: dynamic reflective schema > > Xiabo, > > Your code seems to work for me, I ran the test case and it passes, see the > image below: > https://i.imgur.com/D0ajyQH.png > > > On Wed, Feb 23, 2022 at 2:33 AM xiaobo <[email protected]> > wrote: > > > we have put the test coding on github > > > > > > > https://github.com/guxiaobo/calcite-json-adapter/tree/main/src/test/java/org/apache/calcite/adapter/json/test > > > > > > > > > > > > ------------------ Original ------------------ > > From: "xiaobo ";<[email protected]>; > > Send time: Wednesday, Feb 23, 2022 3:11 PM > > To: "dev"<[email protected]>; > > > > Subject: Re: dynamic reflective schema > > > > > > > > here is the full output with calcite.debug=true, we know the problem is > > because the getRowType(RelDataTypeFactory typeFactory) method is not > > called by the framework, but don't know why. > > > > > > 2022-02-23 15:02:42.228 INFO 78585 --- [ main] > > c.x.javatest.JavaTestApplication : Starting JavaTestApplication > > using Java 11.0.13 on LindadeMacBook-Air.local with PID 78585 > > > (/Users/linda/Documents/Github/sw-smart-risk/sw-pbcm/sw-pbcm-test/java-test-proj/target/classes > > started by linda in > > > /Users/linda/Documents/Github/sw-smart-risk/sw-pbcm/sw-pbcm-test/java-test-proj) > > 2022-02-23 15:02:42.234 INFO 78585 --- [ main] > > c.x.javatest.JavaTestApplication : No active profile set, falling > > back to default profiles: default > > 2022-02-23 15:02:43.230 WARN 78585 --- [ main] > > o.m.s.mapper.ClassPathMapperScanner : No MyBatis mapper was found in > > '[com.xsmartware.javatest]' package. Please check your configuration. > > 2022-02-23 15:02:44.064 INFO 78585 --- [ main] > > o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with > port(s): > > 8080 (http) > > 2022-02-23 15:02:44.082 INFO 78585 --- [ main] > > o.apache.catalina.core.StandardService : Starting service [Tomcat] > > 2022-02-23 15:02:44.082 INFO 78585 --- [ main] > > org.apache.catalina.core.StandardEngine : Starting Servlet engine: > [Apache > > Tomcat/9.0.56] > > 2022-02-23 15:02:44.291 INFO 78585 --- [ main] > > o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded > > WebApplicationContext > > 2022-02-23 15:02:44.292 INFO 78585 --- [ main] > > w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: > > initialization completed in 1970 ms > > 2022-02-23 15:02:45.374 INFO 78585 --- [ main] > > o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): > 8080 > > (http) with context path '' > > 2022-02-23 15:02:45.393 INFO 78585 --- [ main] > > c.x.javatest.JavaTestApplication : Started JavaTestApplication in > > 3.77 seconds (JVM running for 5.146) > > /* > > * 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. > > */ > > package org.apache.calcite.rel.metadata.janino; > > > > public final class GeneratedMetadata_CollationHandler > > implements > > org.apache.calcite.rel.metadata.BuiltInMetadata.Collation.Handler { > > private final Object methodKey0 = > > new > > org.apache.calcite.rel.metadata.janino.DescriptiveCacheKey("ImmutableList > > Handler.collations()"); > > public final org.apache.calcite.rel.metadata.RelMdCollation provider0; > > public GeneratedMetadata_CollationHandler( > > org.apache.calcite.rel.metadata.RelMdCollation provider0) { > > this.provider0 = provider0; > > } > > public org.apache.calcite.rel.metadata.MetadataDef getDef() { > > return provider0.getDef(); > > } > > public com.google.common.collect.ImmutableList collations( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > while (r instanceof > > org.apache.calcite.rel.metadata.DelegatingMetadataRel) { > > r = ((org.apache.calcite.rel.metadata.DelegatingMetadataRel) > > r).getMetadataDelegateRel(); > > } > > final Object key; > > key = methodKey0; > > final Object v = mq.map.get(r, key); > > if (v != null) { > > if (v == org.apache.calcite.rel.metadata.NullSentinel.ACTIVE) { > > throw new > > org.apache.calcite.rel.metadata.CyclicMetadataException(); > > } > > if (v == org.apache.calcite.rel.metadata.NullSentinel.INSTANCE) { > > return null; > > } > > return (com.google.common.collect.ImmutableList) v; > > } > > mq.map.put(r, > key,org.apache.calcite.rel.metadata.NullSentinel.ACTIVE); > > try { > > final com.google.common.collect.ImmutableList x = collations_(r, > mq); > > mq.map.put(r, key, > > org.apache.calcite.rel.metadata.NullSentinel.mask(x)); > > return x; > > } catch (java.lang.Exception e) { > > mq.map.row(r).clear(); > > throw e; > > } > > } > > > > private com.google.common.collect.ImmutableList collations_( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > if (r instanceof > > org.apache.calcite.adapter.enumerable.EnumerableCorrelate) { > > return > > > provider0.collations((org.apache.calcite.adapter.enumerable.EnumerableCorrelate) > > r, mq); > > } else if (r instanceof > > org.apache.calcite.adapter.enumerable.EnumerableHashJoin) { > > return > > > provider0.collations((org.apache.calcite.adapter.enumerable.EnumerableHashJoin) > > r, mq); > > } else if (r instanceof > > org.apache.calcite.adapter.enumerable.EnumerableMergeJoin) { > > return > > > provider0.collations((org.apache.calcite.adapter.enumerable.EnumerableMergeJoin) > > r, mq); > > } else if (r instanceof > > org.apache.calcite.adapter.enumerable.EnumerableMergeUnion) { > > return > > > provider0.collations((org.apache.calcite.adapter.enumerable.EnumerableMergeUnion) > > r, mq); > > } else if (r instanceof > > org.apache.calcite.adapter.enumerable.EnumerableNestedLoopJoin) { > > return > > > provider0.collations((org.apache.calcite.adapter.enumerable.EnumerableNestedLoopJoin) > > r, mq); > > } else if (r instanceof > > org.apache.calcite.adapter.jdbc.JdbcToEnumerableConverter) { > > return > > > provider0.collations((org.apache.calcite.adapter.jdbc.JdbcToEnumerableConverter) > > r, mq); > > } else if (r instanceof org.apache.calcite.plan.hep.HepRelVertex) { > > return > > provider0.collations((org.apache.calcite.plan.hep.HepRelVertex) r, mq); > > } else if (r instanceof org.apache.calcite.plan.volcano.RelSubset) { > > return > > provider0.collations((org.apache.calcite.plan.volcano.RelSubset) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Calc) { > > return provider0.collations((org.apache.calcite.rel.core.Calc) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Filter) { > > return provider0.collations((org.apache.calcite.rel.core.Filter) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Match) { > > return provider0.collations((org.apache.calcite.rel.core.Match) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Project) { > > return provider0.collations((org.apache.calcite.rel.core.Project) > r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Sort) { > > return provider0.collations((org.apache.calcite.rel.core.Sort) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.SortExchange) { > > return > > provider0.collations((org.apache.calcite.rel.core.SortExchange) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.TableModify) { > > return > > provider0.collations((org.apache.calcite.rel.core.TableModify) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.TableScan) { > > return provider0.collations((org.apache.calcite.rel.core.TableScan) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Values) { > > return provider0.collations((org.apache.calcite.rel.core.Values) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Window) { > > return provider0.collations((org.apache.calcite.rel.core.Window) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.RelNode) { > > return provider0.collations((org.apache.calcite.rel.RelNode) r, > mq); > > } else { > > throw new java.lang.IllegalArgumentException("No handler for > > method [public abstract com.google.common.collect.ImmutableList > > > org.apache.calcite.rel.metadata.BuiltInMetadata$Collation$Handler.collations(org.apache.calcite.rel.RelNode,org.apache.calcite.rel.metadata.RelMetadataQuery)] > > applied to argument of type [" + r.getClass() + "]; we recommend you > create > > a catch-all (RelNode) handler"); > > } > > } > > > > } > > > > /* > > * 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. > > */ > > package org.apache.calcite.rel.metadata.janino; > > > > public final class GeneratedMetadata_NonCumulativeCostHandler > > implements > > > org.apache.calcite.rel.metadata.BuiltInMetadata.NonCumulativeCost.Handler { > > private final Object methodKey0 = > > new > > org.apache.calcite.rel.metadata.janino.DescriptiveCacheKey("RelOptCost > > Handler.getNonCumulativeCost()"); > > public final > > > org.apache.calcite.rel.metadata.RelMdPercentageOriginalRows$RelMdNonCumulativeCost > > provider0; > > public GeneratedMetadata_NonCumulativeCostHandler( > > > > > org.apache.calcite.rel.metadata.RelMdPercentageOriginalRows$RelMdNonCumulativeCost > > provider0) { > > this.provider0 = provider0; > > } > > public org.apache.calcite.rel.metadata.MetadataDef getDef() { > > return provider0.getDef(); > > } > > public org.apache.calcite.plan.RelOptCost getNonCumulativeCost( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > while (r instanceof > > org.apache.calcite.rel.metadata.DelegatingMetadataRel) { > > r = ((org.apache.calcite.rel.metadata.DelegatingMetadataRel) > > r).getMetadataDelegateRel(); > > } > > final Object key; > > key = methodKey0; > > final Object v = mq.map.get(r, key); > > if (v != null) { > > if (v == org.apache.calcite.rel.metadata.NullSentinel.ACTIVE) { > > throw new > > org.apache.calcite.rel.metadata.CyclicMetadataException(); > > } > > if (v == org.apache.calcite.rel.metadata.NullSentinel.INSTANCE) { > > return null; > > } > > return (org.apache.calcite.plan.RelOptCost) v; > > } > > mq.map.put(r, > key,org.apache.calcite.rel.metadata.NullSentinel.ACTIVE); > > try { > > final org.apache.calcite.plan.RelOptCost x = > > getNonCumulativeCost_(r, mq); > > mq.map.put(r, key, > > org.apache.calcite.rel.metadata.NullSentinel.mask(x)); > > return x; > > } catch (java.lang.Exception e) { > > mq.map.row(r).clear(); > > throw e; > > } > > } > > > > private org.apache.calcite.plan.RelOptCost getNonCumulativeCost_( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > if (r instanceof org.apache.calcite.rel.RelNode) { > > return > > provider0.getNonCumulativeCost((org.apache.calcite.rel.RelNode) r, mq); > > } else { > > throw new java.lang.IllegalArgumentException("No handler for > > method [public abstract org.apache.calcite.plan.RelOptCost > > > org.apache.calcite.rel.metadata.BuiltInMetadata$NonCumulativeCost$Handler.getNonCumulativeCost(org.apache.calcite.rel.RelNode,org.apache.calcite.rel.metadata.RelMetadataQuery)] > > applied to argument of type [" + r.getClass() + "]; we recommend you > create > > a catch-all (RelNode) handler"); > > } > > } > > > > } > > > > /* > > * 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. > > */ > > package org.apache.calcite.rel.metadata.janino; > > > > public final class GeneratedMetadata_NodeTypesHandler > > implements > > org.apache.calcite.rel.metadata.BuiltInMetadata.NodeTypes.Handler { > > private final Object methodKey0 = > > new > > org.apache.calcite.rel.metadata.janino.DescriptiveCacheKey("Multimap > > Handler.getNodeTypes()"); > > public final org.apache.calcite.rel.metadata.RelMdNodeTypes provider0; > > public GeneratedMetadata_NodeTypesHandler( > > org.apache.calcite.rel.metadata.RelMdNodeTypes provider0) { > > this.provider0 = provider0; > > } > > public org.apache.calcite.rel.metadata.MetadataDef getDef() { > > return provider0.getDef(); > > } > > public com.google.common.collect.Multimap getNodeTypes( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > while (r instanceof > > org.apache.calcite.rel.metadata.DelegatingMetadataRel) { > > r = ((org.apache.calcite.rel.metadata.DelegatingMetadataRel) > > r).getMetadataDelegateRel(); > > } > > final Object key; > > key = methodKey0; > > final Object v = mq.map.get(r, key); > > if (v != null) { > > if (v == org.apache.calcite.rel.metadata.NullSentinel.ACTIVE) { > > throw new > > org.apache.calcite.rel.metadata.CyclicMetadataException(); > > } > > if (v == org.apache.calcite.rel.metadata.NullSentinel.INSTANCE) { > > return null; > > } > > return (com.google.common.collect.Multimap) v; > > } > > mq.map.put(r, > key,org.apache.calcite.rel.metadata.NullSentinel.ACTIVE); > > try { > > final com.google.common.collect.Multimap x = getNodeTypes_(r, mq); > > mq.map.put(r, key, > > org.apache.calcite.rel.metadata.NullSentinel.mask(x)); > > return x; > > } catch (java.lang.Exception e) { > > mq.map.row(r).clear(); > > throw e; > > } > > } > > > > private com.google.common.collect.Multimap getNodeTypes_( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > if (r instanceof org.apache.calcite.plan.volcano.RelSubset) { > > return > > provider0.getNodeTypes((org.apache.calcite.plan.volcano.RelSubset) r, > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Aggregate) { > > return > > provider0.getNodeTypes((org.apache.calcite.rel.core.Aggregate) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Calc) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Calc) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Correlate) { > > return > > provider0.getNodeTypes((org.apache.calcite.rel.core.Correlate) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Exchange) { > > return > provider0.getNodeTypes((org.apache.calcite.rel.core.Exchange) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Filter) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Filter) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Intersect) { > > return > > provider0.getNodeTypes((org.apache.calcite.rel.core.Intersect) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Join) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Join) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Match) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Match) > r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Minus) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Minus) > r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Project) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Project) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Sample) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Sample) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Sort) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Sort) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.TableModify) { > > return > > provider0.getNodeTypes((org.apache.calcite.rel.core.TableModify) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.TableScan) { > > return > > provider0.getNodeTypes((org.apache.calcite.rel.core.TableScan) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Union) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Union) > r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Values) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Values) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Window) { > > return provider0.getNodeTypes((org.apache.calcite.rel.core.Window) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.RelNode) { > > return provider0.getNodeTypes((org.apache.calcite.rel.RelNode) r, > > mq); > > } else { > > throw new java.lang.IllegalArgumentException("No handler for > > method [public abstract com.google.common.collect.Multimap > > > org.apache.calcite.rel.metadata.BuiltInMetadata$NodeTypes$Handler.getNodeTypes(org.apache.calcite.rel.RelNode,org.apache.calcite.rel.metadata.RelMetadataQuery)] > > applied to argument of type [" + r.getClass() + "]; we recommend you > create > > a catch-all (RelNode) handler"); > > } > > } > > > > } > > > > /* > > * 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. > > */ > > package org.apache.calcite.rel.metadata.janino; > > > > public final class GeneratedMetadata_PredicatesHandler > > implements > > org.apache.calcite.rel.metadata.BuiltInMetadata.Predicates.Handler { > > private final Object methodKey0 = > > new > > > org.apache.calcite.rel.metadata.janino.DescriptiveCacheKey("RelOptPredicateList > > Handler.getPredicates()"); > > public final org.apache.calcite.rel.metadata.RelMdPredicates provider0; > > public GeneratedMetadata_PredicatesHandler( > > org.apache.calcite.rel.metadata.RelMdPredicates provider0) { > > this.provider0 = provider0; > > } > > public org.apache.calcite.rel.metadata.MetadataDef getDef() { > > return provider0.getDef(); > > } > > public org.apache.calcite.plan.RelOptPredicateList getPredicates( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > while (r instanceof > > org.apache.calcite.rel.metadata.DelegatingMetadataRel) { > > r = ((org.apache.calcite.rel.metadata.DelegatingMetadataRel) > > r).getMetadataDelegateRel(); > > } > > final Object key; > > key = methodKey0; > > final Object v = mq.map.get(r, key); > > if (v != null) { > > if (v == org.apache.calcite.rel.metadata.NullSentinel.ACTIVE) { > > throw new > > org.apache.calcite.rel.metadata.CyclicMetadataException(); > > } > > if (v == org.apache.calcite.rel.metadata.NullSentinel.INSTANCE) { > > return null; > > } > > return (org.apache.calcite.plan.RelOptPredicateList) v; > > } > > mq.map.put(r, > key,org.apache.calcite.rel.metadata.NullSentinel.ACTIVE); > > try { > > final org.apache.calcite.plan.RelOptPredicateList x = > > getPredicates_(r, mq); > > mq.map.put(r, key, > > org.apache.calcite.rel.metadata.NullSentinel.mask(x)); > > return x; > > } catch (java.lang.Exception e) { > > mq.map.row(r).clear(); > > throw e; > > } > > } > > > > private org.apache.calcite.plan.RelOptPredicateList getPredicates_( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > if (r instanceof org.apache.calcite.plan.volcano.RelSubset) { > > return > > provider0.getPredicates((org.apache.calcite.plan.volcano.RelSubset) r, > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Aggregate) { > > return > > provider0.getPredicates((org.apache.calcite.rel.core.Aggregate) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Exchange) { > > return > > provider0.getPredicates((org.apache.calcite.rel.core.Exchange) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Filter) { > > return provider0.getPredicates((org.apache.calcite.rel.core.Filter) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Intersect) { > > return > > provider0.getPredicates((org.apache.calcite.rel.core.Intersect) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Join) { > > return provider0.getPredicates((org.apache.calcite.rel.core.Join) > r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Minus) { > > return provider0.getPredicates((org.apache.calcite.rel.core.Minus) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Project) { > > return > provider0.getPredicates((org.apache.calcite.rel.core.Project) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Sort) { > > return provider0.getPredicates((org.apache.calcite.rel.core.Sort) > r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.TableModify) { > > return > > provider0.getPredicates((org.apache.calcite.rel.core.TableModify) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.TableScan) { > > return > > provider0.getPredicates((org.apache.calcite.rel.core.TableScan) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Union) { > > return provider0.getPredicates((org.apache.calcite.rel.core.Union) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.RelNode) { > > return provider0.getPredicates((org.apache.calcite.rel.RelNode) r, > > mq); > > } else { > > throw new java.lang.IllegalArgumentException("No handler for > > method [public abstract org.apache.calcite.plan.RelOptPredicateList > > > org.apache.calcite.rel.metadata.BuiltInMetadata$Predicates$Handler.getPredicates(org.apache.calcite.rel.RelNode,org.apache.calcite.rel.metadata.RelMetadataQuery)] > > applied to argument of type [" + r.getClass() + "]; we recommend you > create > > a catch-all (RelNode) handler"); > > } > > } > > > > } > > > > /* > > * 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. > > */ > > package org.apache.calcite.rel.metadata.janino; > > > > public final class GeneratedMetadata_RowCountHandler > > implements > > org.apache.calcite.rel.metadata.BuiltInMetadata.RowCount.Handler { > > private final Object methodKey0 = > > new > > org.apache.calcite.rel.metadata.janino.DescriptiveCacheKey("Double > > Handler.getRowCount()"); > > public final org.apache.calcite.rel.metadata.RelMdRowCount provider0; > > public GeneratedMetadata_RowCountHandler( > > org.apache.calcite.rel.metadata.RelMdRowCount provider0) { > > this.provider0 = provider0; > > } > > public org.apache.calcite.rel.metadata.MetadataDef getDef() { > > return provider0.getDef(); > > } > > public java.lang.Double getRowCount( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > while (r instanceof > > org.apache.calcite.rel.metadata.DelegatingMetadataRel) { > > r = ((org.apache.calcite.rel.metadata.DelegatingMetadataRel) > > r).getMetadataDelegateRel(); > > } > > final Object key; > > key = methodKey0; > > final Object v = mq.map.get(r, key); > > if (v != null) { > > if (v == org.apache.calcite.rel.metadata.NullSentinel.ACTIVE) { > > throw new > > org.apache.calcite.rel.metadata.CyclicMetadataException(); > > } > > if (v == org.apache.calcite.rel.metadata.NullSentinel.INSTANCE) { > > return null; > > } > > return (java.lang.Double) v; > > } > > mq.map.put(r, > key,org.apache.calcite.rel.metadata.NullSentinel.ACTIVE); > > try { > > final java.lang.Double x = getRowCount_(r, mq); > > mq.map.put(r, key, > > org.apache.calcite.rel.metadata.NullSentinel.mask(x)); > > return x; > > } catch (java.lang.Exception e) { > > mq.map.row(r).clear(); > > throw e; > > } > > } > > > > private java.lang.Double getRowCount_( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq) { > > if (r instanceof > > org.apache.calcite.adapter.enumerable.EnumerableLimit) { > > return > > > provider0.getRowCount((org.apache.calcite.adapter.enumerable.EnumerableLimit) > > r, mq); > > } else if (r instanceof org.apache.calcite.plan.volcano.RelSubset) { > > return > > provider0.getRowCount((org.apache.calcite.plan.volcano.RelSubset) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Aggregate) { > > return > provider0.getRowCount((org.apache.calcite.rel.core.Aggregate) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Calc) { > > return provider0.getRowCount((org.apache.calcite.rel.core.Calc) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Exchange) { > > return provider0.getRowCount((org.apache.calcite.rel.core.Exchange) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Filter) { > > return provider0.getRowCount((org.apache.calcite.rel.core.Filter) > r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Intersect) { > > return > provider0.getRowCount((org.apache.calcite.rel.core.Intersect) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Join) { > > return provider0.getRowCount((org.apache.calcite.rel.core.Join) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Minus) { > > return provider0.getRowCount((org.apache.calcite.rel.core.Minus) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Project) { > > return provider0.getRowCount((org.apache.calcite.rel.core.Project) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Sort) { > > return provider0.getRowCount((org.apache.calcite.rel.core.Sort) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.TableModify) { > > return > > provider0.getRowCount((org.apache.calcite.rel.core.TableModify) r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.TableScan) { > > return > provider0.getRowCount((org.apache.calcite.rel.core.TableScan) > > r, mq); > > } else if (r instanceof org.apache.calcite.rel.core.Union) { > > return provider0.getRowCount((org.apache.calcite.rel.core.Union) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.core.Values) { > > return provider0.getRowCount((org.apache.calcite.rel.core.Values) > r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.SingleRel) { > > return provider0.getRowCount((org.apache.calcite.rel.SingleRel) r, > > mq); > > } else if (r instanceof org.apache.calcite.rel.RelNode) { > > return provider0.getRowCount((org.apache.calcite.rel.RelNode) r, > mq); > > } else { > > throw new java.lang.IllegalArgumentException("No handler for > > method [public abstract java.lang.Double > > > org.apache.calcite.rel.metadata.BuiltInMetadata$RowCount$Handler.getRowCount(org.apache.calcite.rel.RelNode,org.apache.calcite.rel.metadata.RelMetadataQuery)] > > applied to argument of type [" + r.getClass() + "]; we recommend you > create > > a catch-all (RelNode) handler"); > > } > > } > > > > } > > > > /* > > * 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. > > */ > > package org.apache.calcite.rel.metadata.janino; > > > > public final class GeneratedMetadata_DistinctRowCountHandler > > implements > > org.apache.calcite.rel.metadata.BuiltInMetadata.DistinctRowCount.Handler > { > > private final Object methodKey0 = > > new > > org.apache.calcite.rel.metadata.janino.DescriptiveCacheKey("Double > > Handler.getDistinctRowCount(RelNode, RelMetadataQuery, ImmutableBitSet, > > RexNode)"); > > public final org.apache.calcite.rel.metadata.RelMdDistinctRowCount > > provider0; > > public GeneratedMetadata_DistinctRowCountHandler( > > org.apache.calcite.rel.metadata.RelMdDistinctRowCount provider0) { > > this.provider0 = provider0; > > } > > public org.apache.calcite.rel.metadata.MetadataDef getDef() { > > return provider0.getDef(); > > } > > public java.lang.Double getDistinctRowCount( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq, > > org.apache.calcite.util.ImmutableBitSet a2, > > org.apache.calcite.rex.RexNode a3) { > > while (r instanceof > > org.apache.calcite.rel.metadata.DelegatingMetadataRel) { > > r = ((org.apache.calcite.rel.metadata.DelegatingMetadataRel) > > r).getMetadataDelegateRel(); > > } > > final Object key; > > key = org.apache.calcite.runtime.FlatLists.of(methodKey0, > > org.apache.calcite.rel.metadata.NullSentinel.mask(a2), a3); > > final Object v = mq.map.get(r, key); > > if (v != null) { > > if (v == org.apache.calcite.rel.metadata.NullSentinel.ACTIVE) { > > throw new > > org.apache.calcite.rel.metadata.CyclicMetadataException(); > > } > > if (v == org.apache.calcite.rel.metadata.NullSentinel.INSTANCE) { > > return null; > > } > > return (java.lang.Double) v; > > } > > mq.map.put(r, > key,org.apache.calcite.rel.metadata.NullSentinel.ACTIVE); > > try { > > final java.lang.Double x = getDistinctRowCount_(r, mq, a2, a3); > > mq.map.put(r, key, > > org.apache.calcite.rel.metadata.NullSentinel.mask(x)); > > return x; > > } catch (java.lang.Exception e) { > > mq.map.row(r).clear(); > > throw e; > > } > > } > > > > private java.lang.Double getDistinctRowCount_( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq, > > org.apache.calcite.util.ImmutableBitSet a2, > > org.apache.calcite.rex.RexNode a3) { > > if (r instanceof org.apache.calcite.plan.volcano.RelSubset) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.plan.volcano.RelSubset) > > r, mq, a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Aggregate) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.core.Aggregate) r, > > mq, a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Exchange) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.core.Exchange) r, > mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Filter) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.core.Filter) r, mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Join) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.core.Join) r, mq, > a2, > > a3); > > } else if (r instanceof org.apache.calcite.rel.core.Project) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.core.Project) r, > mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Sort) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.core.Sort) r, mq, > a2, > > a3); > > } else if (r instanceof org.apache.calcite.rel.core.TableModify) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.core.TableModify) > r, > > mq, a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Union) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.core.Union) r, mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Values) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.core.Values) r, mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.RelNode) { > > return > > provider0.getDistinctRowCount((org.apache.calcite.rel.RelNode) r, mq, a2, > > a3); > > } else { > > throw new java.lang.IllegalArgumentException("No handler for > > method [public abstract java.lang.Double > > > org.apache.calcite.rel.metadata.BuiltInMetadata$DistinctRowCount$Handler.getDistinctRowCount(org.apache.calcite.rel.RelNode,org.apache.calcite.rel.metadata.RelMetadataQuery,org.apache.calcite.util.ImmutableBitSet,org.apache.calcite.rex.RexNode)] > > applied to argument of type [" + r.getClass() + "]; we recommend you > create > > a catch-all (RelNode) handler"); > > } > > } > > > > } > > > > /* > > * 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. > > */ > > package org.apache.calcite.rel.metadata.janino; > > > > public final class GeneratedMetadata_ColumnUniquenessHandler > > implements > > org.apache.calcite.rel.metadata.BuiltInMetadata.ColumnUniqueness.Handler > { > > private final Object methodKey0 = > > new > > org.apache.calcite.rel.metadata.janino.DescriptiveCacheKey("Boolean > > Handler.areColumnsUnique(RelNode, RelMetadataQuery, ImmutableBitSet, > > boolean)"); > > public final org.apache.calcite.rel.metadata.RelMdColumnUniqueness > > provider0; > > public GeneratedMetadata_ColumnUniquenessHandler( > > org.apache.calcite.rel.metadata.RelMdColumnUniqueness provider0) { > > this.provider0 = provider0; > > } > > public org.apache.calcite.rel.metadata.MetadataDef getDef() { > > return provider0.getDef(); > > } > > public java.lang.Boolean areColumnsUnique( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq, > > org.apache.calcite.util.ImmutableBitSet a2, > > boolean a3) { > > while (r instanceof > > org.apache.calcite.rel.metadata.DelegatingMetadataRel) { > > r = ((org.apache.calcite.rel.metadata.DelegatingMetadataRel) > > r).getMetadataDelegateRel(); > > } > > final Object key; > > key = org.apache.calcite.runtime.FlatLists.of(methodKey0, > > org.apache.calcite.rel.metadata.NullSentinel.mask(a2), a3); > > final Object v = mq.map.get(r, key); > > if (v != null) { > > if (v == org.apache.calcite.rel.metadata.NullSentinel.ACTIVE) { > > throw new > > org.apache.calcite.rel.metadata.CyclicMetadataException(); > > } > > if (v == org.apache.calcite.rel.metadata.NullSentinel.INSTANCE) { > > return null; > > } > > return (java.lang.Boolean) v; > > } > > mq.map.put(r, > key,org.apache.calcite.rel.metadata.NullSentinel.ACTIVE); > > try { > > final java.lang.Boolean x = areColumnsUnique_(r, mq, a2, a3); > > mq.map.put(r, key, > > org.apache.calcite.rel.metadata.NullSentinel.mask(x)); > > return x; > > } catch (java.lang.Exception e) { > > mq.map.row(r).clear(); > > throw e; > > } > > } > > > > private java.lang.Boolean areColumnsUnique_( > > org.apache.calcite.rel.RelNode r, > > org.apache.calcite.rel.metadata.RelMetadataQuery mq, > > org.apache.calcite.util.ImmutableBitSet a2, > > boolean a3) { > > if (r instanceof org.apache.calcite.plan.volcano.RelSubset) { > > return > > provider0.areColumnsUnique((org.apache.calcite.plan.volcano.RelSubset) r, > > mq, a2, a3); > > } else if (r instanceof org.apache.calcite.rel.convert.Converter) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.convert.Converter) r, > > mq, a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Aggregate) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.Aggregate) r, mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Calc) { > > return > provider0.areColumnsUnique((org.apache.calcite.rel.core.Calc) > > r, mq, a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Correlate) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.Correlate) r, mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Exchange) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.Exchange) r, mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Filter) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.Filter) r, mq, > a2, > > a3); > > } else if (r instanceof org.apache.calcite.rel.core.Intersect) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.Intersect) r, mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Join) { > > return > provider0.areColumnsUnique((org.apache.calcite.rel.core.Join) > > r, mq, a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Minus) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.Minus) r, mq, a2, > > a3); > > } else if (r instanceof org.apache.calcite.rel.core.Project) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.Project) r, mq, > a2, > > a3); > > } else if (r instanceof org.apache.calcite.rel.core.SetOp) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.SetOp) r, mq, a2, > > a3); > > } else if (r instanceof org.apache.calcite.rel.core.Sort) { > > return > provider0.areColumnsUnique((org.apache.calcite.rel.core.Sort) > > r, mq, a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.TableModify) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.TableModify) r, > mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.TableScan) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.TableScan) r, mq, > > a2, a3); > > } else if (r instanceof org.apache.calcite.rel.core.Values) { > > return > > provider0.areColumnsUnique((org.apache.calcite.rel.core.Values) r, mq, > a2, > > a3); > > } else if (r instanceof org.apache.calcite.rel.RelNode) { > > return provider0.areColumnsUnique((org.apache.calcite.rel.RelNode) > > r, mq, a2, a3); > > } else { > > throw new java.lang.IllegalArgumentException("No handler for > > method [public abstract java.lang.Boolean > > > org.apache.calcite.rel.metadata.BuiltInMetadata$ColumnUniqueness$Handler.areColumnsUnique(org.apache.calcite.rel.RelNode,org.apache.calcite.rel.metadata.RelMetadataQuery,org.apache.calcite.util.ImmutableBitSet,boolean)] > > applied to argument of type [" + r.getClass() + "]; we recommend you > create > > a catch-all (RelNode) handler"); > > } > > } > > > > } > > > > > > /* 1 */ public static class Record1_0 implements java.io.Serializable { > > /* 2 */ public long f0; > > /* 3 */ public Record1_0() {} > > /* 4 */ public boolean equals(Object o) { > > /* 5 */ if (this == o) { > > /* 6 */ return true; > > /* 7 */ } > > /* 8 */ if (!(o instanceof Record1_0)) { > > /* 9 */ return false; > > /* 10 */ } > > /* 11 */ return this.f0 == ((Record1_0) o).f0; > > /* 12 */ } > > /* 13 */ > > /* 14 */ public int hashCode() { > > /* 15 */ int h = 0; > > /* 16 */ h = org.apache.calcite.runtime.Utilities.hash(h, this.f0); > > /* 17 */ return h; > > /* 18 */ } > > /* 19 */ > > /* 20 */ public int compareTo(Record1_0 that) { > > /* 21 */ final int c; > > /* 22 */ c = org.apache.calcite.runtime.Utilities.compare(this.f0, > > that.f0); > > /* 23 */ if (c != 0) { > > /* 24 */ return c; > > /* 25 */ } > > /* 26 */ return 0; > > /* 27 */ } > > /* 28 */ > > /* 29 */ public String toString() { > > /* 30 */ return "{f0=" + this.f0 + "}"; > > /* 31 */ } > > /* 32 */ > > /* 33 */ } > > /* 34 */ > > /* 35 */ public org.apache.calcite.linq4j.Enumerable bind(final > > org.apache.calcite.DataContext root) { > > /* 36 */ java.util.List accumulatorAdders = new > java.util.LinkedList(); > > /* 37 */ accumulatorAdders.add(new > > org.apache.calcite.linq4j.function.Function2() { > > /* 38 */ public Record1_0 apply(Record1_0 acc, Object[] in) { > > /* 39 */ acc.f0++; > > /* 40 */ return acc; > > /* 41 */ } > > /* 42 */ public Record1_0 apply(Object acc, Object in) { > > /* 43 */ return apply( > > /* 44 */ (Record1_0) acc, > > /* 45 */ (Object[]) in); > > /* 46 */ } > > /* 47 */ } > > /* 48 */ ); > > /* 49 */ org.apache.calcite.adapter.enumerable.AggregateLambdaFactory > > lambdaFactory = new > > org.apache.calcite.adapter.enumerable.BasicAggregateLambdaFactory( > > /* 50 */ new org.apache.calcite.linq4j.function.Function0() { > > /* 51 */ public Object apply() { > > /* 52 */ long COUNTa0s0; > > /* 53 */ COUNTa0s0 = 0L; > > /* 54 */ Record1_0 record0; > > /* 55 */ record0 = new Record1_0(); > > /* 56 */ record0.f0 = COUNTa0s0; > > /* 57 */ return record0; > > /* 58 */ } > > /* 59 */ } > > /* 60 */ , > > /* 61 */ accumulatorAdders); > > /* 62 */ return > > > org.apache.calcite.linq4j.Linq4j.singletonEnumerable(org.apache.calcite.schema.Schemas.enumerable((org.apache.calcite.schema.ScannableTable) > > root.getRootSchema().getSubSchema("js").getTable("t1"), > > root).aggregate(lambdaFactory.accumulatorInitializer().apply(), > > lambdaFactory.accumulatorAdder(), > > lambdaFactory.singleGroupResultSelector(new > > org.apache.calcite.linq4j.function.Function1() { > > /* 63 */ public long apply(Record1_0 acc) { > > /* 64 */ return acc.f0; > > /* 65 */ } > > /* 66 */ public Object apply(Object acc) { > > /* 67 */ return apply( > > /* 68 */ (Record1_0) acc); > > /* 69 */ } > > /* 70 */ } > > /* 71 */ ))); > > /* 72 */ } > > /* 73 */ > > /* 74 */ > > /* 75 */ public Class getElementType() { > > /* 76 */ return long.class; > > /* 77 */ } > > /* 78 */ > > /* 79 */ > > 2022-02-23 15:02:59.636 INFO 78585 --- [ main] > > ConditionEvaluationReportLoggingListener : > > > > Error starting ApplicationContext. To display the conditions report > re-run > > your application with 'debug' enabled. > > 2022-02-23 15:02:59.703 ERROR 78585 --- [ main] > > o.s.boot.SpringApplication : Application run failed > > > > java.lang.IllegalStateException: Failed to execute ApplicationRunner > > at > > > org.springframework.boot.SpringApplication.callRunner(SpringApplication.java:761) > > ~[spring-boot-2.6.2.jar:2.6.2] > > at > > > org.springframework.boot.SpringApplication.callRunners(SpringApplication.java:748) > > ~[spring-boot-2.6.2.jar:2.6.2] > > at > > > org.springframework.boot.SpringApplication.run(SpringApplication.java:309) > > ~[spring-boot-2.6.2.jar:2.6.2] > > at > > > org.springframework.boot.SpringApplication.run(SpringApplication.java:1301) > > ~[spring-boot-2.6.2.jar:2.6.2] > > at > > > org.springframework.boot.SpringApplication.run(SpringApplication.java:1290) > > ~[spring-boot-2.6.2.jar:2.6.2] > > at > > > com.xsmartware.javatest.JavaTestApplication.main(JavaTestApplication.java:9) > > ~[classes/:na] > > Caused by: java.sql.SQLException: Error while executing SQL "select > > count(*) from js.t1": null > > at > > org.apache.calcite.avatica.Helper.createException(Helper.java:56) > > ~[avatica-core-1.20.0.jar:1.20.0] > > at > > org.apache.calcite.avatica.Helper.createException(Helper.java:41) > > ~[avatica-core-1.20.0.jar:1.20.0] > > at > > > org.apache.calcite.avatica.AvaticaStatement.executeInternal(AvaticaStatement.java:163) > > ~[avatica-core-1.20.0.jar:1.20.0] > > at > > > org.apache.calcite.avatica.AvaticaStatement.executeQuery(AvaticaStatement.java:227) > > ~[avatica-core-1.20.0.jar:1.20.0] > > at com.xsmartware.common.util.SQLUtil.exeGetLong(SQLUtil.java:42) > > ~[classes/:na] > > at > > com.xsmartware.javatest.calcite.CalCiteTest.test10(CalCiteTest.java:145) > > ~[classes/:na] > > at > > com.xsmartware.javatest.calcite.CalCiteTest.run(CalCiteTest.java:114) > > ~[classes/:na] > > at > > > org.springframework.boot.SpringApplication.callRunner(SpringApplication.java:758) > > ~[spring-boot-2.6.2.jar:2.6.2] > > ... 5 common frames omitted > > Caused by: java.lang.NullPointerException: null > > at > > > org.apache.calcite.adapter.json.JsonEnumerator.<init>(JsonEnumerator.java:49) > > ~[classes/:na] > > at > > > org.apache.calcite.adapter.json.JsonScannableTable$1.enumerator(JsonScannableTable.java:48) > > ~[classes/:na] > > at > > > org.apache.calcite.linq4j.EnumerableDefaults.aggregate(EnumerableDefaults.java:130) > > ~[calcite-linq4j-1.29.0.jar:1.29.0] > > at > > > org.apache.calcite.linq4j.DefaultEnumerable.aggregate(DefaultEnumerable.java:107) > > ~[calcite-linq4j-1.29.0.jar:1.29.0] > > at Baz.bind(Baz.java:62) ~[na:na] > > at > > > org.apache.calcite.jdbc.CalcitePrepare$CalciteSignature.enumerable(CalcitePrepare.java:363) > > ~[calcite-core-1.29.0.jar:1.29.0] > > at > > > org.apache.calcite.jdbc.CalciteConnectionImpl.enumerable(CalciteConnectionImpl.java:338) > > ~[calcite-core-1.29.0.jar:1.29.0] > > at > > > org.apache.calcite.jdbc.CalciteMetaImpl._createIterable(CalciteMetaImpl.java:578) > > ~[calcite-core-1.29.0.jar:1.29.0] > > at > > > org.apache.calcite.jdbc.CalciteMetaImpl.createIterable(CalciteMetaImpl.java:569) > > ~[calcite-core-1.29.0.jar:1.29.0] > > at > > > org.apache.calcite.avatica.AvaticaResultSet.execute(AvaticaResultSet.java:184) > > ~[avatica-core-1.20.0.jar:1.20.0] > > at > > > org.apache.calcite.jdbc.CalciteResultSet.execute(CalciteResultSet.java:64) > > ~[calcite-core-1.29.0.jar:1.29.0] > > at > > > org.apache.calcite.jdbc.CalciteResultSet.execute(CalciteResultSet.java:43) > > ~[calcite-core-1.29.0.jar:1.29.0] > > at > > > org.apache.calcite.avatica.AvaticaConnection$1.execute(AvaticaConnection.java:666) > > ~[avatica-core-1.20.0.jar:1.20.0] > > at > > > org.apache.calcite.jdbc.CalciteMetaImpl.prepareAndExecute(CalciteMetaImpl.java:638) > > ~[calcite-core-1.29.0.jar:1.29.0] > > at > > > org.apache.calcite.avatica.AvaticaConnection.prepareAndExecuteInternal(AvaticaConnection.java:674) > > ~[avatica-core-1.20.0.jar:1.20.0] > > at > > > org.apache.calcite.avatica.AvaticaStatement.executeInternal(AvaticaStatement.java:156) > > ~[avatica-core-1.20.0.jar:1.20.0] > > ... 10 common frames omitted > > > > > > > > > > > > ------------------ Original ------------------ > > From: "Julian Hyde";<[email protected]>; > > Send time: Wednesday, Feb 23, 2022 8:27 AM > > To: "dev"<[email protected]>; > > > > Subject: Re: dynamic reflective schema > > > > > > > > Every time I see "at Baz.bind” I am reminded that I should have chosen a > > better name for that class than ‘Baz’. :) > > > > I figured ‘it’s generated, no one is ever going to know its name’. How > > wrong I was. The stack traces are all over the internet. > > > > Julian > > > > > > > On Feb 22, 2022, at 3:32 PM, Scott Reynolds <[email protected]> > > wrote: > > > > > > Whenever I see "at Baz.bind(Unknown Source)" I am reminded how > important > > it > > > is, when debugging, to set the System Property calcite.debug = true > > > > > > https://github.com/apache/calcite/blob/a8a6569e6ba75efe9d5725c49338a7f181d3ab5c/core/src/main/java/org/apache/calcite/config/CalciteSystemProperty.java#L59 > > > > > > That will get you a good stack trace and will help you figure out the > > > generated code is attempting to do. > > > > > > On Tue, Feb 22, 2022 at 5:35 AM xiaobo <[email protected]> > > wrote: > > > > > >> we have static data conbination use cases , reflective shcema is > > the > > >> best choice! > > >> > > >> > > >> > > >> ---Original--- > > >> From: "Gavin Ray"<[email protected]> > > >> Date: Mon, Feb 21, 2022 01:52 AM > > >> To: "dev"<[email protected]>; > > >> Subject: Re: dynamic reflective schema > > >> > > >> > > >> Ah, you don't want to use ReflectiveSchema, it's a simple schema type > > meant > > >> for easily making test schemas > > >> > > >> You want to extend from "AbstractSchema" and override the function > > >> "Map<String, Table> getTableMap()" > > >> For the "Table" type, you probably want to use "JsonScannableTable" > > >> > > >> The CsvSchema example does exactly this, if you want to see an example > > >> implementation: > > >> > > >> > > > https://github.com/apache/calcite/blob/4bc916619fd286b2c0cc4d5c653c96a68801d74e/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvSchema.java#L69-L106 > > >> > > >> Hope this helps =) > > >> > > >> > > >> > > >> On Sat, Feb 19, 2022 at 11:03 PM xiaobo <[email protected] > > > > > >> wrote: > > >> > > >> > Hi, > > >> > When using reflectiveSchema we must define a static Java > > class > > >> for the > > >> > schema object, but in our use case the actual data to query is > > >> dynamic, > > >> > define JAVA class for each data combination is impossible, we > have > > an > > >> idea > > >> > that can we make a JSONSchema which accepts a Map<String, > > >> > List<JSONObject>>, so that each List will be mapped to a > > table > > >> , and each > > >> > JSONObject mapped to a row, JSONObject keys will be column names. > > Is > > >> there > > >> > anything similar with this? > > >> > > > >> > > > >> > Regards
