korlov42 commented on a change in pull request #9369:
URL: https://github.com/apache/ignite/pull/9369#discussion_r702901070
##########
File path:
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/PlanningContext.java
##########
@@ -17,131 +17,50 @@
package org.apache.ignite.internal.processors.query.calcite.prepare;
-import java.util.Properties;
-import java.util.UUID;
import java.util.function.Function;
-import org.apache.calcite.config.CalciteConnectionConfig;
-import org.apache.calcite.config.CalciteConnectionConfigImpl;
-import org.apache.calcite.config.CalciteConnectionProperty;
-import org.apache.calcite.jdbc.CalciteSchema;
import org.apache.calcite.plan.Context;
import org.apache.calcite.plan.Contexts;
import org.apache.calcite.plan.RelOptCluster;
import org.apache.calcite.prepare.CalciteCatalogReader;
-import org.apache.calcite.rel.type.RelDataTypeSystem;
+import org.apache.calcite.rex.RexBuilder;
import org.apache.calcite.schema.SchemaPlus;
import org.apache.calcite.sql.SqlOperatorTable;
import org.apache.calcite.sql.validate.SqlConformance;
import org.apache.calcite.tools.FrameworkConfig;
-import org.apache.calcite.tools.Frameworks;
import org.apache.calcite.tools.RuleSet;
-import org.apache.ignite.IgniteLogger;
-import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
-import org.apache.ignite.internal.processors.query.GridQueryCancel;
import
org.apache.ignite.internal.processors.query.calcite.type.IgniteTypeFactory;
-import org.apache.ignite.logger.NullLogger;
import org.jetbrains.annotations.NotNull;
-import static org.apache.calcite.tools.Frameworks.createRootSchema;
-import static
org.apache.ignite.internal.processors.query.calcite.CalciteQueryProcessor.FRAMEWORK_CONFIG;
-
/**
* Planning context.
*/
public final class PlanningContext implements Context {
- /** */
- private static final PlanningContext EMPTY = builder().build();
-
- /** */
- private final FrameworkConfig cfg;
-
/** */
private final Context parentCtx;
- /** */
- private final UUID locNodeId;
-
- /** */
- private final UUID originatingNodeId;
-
/** */
private final String qry;
/** */
private final Object[] parameters;
- /** */
- private final AffinityTopologyVersion topVer;
-
- /** */
- private final GridQueryCancel qryCancel;
-
- /** */
- private final IgniteLogger log;
-
- /** */
- private final IgniteTypeFactory typeFactory;
-
/** */
private Function<RuleSet, RuleSet> rulesFilter;
/** */
private IgnitePlanner planner;
- /** */
- private CalciteConnectionConfig connCfg;
-
- /** */
- private CalciteCatalogReader catalogReader;
-
/**
* Private constructor, used by a builder.
*/
private PlanningContext(
- FrameworkConfig cfg,
Context parentCtx,
- UUID locNodeId,
- UUID originatingNodeId,
String qry,
- Object[] parameters,
- AffinityTopologyVersion topVer,
- IgniteLogger log) {
- this.locNodeId = locNodeId;
- this.originatingNodeId = originatingNodeId;
+ Object[] parameters) {
this.qry = qry;
Review comment:
```suggestion
Object[] parameters
) {
this.qry = qry;
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
