You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2022/01/10 13:36:37 UTC
[ignite-3] branch ignite-15212 updated (f435ba2 -> 265847b)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15212
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from f435ba2 Minors.
add 82d2e23 IGNITE-16185 Improve the interface of UserObjectMarshaller
add ca29c42 IGNITE-16117 Thin client: Convert async exceptions in sync APIs (#525)
add 663be6e IGNITE-16214 Bump version up to 1.28.0 - Fixes #527.
add 0595e40 IGNITE-16090 Query execution service should wait for distributed table being created (#520)
add 092946e IGNITE-15312 Enabled testPreVote test
add e2333ef IGNITE-15810 Rename ignite-calcite module to ignite-sql-engine at Ignite 3.0 (#532)
add 563df50 IGNITE-16162 Nullified resources when striped disruptor is stopped.
add 781122a IGNITE-16164 Implement (un)marshalling of arbitrary objects (#530)
add 265847b Merge branch 'main' into ignite-15212
No new revisions were added by this update.
Summary of changes:
modules/calcite/README.txt | 35 -
modules/calcite/pom.xml | 300 ---
modules/calcite/src/main/codegen/config.fmpp | 639 -----
.../processors/query/calcite/QueryCancel.java | 92 -
.../query/calcite/QueryCancelledException.java | 36 -
.../processors/query/calcite/QueryProcessor.java | 39 -
.../query/calcite/ResultFieldMetadata.java | 56 -
.../query/calcite/ResultSetMetadata.java | 30 -
.../processors/query/calcite/SqlCursor.java | 37 -
.../query/calcite/SqlQueryProcessor.java | 259 --
.../processors/query/calcite/SqlQueryType.java | 58 -
.../internal/processors/query/calcite/Stubs.java | 25 -
.../query/calcite/exec/AbstractIndexScan.java | 108 -
.../query/calcite/exec/ArrayRowHandler.java | 90 -
.../calcite/exec/ClosableIteratorsHolder.java | 177 --
.../query/calcite/exec/ExchangeService.java | 94 -
.../query/calcite/exec/ExchangeServiceImpl.java | 275 --
.../calcite/exec/ExecutionCancelledException.java | 27 -
.../query/calcite/exec/ExecutionContext.java | 355 ---
.../query/calcite/exec/ExecutionService.java | 45 -
.../query/calcite/exec/ExecutionServiceImpl.java | 874 ------
.../query/calcite/exec/LifecycleAware.java | 35 -
.../query/calcite/exec/LogicalRelImplementor.java | 725 -----
.../query/calcite/exec/MailboxRegistry.java | 97 -
.../query/calcite/exec/MailboxRegistryImpl.java | 197 --
.../query/calcite/exec/QueryTaskExecutor.java | 47 -
.../query/calcite/exec/QueryTaskExecutorImpl.java | 120 -
.../processors/query/calcite/exec/RowHandler.java | 79 -
.../query/calcite/exec/RuntimeHashIndex.java | 115 -
.../query/calcite/exec/RuntimeIndex.java | 28 -
.../query/calcite/exec/RuntimeSortedIndex.java | 219 --
.../query/calcite/exec/TableFunctionScan.java | 53 -
.../processors/query/calcite/exec/TreeIndex.java | 36 -
.../query/calcite/exec/ddl/DdlCommandHandler.java | 322 ---
.../query/calcite/exec/exp/BiScalar.java | 29 -
.../query/calcite/exec/exp/CallImplementor.java | 43 -
.../query/calcite/exec/exp/ConverterUtils.java | 462 ----
.../query/calcite/exec/exp/ExpressionFactory.java | 113 -
.../calcite/exec/exp/ExpressionFactoryImpl.java | 640 -----
.../calcite/exec/exp/IgniteBuiltInMethod.java | 41 -
.../query/calcite/exec/exp/IgniteSqlFunctions.java | 262 --
.../calcite/exec/exp/ImplementableFunction.java | 37 -
.../query/calcite/exec/exp/NotNullImplementor.java | 43 -
.../exec/exp/ReflectiveCallNotNullImplementor.java | 83 -
.../query/calcite/exec/exp/RexExecutorImpl.java | 212 --
.../query/calcite/exec/exp/RexImpTable.java | 2614 ------------------
.../query/calcite/exec/exp/RexToLixTranslator.java | 1375 ----------
.../processors/query/calcite/exec/exp/Scalar.java | 25 -
.../query/calcite/exec/exp/SingleScalar.java | 29 -
.../query/calcite/exec/exp/agg/Accumulator.java | 38 -
.../calcite/exec/exp/agg/AccumulatorWrapper.java | 32 -
.../query/calcite/exec/exp/agg/Accumulators.java | 1149 --------
.../calcite/exec/exp/agg/AccumulatorsFactory.java | 320 ---
.../query/calcite/exec/exp/agg/AggregateType.java | 33 -
.../query/calcite/exec/exp/agg/GroupKey.java | 114 -
.../query/calcite/exec/rel/AbstractNode.java | 206 --
.../query/calcite/exec/rel/AbstractSetOpNode.java | 367 ---
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 478 ----
.../query/calcite/exec/rel/Downstream.java | 45 -
.../query/calcite/exec/rel/FilterNode.java | 150 --
.../query/calcite/exec/rel/HashAggregateNode.java | 374 ---
.../processors/query/calcite/exec/rel/Inbox.java | 507 ----
.../query/calcite/exec/rel/IndexSpoolNode.java | 214 --
.../query/calcite/exec/rel/IntersectNode.java | 123 -
.../query/calcite/exec/rel/LimitNode.java | 142 -
.../processors/query/calcite/exec/rel/Mailbox.java | 45 -
.../query/calcite/exec/rel/MergeJoinNode.java | 1172 --------
.../query/calcite/exec/rel/MinusNode.java | 105 -
.../query/calcite/exec/rel/ModifyNode.java | 240 --
.../query/calcite/exec/rel/NestedLoopJoinNode.java | 864 ------
.../processors/query/calcite/exec/rel/Node.java | 82 -
.../processors/query/calcite/exec/rel/Outbox.java | 366 ---
.../query/calcite/exec/rel/ProjectNode.java | 93 -
.../query/calcite/exec/rel/RootNode.java | 286 --
.../query/calcite/exec/rel/ScanNode.java | 135 -
.../query/calcite/exec/rel/SingleNode.java | 36 -
.../query/calcite/exec/rel/SortAggregateNode.java | 309 ---
.../query/calcite/exec/rel/SortNode.java | 158 --
.../query/calcite/exec/rel/TableScanNode.java | 277 --
.../query/calcite/exec/rel/TableSpoolNode.java | 174 --
.../query/calcite/exec/rel/UnionAllNode.java | 104 -
.../calcite/extension/CatalogUpdateListener.java | 33 -
.../calcite/extension/ExternalConvention.java | 59 -
.../query/calcite/extension/SqlExtension.java | 154 --
.../query/calcite/externalize/RelInputEx.java | 36 -
.../query/calcite/externalize/RelJson.java | 906 -------
.../query/calcite/externalize/RelJsonReader.java | 367 ---
.../query/calcite/externalize/RelJsonWriter.java | 173 --
.../query/calcite/message/ErrorMessage.java | 45 -
.../message/ExecutionContextAwareMessage.java | 37 -
.../query/calcite/message/InboxCloseMessage.java | 45 -
.../query/calcite/message/MessageListener.java | 34 -
.../query/calcite/message/MessageService.java | 52 -
.../query/calcite/message/MessageServiceImpl.java | 164 --
.../query/calcite/message/OutboxCloseMessage.java | 45 -
.../message/QueryBatchAcknowledgeMessage.java | 37 -
.../query/calcite/message/QueryBatchMessage.java | 48 -
.../query/calcite/message/QueryStartRequest.java | 52 -
.../query/calcite/message/QueryStartResponse.java | 45 -
.../calcite/message/SqlQueryMessageGroup.java | 44 -
.../query/calcite/metadata/AffinityService.java | 34 -
.../query/calcite/metadata/ColocationGroup.java | 258 --
.../metadata/ColocationMappingException.java | 33 -
.../calcite/metadata/FragmentDescription.java | 90 -
.../query/calcite/metadata/FragmentMapping.java | 186 --
.../calcite/metadata/FragmentMappingException.java | 58 -
.../query/calcite/metadata/IgniteMdCollation.java | 648 -----
.../calcite/metadata/IgniteMdCumulativeCost.java | 134 -
.../calcite/metadata/IgniteMdDistinctRowCount.java | 57 -
.../calcite/metadata/IgniteMdDistribution.java | 114 -
.../calcite/metadata/IgniteMdFragmentMapping.java | 242 --
.../metadata/IgniteMdNonCumulativeCost.java | 55 -
.../metadata/IgniteMdPercentageOriginalRows.java | 176 --
.../query/calcite/metadata/IgniteMdPredicates.java | 54 -
.../query/calcite/metadata/IgniteMdRowCount.java | 152 --
.../calcite/metadata/IgniteMdSelectivity.java | 145 -
.../query/calcite/metadata/IgniteMetadata.java | 71 -
.../query/calcite/metadata/MappingService.java | 39 -
.../query/calcite/metadata/MappingServiceImpl.java | 63 -
.../calcite/metadata/NodeMappingException.java | 47 -
.../query/calcite/metadata/RelMetadataQueryEx.java | 101 -
.../query/calcite/metadata/RemoteException.java | 68 -
.../query/calcite/metadata/cost/IgniteCost.java | 244 --
.../calcite/metadata/cost/IgniteCostFactory.java | 107 -
.../calcite/prepare/AbstractMultiStepPlan.java | 109 -
.../processors/query/calcite/prepare/CacheKey.java | 86 -
.../processors/query/calcite/prepare/Cloner.java | 85 -
.../processors/query/calcite/prepare/DdlPlan.java | 48 -
.../query/calcite/prepare/ExecutionPlan.java | 43 -
.../query/calcite/prepare/ExplainPlan.java | 59 -
.../processors/query/calcite/prepare/Fragment.java | 177 --
.../query/calcite/prepare/FragmentPlan.java | 56 -
.../query/calcite/prepare/FragmentSplitter.java | 139 -
.../query/calcite/prepare/IdGenerator.java | 35 -
.../query/calcite/prepare/IgnitePlanner.java | 391 ---
.../query/calcite/prepare/IgnitePrograms.java | 80 -
.../query/calcite/prepare/IgniteRelShuttle.java | 254 --
.../query/calcite/prepare/IgniteSqlValidator.java | 358 ---
.../query/calcite/prepare/MappingQueryContext.java | 62 -
.../query/calcite/prepare/MultiStepDmlPlan.java | 41 -
.../query/calcite/prepare/MultiStepPlan.java | 59 -
.../query/calcite/prepare/MultiStepQueryPlan.java | 43 -
.../query/calcite/prepare/PlannerHelper.java | 250 --
.../query/calcite/prepare/PlannerPhase.java | 269 --
.../query/calcite/prepare/PlanningContext.java | 218 --
.../query/calcite/prepare/QueryPlan.java | 39 -
.../query/calcite/prepare/QueryPlanCache.java | 49 -
.../query/calcite/prepare/QueryPlanCacheImpl.java | 78 -
.../query/calcite/prepare/QueryPlanFactory.java | 32 -
.../query/calcite/prepare/QueryTemplate.java | 142 -
.../calcite/prepare/ResultFieldMetadataImpl.java | 90 -
.../calcite/prepare/ResultSetMetadataImpl.java | 79 -
.../calcite/prepare/ResultSetMetadataInternal.java | 32 -
.../processors/query/calcite/prepare/Splitter.java | 130 -
.../query/calcite/prepare/ValidationResult.java | 68 -
.../prepare/ddl/AbstractTableDdlCommand.java | 64 -
.../calcite/prepare/ddl/AlterTableAddCommand.java | 48 -
.../calcite/prepare/ddl/AlterTableDropCommand.java | 64 -
.../calcite/prepare/ddl/ColumnDefinition.java | 80 -
.../calcite/prepare/ddl/CreateIndexCommand.java | 96 -
.../calcite/prepare/ddl/CreateTableCommand.java | 124 -
.../query/calcite/prepare/ddl/DdlCommand.java | 22 -
.../prepare/ddl/DdlSqlToCommandConverter.java | 471 ----
.../calcite/prepare/ddl/DropIndexCommand.java | 47 -
.../calcite/prepare/ddl/DropTableCommand.java | 24 -
.../query/calcite/rel/AbstractIgniteJoin.java | 334 ---
.../query/calcite/rel/AbstractIgniteSpool.java | 51 -
.../query/calcite/rel/AbstractIndexScan.java | 173 --
.../query/calcite/rel/IgniteAggregate.java | 131 -
.../query/calcite/rel/IgniteConvention.java | 47 -
.../rel/IgniteCorrelatedNestedLoopJoin.java | 263 --
.../query/calcite/rel/IgniteExchange.java | 106 -
.../processors/query/calcite/rel/IgniteFilter.java | 155 --
.../query/calcite/rel/IgniteGateway.java | 144 -
.../query/calcite/rel/IgniteHashIndexSpool.java | 158 --
.../query/calcite/rel/IgniteIndexScan.java | 154 --
.../processors/query/calcite/rel/IgniteLimit.java | 213 --
.../query/calcite/rel/IgniteMergeJoin.java | 348 ---
.../query/calcite/rel/IgniteNestedLoopJoin.java | 120 -
.../query/calcite/rel/IgniteProject.java | 250 --
.../query/calcite/rel/IgniteReceiver.java | 150 --
.../processors/query/calcite/rel/IgniteRel.java | 92 -
.../query/calcite/rel/IgniteRelVisitor.java | 179 --
.../processors/query/calcite/rel/IgniteSender.java | 158 --
.../processors/query/calcite/rel/IgniteSort.java | 144 -
.../query/calcite/rel/IgniteSortedIndexSpool.java | 173 --
.../query/calcite/rel/IgniteTableFunctionScan.java | 90 -
.../query/calcite/rel/IgniteTableModify.java | 110 -
.../query/calcite/rel/IgniteTableScan.java | 145 -
.../query/calcite/rel/IgniteTableSpool.java | 98 -
.../query/calcite/rel/IgniteTrimExchange.java | 137 -
.../query/calcite/rel/IgniteUnionAll.java | 163 --
.../processors/query/calcite/rel/IgniteValues.java | 80 -
.../query/calcite/rel/InternalIgniteRel.java | 24 -
.../rel/ProjectableFilterableTableScan.java | 203 --
.../query/calcite/rel/SourceAwareIgniteRel.java | 27 -
.../calcite/rel/agg/IgniteHashAggregateBase.java | 47 -
.../calcite/rel/agg/IgniteMapAggregateBase.java | 100 -
.../calcite/rel/agg/IgniteMapHashAggregate.java | 118 -
.../calcite/rel/agg/IgniteMapSortAggregate.java | 154 --
.../calcite/rel/agg/IgniteReduceAggregateBase.java | 196 --
.../calcite/rel/agg/IgniteReduceHashAggregate.java | 127 -
.../calcite/rel/agg/IgniteReduceSortAggregate.java | 137 -
.../calcite/rel/agg/IgniteSingleAggregateBase.java | 101 -
.../calcite/rel/agg/IgniteSingleHashAggregate.java | 73 -
.../calcite/rel/agg/IgniteSingleSortAggregate.java | 118 -
.../calcite/rel/agg/IgniteSortAggregateBase.java | 74 -
.../rel/logical/IgniteLogicalIndexScan.java | 113 -
.../rel/logical/IgniteLogicalTableScan.java | 66 -
.../query/calcite/rel/set/IgniteIntersect.java | 70 -
.../query/calcite/rel/set/IgniteMapIntersect.java | 84 -
.../query/calcite/rel/set/IgniteMapMinus.java | 84 -
.../query/calcite/rel/set/IgniteMapSetOp.java | 112 -
.../query/calcite/rel/set/IgniteMinus.java | 77 -
.../query/calcite/rel/set/IgniteMinusBase.java | 104 -
.../calcite/rel/set/IgniteReduceIntersect.java | 99 -
.../query/calcite/rel/set/IgniteReduceMinus.java | 99 -
.../query/calcite/rel/set/IgniteReduceSetOp.java | 79 -
.../query/calcite/rel/set/IgniteSetOp.java | 79 -
.../calcite/rel/set/IgniteSingleIntersect.java | 73 -
.../query/calcite/rel/set/IgniteSingleMinus.java | 73 -
.../query/calcite/rel/set/IgniteSingleSetOp.java | 103 -
.../calcite/rule/AbstractIgniteConverterRule.java | 61 -
.../calcite/rule/CorrelateToNestedLoopRule.java | 132 -
.../calcite/rule/CorrelatedNestedLoopJoinRule.java | 215 --
.../query/calcite/rule/FilterConverterRule.java | 63 -
.../rule/FilterSpoolMergeToHashIndexSpoolRule.java | 137 -
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 124 -
.../calcite/rule/HashAggregateConverterRule.java | 115 -
.../calcite/rule/LogicalScanConverterRule.java | 185 --
.../query/calcite/rule/MergeJoinConverterRule.java | 75 -
.../query/calcite/rule/MinusConverterRule.java | 89 -
.../calcite/rule/NestedLoopJoinConverterRule.java | 56 -
.../query/calcite/rule/ProjectConverterRule.java | 55 -
.../query/calcite/rule/SetOpConverterRule.java | 176 --
.../calcite/rule/SortAggregateConverterRule.java | 143 -
.../query/calcite/rule/SortConverterRule.java | 87 -
.../rule/TableFunctionScanConverterRule.java | 87 -
.../calcite/rule/TableModifyConverterRule.java | 61 -
.../query/calcite/rule/UnionConverterRule.java | 96 -
.../query/calcite/rule/ValuesConverterRule.java | 57 -
.../calcite/rule/logical/ExposeIndexRule.java | 99 -
.../calcite/rule/logical/FilterScanMergeRule.java | 206 --
.../calcite/rule/logical/LogicalOrToUnionRule.java | 124 -
.../calcite/rule/logical/ProjectScanMergeRule.java | 246 --
.../query/calcite/schema/ColumnDescriptor.java | 42 -
.../query/calcite/schema/ColumnDescriptorImpl.java | 102 -
.../query/calcite/schema/IgniteIndex.java | 54 -
.../query/calcite/schema/IgniteSchema.java | 76 -
.../query/calcite/schema/IgniteTable.java | 124 -
.../query/calcite/schema/IgniteTableImpl.java | 337 ---
.../query/calcite/schema/InternalIgniteTable.java | 152 --
.../query/calcite/schema/SchemaHolder.java | 32 -
.../query/calcite/schema/SchemaHolderImpl.java | 184 --
.../query/calcite/schema/TableDescriptor.java | 111 -
.../query/calcite/schema/TableDescriptorImpl.java | 161 --
.../calcite/sql/IgniteAbstractSqlAlterTable.java | 90 -
.../calcite/sql/IgniteSqlAlterTableAddColumn.java | 73 -
.../calcite/sql/IgniteSqlAlterTableDropColumn.java | 79 -
.../query/calcite/sql/IgniteSqlConformance.java | 41 -
.../query/calcite/sql/IgniteSqlCreateIndex.java | 118 -
.../query/calcite/sql/IgniteSqlCreateTable.java | 115 -
.../calcite/sql/IgniteSqlCreateTableOption.java | 122 -
.../sql/IgniteSqlCreateTableOptionEnum.java | 29 -
.../query/calcite/sql/IgniteSqlDropIndex.java | 72 -
.../calcite/sql/fun/IgniteSqlOperatorTable.java | 60 -
.../calcite/sql/fun/SqlSystemRangeFunction.java | 63 -
.../query/calcite/trait/AffinityAdapter.java | 55 -
.../processors/query/calcite/trait/AllNodes.java | 44 -
.../query/calcite/trait/CorrelationTrait.java | 121 -
.../query/calcite/trait/CorrelationTraitDef.java | 60 -
.../query/calcite/trait/Destination.java | 38 -
.../query/calcite/trait/DistributionFunction.java | 310 ---
.../query/calcite/trait/DistributionTrait.java | 229 --
.../query/calcite/trait/DistributionTraitDef.java | 61 -
.../query/calcite/trait/IgniteDistribution.java | 54 -
.../query/calcite/trait/IgniteDistributions.java | 134 -
.../query/calcite/trait/Partitioned.java | 56 -
.../processors/query/calcite/trait/RandomNode.java | 54 -
.../processors/query/calcite/trait/RelFactory.java | 37 -
.../query/calcite/trait/RewindabilityTrait.java | 110 -
.../query/calcite/trait/RewindabilityTraitDef.java | 60 -
.../processors/query/calcite/trait/TraitUtils.java | 659 -----
.../query/calcite/trait/TraitsAwareIgniteRel.java | 163 --
.../query/calcite/type/IgniteTypeFactory.java | 291 --
.../query/calcite/type/IgniteTypeSystem.java | 41 -
.../query/calcite/util/AbstractQueryContext.java | 40 -
.../query/calcite/util/BaseQueryContext.java | 246 --
.../processors/query/calcite/util/Commons.java | 833 ------
.../query/calcite/util/FilteringIterator.java | 91 -
.../processors/query/calcite/util/HintUtils.java | 72 -
.../query/calcite/util/IgniteMethod.java | 82 -
.../query/calcite/util/IgniteResource.java | 40 -
.../query/calcite/util/IndexConditions.java | 151 --
.../query/calcite/util/NodeLeaveHandler.java | 50 -
.../processors/query/calcite/util/Primitives.java | 109 -
.../processors/query/calcite/util/RexUtils.java | 673 -----
.../query/calcite/util/TransformingIterator.java | 58 -
.../processors/query/calcite/util/TypeUtils.java | 392 ---
.../query/calcite/StopCalciteModuleTest.java | 216 --
.../calcite/exec/DdlWithMockedManagersTest.java | 453 ----
.../query/calcite/exec/RuntimeSortedIndexTest.java | 200 --
.../calcite/exec/exp/IgniteSqlFunctionsTest.java | 141 -
.../calcite/exec/rel/AbstractExecutionTest.java | 227 --
.../exec/rel/AbstractSetOpExecutionTest.java | 166 --
.../query/calcite/exec/rel/BaseAggregateTest.java | 566 ----
.../query/calcite/exec/rel/ExecutionTest.java | 689 -----
.../exec/rel/HashAggregateExecutionTest.java | 137 -
.../rel/HashAggregateSingleGroupExecutionTest.java | 484 ----
.../exec/rel/HashIndexSpoolExecutionTest.java | 161 --
.../calcite/exec/rel/IntersectExecutionTest.java | 83 -
.../calcite/exec/rel/MergeJoinExecutionTest.java | 375 ---
.../query/calcite/exec/rel/MinusExecutionTest.java | 83 -
.../exec/rel/NestedLoopJoinExecutionTest.java | 364 ---
.../exec/rel/SortAggregateExecutionTest.java | 145 -
.../exec/rel/SortedIndexSpoolExecutionTest.java | 189 --
.../calcite/exec/rel/TableSpoolExecutionTest.java | 156 --
.../planner/AbstractAggregatePlannerTest.java | 83 -
.../query/calcite/planner/AbstractPlannerTest.java | 888 -------
.../planner/AggregateDistinctPlannerTest.java | 124 -
.../calcite/planner/AggregatePlannerTest.java | 313 ---
.../CorrelatedNestedLoopJoinPlannerTest.java | 177 --
.../calcite/planner/HashAggregatePlannerTest.java | 134 -
.../calcite/planner/HashIndexSpoolPlannerTest.java | 237 --
.../calcite/planner/JoinColocationPlannerTest.java | 202 --
.../calcite/planner/JoinCommutePlannerTest.java | 206 --
.../calcite/planner/LimitOffsetPlannerTest.java | 203 --
.../calcite/planner/MergeJoinPlannerTest.java | 2799 --------------------
.../query/calcite/planner/PlannerTest.java | 841 ------
.../query/calcite/planner/SetOpPlannerTest.java | 444 ----
.../calcite/planner/SortAggregatePlannerTest.java | 168 --
.../planner/SortedIndexSpoolPlannerTest.java | 198 --
.../query/calcite/planner/TableDmlPlannerTest.java | 189 --
.../calcite/planner/TableFunctionPlannerTest.java | 124 -
.../calcite/planner/TableSpoolPlannerTest.java | 151 --
.../query/calcite/planner/UnionPlannerTest.java | 126 -
.../query/calcite/sql/SqlDdlParserTest.java | 304 ---
modules/client-handler/pom.xml | 2 +-
.../ignite/client/handler/ItClientHandlerTest.java | 2 +-
.../ignite/client/handler/ClientHandlerModule.java | 2 +-
.../handler/ClientInboundMessageHandler.java | 2 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 10 +-
.../handler/requests/sql/JdbcMetadataCatalog.java | 2 +-
.../org/apache/ignite/client/IgniteClient.java | 3 +-
.../apache/ignite/internal/client/ClientUtils.java | 62 +
.../client/table/ClientKeyValueBinaryView.java | 30 +-
.../internal/client/table/ClientKeyValueView.java | 29 +-
.../client/table/ClientRecordBinaryView.java | 32 +-
.../internal/client/table/ClientRecordView.java | 32 +-
.../ignite/internal/client/table/ClientTables.java | 12 +-
.../internal/client/tx/ClientTransaction.java | 6 +-
.../internal/client/tx/ClientTransactions.java | 4 +-
.../client/ClientKeyValueBinaryViewTest.java | 3 +-
.../ignite/client/ClientKeyValueViewTest.java | 6 +-
.../apache/ignite/client/ClientRecordViewTest.java | 6 +-
.../org/apache/ignite/client/ClientTableTest.java | 7 +-
.../org/apache/ignite/client/ReconnectTest.java | 5 +-
.../org/apache/ignite/client/fakes/FakeCursor.java | 6 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 2 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 4 +-
modules/network/pom.xml | 6 +
.../network/message/FieldDescriptorMessage.java | 5 +
.../network/serialization/BuiltinType.java | 6 +-
.../network/serialization/ClassDescriptor.java | 17 +-
.../serialization/ClassDescriptorFactory.java | 60 +-
.../ClassDescriptorFactoryContext.java | 53 +-
.../serialization/ClassIndexedDescriptors.java | 50 +
.../network/serialization/FieldAccessor.java | 39 +
.../network/serialization/FieldAccessorImpl.java | 83 +
.../network/serialization/FieldDescriptor.java | 46 +-
.../serialization/IdIndexedDescriptors.java | 60 +
.../MapBackedIdIndexedDescriptors.java | 39 +
.../PerSessionSerializationService.java | 19 +-
.../network/serialization/ReflectionException.java | 30 +
.../serialization/SerializationService.java | 8 +-
.../serialization/SerializedStreamCommands.java | 32 +
.../SpecialMethodInvocationException.java | 30 +
.../serialization/SpecialSerializationMethods.java | 51 +
.../SpecialSerializationMethodsImpl.java | 116 +
.../serialization/UserObjectSerializer.java | 2 +-
.../marshal/ArbitraryObjectMarshaller.java | 82 +
.../marshal/BestEffortInstantiation.java | 56 +
.../marshal/BuiltInContainerMarshallers.java | 161 +-
.../serialization/marshal/BuiltInMarshalling.java | 158 +-
.../marshal/BuiltInNonContainerMarshallers.java | 70 +-
.../marshal/DefaultUserObjectMarshaller.java | 371 ++-
.../marshal/ExternalizableMarshaller.java | 75 +
.../serialization/marshal/Instantiation.java | 42 +
.../marshal/InstantiationException.java | 34 +
.../serialization/marshal/MarshallingContext.java | 90 +
.../marshal/NoArgConstructorInstantiation.java | 50 +
.../serialization/marshal/ReflectionException.java | 30 -
.../marshal/SerializableInstantiation.java | 115 +
.../marshal/SpecialSerializationMethods.java | 151 --
.../marshal/SpecialSerializationMethodsCache.java | 33 -
.../serialization/marshal/TrackingMarshaller.java | 39 -
.../serialization/marshal/TypedValueWriter.java | 39 +
.../marshal/UnmarshallingContext.java | 69 +
.../serialization/marshal/UnsafeInstantiation.java | 42 +
.../marshal/UserObjectMarshaller.java | 7 +-
.../network/serialization/marshal/ValueReader.java | 5 +-
.../network/serialization/marshal/ValueWriter.java | 7 +-
.../serialization/ClassDescriptorFactoryTest.java | 31 +
.../MapBackedIdIndexedDescriptorsTest.java | 53 +
.../network/serialization/MarshallableTest.java | 6 +-
.../marshal/BestEffortInstantiationTest.java | 97 +
...erObjectMarshallerWithArbitraryObjectsTest.java | 504 ++++
...efaultUserObjectMarshallerWithBuiltinsTest.java | 237 +-
...UserObjectMarshallerWithExternalizableTest.java | 6 +-
.../marshal/MarshallingContextTest.java | 86 +
.../marshal/NoArgConstructorInstantiationTest.java | 62 +
.../marshal/SerializableInstantiationTest.java | 163 ++
.../marshal/UnsafeInstantiationTest.java | 53 +
.../marshal/WithAccessibleNoArgConstructor.java | 21 +
.../marshal/WithPrivateNoArgConstructor.java | 23 +
.../marshal/WithoutNoArgConstructor.java | 26 +
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 27 +-
.../raft/jraft/disruptor/StripedDisruptor.java | 19 +-
modules/runner/pom.xml | 2 +-
.../calcite/AbstractBasicIntegrationTest.java | 243 --
.../ignite/internal/calcite/ItAggregatesTest.java | 160 --
.../ignite/internal/calcite/ItDataTypesTest.java | 97 -
.../ignite/internal/calcite/ItFunctionsTest.java | 239 --
.../ignite/internal/calcite/ItIndexSpoolTest.java | 122 -
.../apache/ignite/internal/calcite/ItJoinTest.java | 758 ------
.../ignite/internal/calcite/ItMetadataTest.java | 108 -
.../internal/calcite/ItMixedQueriesTest.java | 410 ---
.../internal/calcite/ItOrToUnionRuleTest.java | 226 --
.../calcite/ItProjectScanMergeRuleTest.java | 158 --
.../internal/calcite/ItSecondaryIndexTest.java | 782 ------
.../ignite/internal/calcite/ItSetOpTest.java | 273 --
.../internal/calcite/ItSortAggregateTest.java | 101 -
.../internal/calcite/ItSqlExtensionTest.java | 69 -
.../internal/calcite/extension/TestExtension.java | 168 --
.../calcite/extension/TestFilterConverterRule.java | 59 -
.../internal/calcite/extension/TestPhysFilter.java | 143 -
.../calcite/extension/TestPhysTableScan.java | 78 -
.../internal/calcite/extension/TestTableImpl.java | 101 -
.../ignite/internal/calcite/util/Commons.java | 33 -
.../ignite/internal/calcite/util/QueryChecker.java | 480 ----
.../runner/app/ItTableApiContractTest.java | 2 +-
.../app/client/ItThinClientTransactionsTest.java | 14 +-
.../sql/engine/AbstractBasicIntegrationTest.java | 242 ++
.../internal/sql/engine/ItAggregatesTest.java | 160 ++
.../internal/sql/engine/ItDataTypesTest.java | 97 +
.../internal/sql/engine/ItFunctionsTest.java | 239 ++
.../internal/sql/engine/ItIndexSpoolTest.java | 120 +
.../ignite/internal/sql/engine/ItJoinTest.java | 758 ++++++
.../ignite/internal/sql/engine/ItMetadataTest.java | 107 +
.../internal/sql/engine/ItMixedQueriesTest.java | 410 +++
.../internal/sql/engine/ItOrToUnionRuleTest.java | 226 ++
.../sql/engine/ItProjectScanMergeRuleTest.java | 158 ++
.../internal/sql/engine/ItSecondaryIndexTest.java | 782 ++++++
.../ignite/internal/sql/engine/ItSetOpTest.java | 273 ++
.../internal/sql/engine/ItSortAggregateTest.java | 101 +
.../internal/sql/engine/ItSqlExtensionTest.java | 69 +
.../sql/engine/extension/TestExtension.java | 165 ++
.../engine/extension/TestFilterConverterRule.java | 59 +
.../sql/engine/extension/TestPhysFilter.java | 143 +
.../sql/engine/extension/TestPhysTableScan.java | 78 +
.../sql/engine/extension/TestTableImpl.java | 111 +
.../internal/sql/engine/util/CursorUtils.java | 33 +
.../internal/sql/engine/util/QueryChecker.java | 480 ++++
...processors.query.calcite.extension.SqlExtension | 1 -
...nite.internal.sql.engine.extension.SqlExtension | 1 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 4 +-
modules/sql-engine/README.txt | 35 +
modules/sql-engine/pom.xml | 305 +++
modules/sql-engine/src/main/codegen/config.fmpp | 639 +++++
.../src/main/codegen/includes/parserImpls.ftl | 0
.../apache/calcite/plan/volcano/VolcanoUtils.java | 0
.../apache/calcite/plan/volcano/package-info.java | 0
.../ignite/internal/sql/engine/QueryCancel.java | 92 +
.../sql/engine/QueryCancelledException.java | 36 +
.../ignite/internal/sql/engine/QueryProcessor.java | 39 +
.../internal/sql/engine/ResultFieldMetadata.java | 56 +
.../internal/sql/engine/ResultSetMetadata.java | 30 +
.../ignite/internal/sql/engine/SqlCursor.java | 37 +
.../internal/sql/engine/SqlQueryProcessor.java | 259 ++
.../ignite/internal/sql/engine/SqlQueryType.java | 58 +
.../apache/ignite/internal/sql/engine/Stubs.java | 25 +
.../sql/engine/exec/AbstractIndexScan.java | 108 +
.../internal/sql/engine/exec/ArrayRowHandler.java | 90 +
.../sql/engine/exec/ClosableIteratorsHolder.java | 177 ++
.../internal/sql/engine/exec/ExchangeService.java | 94 +
.../sql/engine/exec/ExchangeServiceImpl.java | 275 ++
.../engine/exec/ExecutionCancelledException.java | 27 +
.../internal/sql/engine/exec/ExecutionContext.java | 355 +++
.../internal/sql/engine/exec/ExecutionService.java | 45 +
.../sql/engine/exec/ExecutionServiceImpl.java | 874 ++++++
.../internal/sql/engine/exec/LifecycleAware.java | 35 +
.../sql/engine/exec/LogicalRelImplementor.java | 725 +++++
.../internal/sql/engine/exec/MailboxRegistry.java | 97 +
.../sql/engine/exec/MailboxRegistryImpl.java | 197 ++
.../sql/engine/exec/QueryTaskExecutor.java | 47 +
.../sql/engine/exec/QueryTaskExecutorImpl.java | 120 +
.../internal/sql/engine/exec/RowHandler.java | 79 +
.../internal/sql/engine/exec/RuntimeHashIndex.java | 115 +
.../internal/sql/engine/exec/RuntimeIndex.java | 28 +
.../sql/engine/exec/RuntimeSortedIndex.java | 219 ++
.../sql/engine/exec/TableFunctionScan.java | 53 +
.../ignite/internal/sql/engine/exec/TreeIndex.java | 36 +
.../sql/engine/exec/ddl/DdlCommandHandler.java | 322 +++
.../internal/sql/engine/exec/exp/BiScalar.java | 29 +
.../sql/engine/exec/exp/CallImplementor.java | 43 +
.../sql/engine/exec/exp/ConverterUtils.java | 462 ++++
.../sql/engine/exec/exp/ExpressionFactory.java | 113 +
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 640 +++++
.../sql/engine/exec/exp/IgniteBuiltInMethod.java | 41 +
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 262 ++
.../sql/engine/exec/exp/ImplementableFunction.java | 37 +
.../sql/engine/exec/exp/NotNullImplementor.java | 43 +
.../exec/exp/ReflectiveCallNotNullImplementor.java | 83 +
.../sql/engine/exec/exp/RexExecutorImpl.java | 212 ++
.../internal/sql/engine/exec/exp/RexImpTable.java | 2614 ++++++++++++++++++
.../sql/engine/exec/exp/RexToLixTranslator.java | 1375 ++++++++++
.../internal/sql/engine/exec/exp/Scalar.java | 25 +
.../internal/sql/engine/exec/exp/SingleScalar.java | 29 +
.../sql/engine/exec/exp/agg/Accumulator.java | 38 +
.../engine/exec/exp/agg/AccumulatorWrapper.java | 32 +
.../sql/engine/exec/exp/agg/Accumulators.java | 1149 ++++++++
.../engine/exec/exp/agg/AccumulatorsFactory.java | 320 +++
.../sql/engine/exec/exp/agg/AggregateType.java | 33 +
.../internal/sql/engine/exec/exp/agg/GroupKey.java | 114 +
.../internal/sql/engine/exec/rel/AbstractNode.java | 206 ++
.../sql/engine/exec/rel/AbstractSetOpNode.java | 367 +++
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 478 ++++
.../internal/sql/engine/exec/rel/Downstream.java | 45 +
.../internal/sql/engine/exec/rel/FilterNode.java | 150 ++
.../sql/engine/exec/rel/HashAggregateNode.java | 374 +++
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 507 ++++
.../sql/engine/exec/rel/IndexSpoolNode.java | 214 ++
.../sql/engine/exec/rel/IntersectNode.java | 123 +
.../internal/sql/engine/exec/rel/LimitNode.java | 142 +
.../internal/sql/engine/exec/rel/Mailbox.java | 45 +
.../sql/engine/exec/rel/MergeJoinNode.java | 1172 ++++++++
.../internal/sql/engine/exec/rel/MinusNode.java | 105 +
.../internal/sql/engine/exec/rel/ModifyNode.java | 240 ++
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 864 ++++++
.../ignite/internal/sql/engine/exec/rel/Node.java | 82 +
.../internal/sql/engine/exec/rel/Outbox.java | 366 +++
.../internal/sql/engine/exec/rel/ProjectNode.java | 93 +
.../internal/sql/engine/exec/rel/RootNode.java | 286 ++
.../internal/sql/engine/exec/rel/ScanNode.java | 135 +
.../internal/sql/engine/exec/rel/SingleNode.java | 36 +
.../sql/engine/exec/rel/SortAggregateNode.java | 309 +++
.../internal/sql/engine/exec/rel/SortNode.java | 158 ++
.../sql/engine/exec/rel/TableScanNode.java | 277 ++
.../sql/engine/exec/rel/TableSpoolNode.java | 174 ++
.../internal/sql/engine/exec/rel/UnionAllNode.java | 104 +
.../engine/extension/CatalogUpdateListener.java | 33 +
.../sql/engine/extension/ExternalConvention.java | 59 +
.../sql/engine/extension/SqlExtension.java | 154 ++
.../sql/engine/externalize/RelInputEx.java | 45 +
.../internal/sql/engine/externalize/RelJson.java | 906 +++++++
.../sql/engine/externalize/RelJsonReader.java | 382 +++
.../sql/engine/externalize/RelJsonWriter.java | 173 ++
.../internal/sql/engine/message/ErrorMessage.java | 45 +
.../message/ExecutionContextAwareMessage.java | 37 +
.../sql/engine/message/InboxCloseMessage.java | 45 +
.../sql/engine/message/MessageListener.java | 34 +
.../sql/engine/message/MessageService.java | 52 +
.../sql/engine/message/MessageServiceImpl.java | 164 ++
.../sql/engine/message/OutboxCloseMessage.java | 45 +
.../message/QueryBatchAcknowledgeMessage.java | 37 +
.../sql/engine/message/QueryBatchMessage.java | 48 +
.../sql/engine/message/QueryStartRequest.java | 52 +
.../sql/engine/message/QueryStartResponse.java | 45 +
.../sql/engine/message/SqlQueryMessageGroup.java | 44 +
.../sql/engine/metadata/AffinityService.java | 34 +
.../sql/engine/metadata/ColocationGroup.java | 258 ++
.../metadata/ColocationMappingException.java | 33 +
.../sql/engine/metadata/FragmentDescription.java | 90 +
.../sql/engine/metadata/FragmentMapping.java | 186 ++
.../engine/metadata/FragmentMappingException.java | 58 +
.../sql/engine/metadata/IgniteMdCollation.java | 648 +++++
.../engine/metadata/IgniteMdCumulativeCost.java | 134 +
.../engine/metadata/IgniteMdDistinctRowCount.java | 57 +
.../sql/engine/metadata/IgniteMdDistribution.java | 114 +
.../engine/metadata/IgniteMdFragmentMapping.java | 242 ++
.../engine/metadata/IgniteMdNonCumulativeCost.java | 55 +
.../metadata/IgniteMdPercentageOriginalRows.java | 176 ++
.../sql/engine/metadata/IgniteMdPredicates.java | 54 +
.../sql/engine/metadata/IgniteMdRowCount.java | 152 ++
.../sql/engine/metadata/IgniteMdSelectivity.java | 145 +
.../sql/engine/metadata/IgniteMetadata.java | 71 +
.../sql/engine/metadata/MappingService.java | 39 +
.../sql/engine/metadata/MappingServiceImpl.java | 63 +
.../sql/engine/metadata/NodeMappingException.java | 47 +
.../sql/engine/metadata/RelMetadataQueryEx.java | 101 +
.../sql/engine/metadata/RemoteException.java | 68 +
.../sql/engine/metadata/cost/IgniteCost.java | 244 ++
.../engine/metadata/cost/IgniteCostFactory.java | 107 +
.../sql/engine/prepare/AbstractMultiStepPlan.java | 109 +
.../internal/sql/engine/prepare/CacheKey.java | 86 +
.../ignite/internal/sql/engine/prepare/Cloner.java | 85 +
.../internal/sql/engine/prepare/DdlPlan.java | 48 +
.../internal/sql/engine/prepare/ExecutionPlan.java | 43 +
.../internal/sql/engine/prepare/ExplainPlan.java | 59 +
.../internal/sql/engine/prepare/Fragment.java | 177 ++
.../internal/sql/engine/prepare/FragmentPlan.java | 56 +
.../sql/engine/prepare/FragmentSplitter.java | 139 +
.../internal/sql/engine/prepare/IdGenerator.java | 35 +
.../internal/sql/engine/prepare/IgnitePlanner.java | 391 +++
.../sql/engine/prepare/IgnitePrograms.java | 80 +
.../sql/engine/prepare/IgniteRelShuttle.java | 254 ++
.../sql/engine/prepare/IgniteSqlValidator.java | 358 +++
.../sql/engine/prepare/MappingQueryContext.java | 62 +
.../sql/engine/prepare/MultiStepDmlPlan.java | 41 +
.../internal/sql/engine/prepare/MultiStepPlan.java | 59 +
.../sql/engine/prepare/MultiStepQueryPlan.java | 43 +
.../internal/sql/engine/prepare/PlannerHelper.java | 250 ++
.../internal/sql/engine/prepare/PlannerPhase.java | 269 ++
.../sql/engine/prepare/PlanningContext.java | 218 ++
.../internal/sql/engine/prepare/QueryPlan.java | 39 +
.../sql/engine/prepare/QueryPlanCache.java | 49 +
.../sql/engine/prepare/QueryPlanCacheImpl.java | 78 +
.../sql/engine/prepare/QueryPlanFactory.java | 32 +
.../internal/sql/engine/prepare/QueryTemplate.java | 142 +
.../engine/prepare/ResultFieldMetadataImpl.java | 90 +
.../sql/engine/prepare/ResultSetMetadataImpl.java | 79 +
.../engine/prepare/ResultSetMetadataInternal.java | 32 +
.../internal/sql/engine/prepare/Splitter.java | 130 +
.../sql/engine/prepare/ValidationResult.java | 68 +
.../prepare/ddl/AbstractTableDdlCommand.java | 64 +
.../engine/prepare/ddl/AlterTableAddCommand.java | 48 +
.../engine/prepare/ddl/AlterTableDropCommand.java | 64 +
.../sql/engine/prepare/ddl/ColumnDefinition.java | 80 +
.../sql/engine/prepare/ddl/CreateIndexCommand.java | 96 +
.../sql/engine/prepare/ddl/CreateTableCommand.java | 124 +
.../sql/engine/prepare/ddl/DdlCommand.java | 22 +
.../prepare/ddl/DdlSqlToCommandConverter.java | 471 ++++
.../sql/engine/prepare/ddl/DropIndexCommand.java | 47 +
.../sql/engine/prepare/ddl/DropTableCommand.java | 24 +
.../sql/engine/rel/AbstractIgniteJoin.java | 334 +++
.../sql/engine/rel/AbstractIgniteSpool.java | 51 +
.../internal/sql/engine/rel/AbstractIndexScan.java | 173 ++
.../internal/sql/engine/rel/IgniteAggregate.java | 131 +
.../internal/sql/engine/rel/IgniteConvention.java | 47 +
.../engine/rel/IgniteCorrelatedNestedLoopJoin.java | 263 ++
.../internal/sql/engine/rel/IgniteExchange.java | 106 +
.../internal/sql/engine/rel/IgniteFilter.java | 155 ++
.../internal/sql/engine/rel/IgniteGateway.java | 144 +
.../sql/engine/rel/IgniteHashIndexSpool.java | 158 ++
.../internal/sql/engine/rel/IgniteIndexScan.java | 154 ++
.../internal/sql/engine/rel/IgniteLimit.java | 213 ++
.../internal/sql/engine/rel/IgniteMergeJoin.java | 348 +++
.../sql/engine/rel/IgniteNestedLoopJoin.java | 120 +
.../internal/sql/engine/rel/IgniteProject.java | 250 ++
.../internal/sql/engine/rel/IgniteReceiver.java | 150 ++
.../ignite/internal/sql/engine/rel/IgniteRel.java | 92 +
.../internal/sql/engine/rel/IgniteRelVisitor.java | 179 ++
.../internal/sql/engine/rel/IgniteSender.java | 158 ++
.../ignite/internal/sql/engine/rel/IgniteSort.java | 144 +
.../sql/engine/rel/IgniteSortedIndexSpool.java | 173 ++
.../sql/engine/rel/IgniteTableFunctionScan.java | 90 +
.../internal/sql/engine/rel/IgniteTableModify.java | 122 +
.../internal/sql/engine/rel/IgniteTableScan.java | 145 +
.../internal/sql/engine/rel/IgniteTableSpool.java | 98 +
.../sql/engine/rel/IgniteTrimExchange.java | 137 +
.../internal/sql/engine/rel/IgniteUnionAll.java | 163 ++
.../internal/sql/engine/rel/IgniteValues.java | 80 +
.../internal/sql/engine/rel/InternalIgniteRel.java | 24 +
.../engine/rel/ProjectableFilterableTableScan.java | 215 ++
.../sql/engine/rel/SourceAwareIgniteRel.java | 27 +
.../engine/rel/agg/IgniteHashAggregateBase.java | 47 +
.../sql/engine/rel/agg/IgniteMapAggregateBase.java | 100 +
.../sql/engine/rel/agg/IgniteMapHashAggregate.java | 118 +
.../sql/engine/rel/agg/IgniteMapSortAggregate.java | 154 ++
.../engine/rel/agg/IgniteReduceAggregateBase.java | 196 ++
.../engine/rel/agg/IgniteReduceHashAggregate.java | 127 +
.../engine/rel/agg/IgniteReduceSortAggregate.java | 137 +
.../engine/rel/agg/IgniteSingleAggregateBase.java | 101 +
.../engine/rel/agg/IgniteSingleHashAggregate.java | 73 +
.../engine/rel/agg/IgniteSingleSortAggregate.java | 118 +
.../engine/rel/agg/IgniteSortAggregateBase.java | 74 +
.../engine/rel/logical/IgniteLogicalIndexScan.java | 113 +
.../engine/rel/logical/IgniteLogicalTableScan.java | 66 +
.../sql/engine/rel/set/IgniteIntersect.java | 70 +
.../sql/engine/rel/set/IgniteMapIntersect.java | 84 +
.../sql/engine/rel/set/IgniteMapMinus.java | 84 +
.../sql/engine/rel/set/IgniteMapSetOp.java | 112 +
.../internal/sql/engine/rel/set/IgniteMinus.java | 77 +
.../sql/engine/rel/set/IgniteMinusBase.java | 104 +
.../sql/engine/rel/set/IgniteReduceIntersect.java | 99 +
.../sql/engine/rel/set/IgniteReduceMinus.java | 99 +
.../sql/engine/rel/set/IgniteReduceSetOp.java | 79 +
.../internal/sql/engine/rel/set/IgniteSetOp.java | 79 +
.../sql/engine/rel/set/IgniteSingleIntersect.java | 73 +
.../sql/engine/rel/set/IgniteSingleMinus.java | 73 +
.../sql/engine/rel/set/IgniteSingleSetOp.java | 103 +
.../engine/rule/AbstractIgniteConverterRule.java | 61 +
.../sql/engine/rule/CorrelateToNestedLoopRule.java | 102 +
.../engine/rule/CorrelatedNestedLoopJoinRule.java | 161 ++
.../sql/engine/rule/FilterConverterRule.java | 63 +
.../rule/FilterSpoolMergeToHashIndexSpoolRule.java | 137 +
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 124 +
.../engine/rule/HashAggregateConverterRule.java | 115 +
.../sql/engine/rule/LogicalScanConverterRule.java | 185 ++
.../sql/engine/rule/MergeJoinConverterRule.java | 75 +
.../sql/engine/rule/MinusConverterRule.java | 89 +
.../engine/rule/NestedLoopJoinConverterRule.java | 56 +
.../sql/engine/rule/ProjectConverterRule.java | 55 +
.../sql/engine/rule/SetOpConverterRule.java | 176 ++
.../engine/rule/SortAggregateConverterRule.java | 143 +
.../sql/engine/rule/SortConverterRule.java | 87 +
.../rule/TableFunctionScanConverterRule.java | 66 +
.../sql/engine/rule/TableModifyConverterRule.java | 61 +
.../sql/engine/rule/UnionConverterRule.java | 96 +
.../sql/engine/rule/ValuesConverterRule.java | 57 +
.../sql/engine/rule/logical/ExposeIndexRule.java | 99 +
.../engine/rule/logical/FilterScanMergeRule.java | 206 ++
.../engine/rule/logical/LogicalOrToUnionRule.java | 124 +
.../engine/rule/logical/ProjectScanMergeRule.java | 246 ++
.../sql/engine/schema/ColumnDescriptor.java | 42 +
.../sql/engine/schema/ColumnDescriptorImpl.java | 102 +
.../internal/sql/engine/schema/IgniteIndex.java | 54 +
.../internal/sql/engine/schema/IgniteSchema.java | 76 +
.../internal/sql/engine/schema/IgniteTable.java | 132 +
.../sql/engine/schema/IgniteTableImpl.java | 345 +++
.../sql/engine/schema/InternalIgniteTable.java | 152 ++
.../sql/engine/schema/SqlSchemaManager.java | 42 +
.../sql/engine/schema/SqlSchemaManagerImpl.java | 236 ++
.../sql/engine/schema/TableDescriptor.java | 111 +
.../sql/engine/schema/TableDescriptorImpl.java | 161 ++
.../engine/sql/IgniteAbstractSqlAlterTable.java | 90 +
.../engine/sql/IgniteSqlAlterTableAddColumn.java | 73 +
.../engine/sql/IgniteSqlAlterTableDropColumn.java | 79 +
.../sql/engine/sql/IgniteSqlConformance.java | 41 +
.../sql/engine/sql/IgniteSqlCreateIndex.java | 118 +
.../sql/engine/sql/IgniteSqlCreateTable.java | 115 +
.../sql/engine/sql/IgniteSqlCreateTableOption.java | 122 +
.../engine/sql/IgniteSqlCreateTableOptionEnum.java | 29 +
.../sql/engine/sql/IgniteSqlDropIndex.java | 72 +
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 60 +
.../sql/engine/sql/fun/SqlSystemRangeFunction.java | 63 +
.../internal/sql/engine/trait/AffinityAdapter.java | 55 +
.../ignite/internal/sql/engine/trait/AllNodes.java | 44 +
.../sql/engine/trait/CorrelationTrait.java | 121 +
.../sql/engine/trait/CorrelationTraitDef.java | 60 +
.../internal/sql/engine/trait/Destination.java | 38 +
.../sql/engine/trait/DistributionFunction.java | 310 +++
.../sql/engine/trait/DistributionTrait.java | 229 ++
.../sql/engine/trait/DistributionTraitDef.java | 61 +
.../sql/engine/trait/IgniteDistribution.java | 54 +
.../sql/engine/trait/IgniteDistributions.java | 134 +
.../internal/sql/engine/trait/Partitioned.java | 56 +
.../internal/sql/engine/trait/RandomNode.java | 54 +
.../internal/sql/engine/trait/RelFactory.java | 37 +
.../sql/engine/trait/RewindabilityTrait.java | 110 +
.../sql/engine/trait/RewindabilityTraitDef.java | 60 +
.../internal/sql/engine/trait/TraitUtils.java | 543 ++++
.../sql/engine/trait/TraitsAwareIgniteRel.java | 163 ++
.../sql/engine/type/IgniteTypeFactory.java | 291 ++
.../internal/sql/engine/type/IgniteTypeSystem.java | 41 +
.../sql/engine/util/AbstractQueryContext.java | 40 +
.../internal/sql/engine/util/BaseQueryContext.java | 246 ++
.../ignite/internal/sql/engine/util/Commons.java | 833 ++++++
.../sql/engine/util/FilteringIterator.java | 91 +
.../ignite/internal/sql/engine/util/HintUtils.java | 72 +
.../internal/sql/engine/util/IgniteMethod.java | 82 +
.../internal/sql/engine/util/IgniteResource.java | 40 +
.../internal/sql/engine/util/IndexConditions.java | 151 ++
.../internal/sql/engine/util/NodeLeaveHandler.java | 50 +
.../internal/sql/engine/util/Primitives.java | 109 +
.../ignite/internal/sql/engine/util/RexUtils.java | 673 +++++
.../sql/engine/util/TransformingIterator.java | 58 +
.../ignite/internal/sql/engine/util/TypeUtils.java | 392 +++
.../internal/sql/engine/IgniteSqlApiTest.java | 389 +++
.../internal/sql/engine/StopCalciteModuleTest.java | 218 ++
.../apache/ignite/internal/sql/engine/TestRow.java | 269 ++
.../sql/engine/exec/DdlWithMockedManagersTest.java | 453 ++++
.../sql/engine/exec/RuntimeSortedIndexTest.java | 200 ++
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 141 +
.../sql/engine/exec/rel/AbstractExecutionTest.java | 227 ++
.../exec/rel/AbstractSetOpExecutionTest.java | 166 ++
.../sql/engine/exec/rel/BaseAggregateTest.java | 566 ++++
.../sql/engine/exec/rel/ExecutionTest.java | 689 +++++
.../exec/rel/HashAggregateExecutionTest.java | 137 +
.../rel/HashAggregateSingleGroupExecutionTest.java | 484 ++++
.../exec/rel/HashIndexSpoolExecutionTest.java | 161 ++
.../engine/exec/rel/IntersectExecutionTest.java | 83 +
.../engine/exec/rel/MergeJoinExecutionTest.java | 375 +++
.../sql/engine/exec/rel/MinusExecutionTest.java | 83 +
.../exec/rel/NestedLoopJoinExecutionTest.java | 364 +++
.../exec/rel/SortAggregateExecutionTest.java | 145 +
.../exec/rel/SortedIndexSpoolExecutionTest.java | 189 ++
.../engine/exec/rel/TableSpoolExecutionTest.java | 156 ++
.../sql/engine/externalize/RelJsonReaderTest.java | 75 +
.../planner/AbstractAggregatePlannerTest.java | 83 +
.../sql/engine/planner/AbstractPlannerTest.java | 910 +++++++
.../planner/AggregateDistinctPlannerTest.java | 124 +
.../sql/engine/planner/AggregatePlannerTest.java | 313 +++
.../CorrelatedNestedLoopJoinPlannerTest.java | 177 ++
.../engine/planner/HashAggregatePlannerTest.java | 134 +
.../engine/planner/HashIndexSpoolPlannerTest.java | 237 ++
.../engine/planner/JoinColocationPlannerTest.java | 202 ++
.../sql/engine/planner/JoinCommutePlannerTest.java | 206 ++
.../sql/engine/planner/LimitOffsetPlannerTest.java | 203 ++
.../sql/engine/planner/MergeJoinPlannerTest.java | 2799 ++++++++++++++++++++
.../internal/sql/engine/planner/PlannerTest.java | 841 ++++++
.../sql/engine/planner/SetOpPlannerTest.java | 444 ++++
.../engine/planner/SortAggregatePlannerTest.java | 168 ++
.../planner/SortedIndexSpoolPlannerTest.java | 198 ++
.../sql/engine/planner/TableDmlPlannerTest.java | 189 ++
.../engine/planner/TableFunctionPlannerTest.java | 124 +
.../sql/engine/planner/TableSpoolPlannerTest.java | 151 ++
.../sql/engine/planner/UnionPlannerTest.java | 126 +
.../internal/sql/engine/sql/SqlDdlParserTest.java | 304 +++
modules/sql/pom.xml | 65 -
modules/sql/src/test/java/IgniteSqlTest.java | 384 ---
modules/sql/src/test/java/TestRow.java | 269 --
parent/pom.xml | 15 +-
pom.xml | 3 +-
814 files changed, 69806 insertions(+), 67259 deletions(-)
delete mode 100644 modules/calcite/README.txt
delete mode 100644 modules/calcite/pom.xml
delete mode 100644 modules/calcite/src/main/codegen/config.fmpp
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/QueryCancel.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/QueryCancelledException.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/QueryProcessor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/ResultFieldMetadata.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/ResultSetMetadata.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlCursor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlQueryProcessor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlQueryType.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/Stubs.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/AbstractIndexScan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ArrayRowHandler.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolder.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeService.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeServiceImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionCancelledException.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionContext.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionService.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/LifecycleAware.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/LogicalRelImplementor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistry.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistryImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutorImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RowHandler.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RuntimeHashIndex.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RuntimeIndex.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RuntimeSortedIndex.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/TableFunctionScan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/TreeIndex.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ddl/DdlCommandHandler.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/BiScalar.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/CallImplementor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ConverterUtils.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactory.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactoryImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/IgniteBuiltInMethod.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/IgniteSqlFunctions.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ImplementableFunction.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/NotNullImplementor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ReflectiveCallNotNullImplementor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/RexExecutorImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/RexImpTable.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/RexToLixTranslator.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/Scalar.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/SingleScalar.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulator.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AccumulatorWrapper.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulators.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AccumulatorsFactory.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AggregateType.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/GroupKey.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractSetOpNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/CorrelatedNestedLoopJoinNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Downstream.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FilterNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Inbox.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/IndexSpoolNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/IntersectNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/LimitNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Mailbox.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/MergeJoinNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/MinusNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ModifyNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/NestedLoopJoinNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Node.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Outbox.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ProjectNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RootNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ScanNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SingleNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortAggregateNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TableScanNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TableSpoolNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/UnionAllNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/extension/CatalogUpdateListener.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/extension/ExternalConvention.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/extension/SqlExtension.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelInputEx.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJson.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonReader.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonWriter.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/ErrorMessage.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/ExecutionContextAwareMessage.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/InboxCloseMessage.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageListener.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageService.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/OutboxCloseMessage.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchAcknowledgeMessage.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchMessage.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartRequest.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartResponse.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/SqlQueryMessageGroup.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/AffinityService.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/ColocationGroup.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/ColocationMappingException.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/FragmentDescription.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/FragmentMapping.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/FragmentMappingException.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdCollation.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdCumulativeCost.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdDistinctRowCount.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdDistribution.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdFragmentMapping.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdNonCumulativeCost.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdPercentageOriginalRows.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdPredicates.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdRowCount.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdSelectivity.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMetadata.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingService.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingServiceImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/NodeMappingException.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/RelMetadataQueryEx.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/RemoteException.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/cost/IgniteCost.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/cost/IgniteCostFactory.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/AbstractMultiStepPlan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/CacheKey.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Cloner.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/DdlPlan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ExecutionPlan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ExplainPlan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Fragment.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentPlan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentSplitter.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IdGenerator.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgnitePlanner.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgnitePrograms.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgniteRelShuttle.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgniteSqlValidator.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MappingQueryContext.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepDmlPlan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepPlan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepQueryPlan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/PlannerHelper.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/PlannerPhase.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/PlanningContext.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCache.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCacheImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanFactory.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryTemplate.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ResultFieldMetadataImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ResultSetMetadataImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ResultSetMetadataInternal.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Splitter.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ValidationResult.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/AbstractTableDdlCommand.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/AlterTableAddCommand.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/AlterTableDropCommand.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/ColumnDefinition.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/CreateIndexCommand.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/CreateTableCommand.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/DdlCommand.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/DdlSqlToCommandConverter.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/DropIndexCommand.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ddl/DropTableCommand.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/AbstractIgniteJoin.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/AbstractIgniteSpool.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/AbstractIndexScan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteAggregate.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteConvention.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteCorrelatedNestedLoopJoin.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteExchange.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteFilter.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteGateway.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteHashIndexSpool.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteIndexScan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteLimit.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteMergeJoin.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteNestedLoopJoin.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteProject.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteReceiver.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteRel.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteRelVisitor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSender.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSort.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSortedIndexSpool.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableFunctionScan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableModify.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableScan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableSpool.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTrimExchange.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteUnionAll.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteValues.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/InternalIgniteRel.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/ProjectableFilterableTableScan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/SourceAwareIgniteRel.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteHashAggregateBase.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteMapAggregateBase.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteMapHashAggregate.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteMapSortAggregate.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteReduceAggregateBase.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteReduceHashAggregate.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteReduceSortAggregate.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteSingleAggregateBase.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteSingleHashAggregate.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteSingleSortAggregate.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/agg/IgniteSortAggregateBase.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/logical/IgniteLogicalIndexScan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/logical/IgniteLogicalTableScan.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteIntersect.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteMapIntersect.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteMapMinus.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteMapSetOp.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteMinus.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteMinusBase.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteReduceIntersect.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteReduceMinus.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteReduceSetOp.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteSetOp.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteSingleIntersect.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteSingleMinus.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteSingleSetOp.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/AbstractIgniteConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/CorrelateToNestedLoopRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/CorrelatedNestedLoopJoinRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/FilterConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/FilterSpoolMergeToHashIndexSpoolRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/FilterSpoolMergeToSortedIndexSpoolRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/HashAggregateConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/LogicalScanConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/MergeJoinConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/MinusConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/NestedLoopJoinConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/ProjectConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/SetOpConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/SortAggregateConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/SortConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/TableFunctionScanConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/TableModifyConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/UnionConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/ValuesConverterRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/logical/ExposeIndexRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/logical/FilterScanMergeRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/logical/LogicalOrToUnionRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/logical/ProjectScanMergeRule.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/ColumnDescriptor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/ColumnDescriptorImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteIndex.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteSchema.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTable.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTableImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/InternalIgniteTable.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/SchemaHolder.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/SchemaHolderImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptor.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptorImpl.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteAbstractSqlAlterTable.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlAlterTableAddColumn.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlAlterTableDropColumn.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlConformance.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlCreateIndex.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlCreateTable.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlCreateTableOption.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlCreateTableOptionEnum.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlDropIndex.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/fun/IgniteSqlOperatorTable.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/fun/SqlSystemRangeFunction.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/AffinityAdapter.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/AllNodes.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/CorrelationTrait.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/CorrelationTraitDef.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/Destination.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionFunction.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionTrait.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionTraitDef.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/IgniteDistribution.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/IgniteDistributions.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/Partitioned.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/RandomNode.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/RelFactory.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/RewindabilityTrait.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/RewindabilityTraitDef.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/TraitUtils.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/TraitsAwareIgniteRel.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeFactory.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeSystem.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/AbstractQueryContext.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/BaseQueryContext.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/Commons.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/FilteringIterator.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/HintUtils.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IgniteMethod.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IgniteResource.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IndexConditions.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/NodeLeaveHandler.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/Primitives.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/RexUtils.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/TransformingIterator.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/TypeUtils.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/StopCalciteModuleTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/DdlWithMockedManagersTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/RuntimeSortedIndexTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/IgniteSqlFunctionsTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractSetOpExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/BaseAggregateTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateSingleGroupExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashIndexSpoolExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/IntersectExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/MergeJoinExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/MinusExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/NestedLoopJoinExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortAggregateExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortedIndexSpoolExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TableSpoolExecutionTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/AbstractAggregatePlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/AbstractPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/AggregateDistinctPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/AggregatePlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/CorrelatedNestedLoopJoinPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/HashAggregatePlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/HashIndexSpoolPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/JoinColocationPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/JoinCommutePlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/LimitOffsetPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/MergeJoinPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/PlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/SetOpPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/SortAggregatePlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/SortedIndexSpoolPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/TableDmlPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/TableFunctionPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/TableSpoolPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/UnionPlannerTest.java
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/sql/SqlDdlParserTest.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/ClientUtils.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/ClassIndexedDescriptors.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/FieldAccessor.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/FieldAccessorImpl.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/IdIndexedDescriptors.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/MapBackedIdIndexedDescriptors.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/ReflectionException.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/SerializedStreamCommands.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/SpecialMethodInvocationException.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/SpecialSerializationMethods.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/SpecialSerializationMethodsImpl.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/ArbitraryObjectMarshaller.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/BestEffortInstantiation.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/ExternalizableMarshaller.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/Instantiation.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/InstantiationException.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/MarshallingContext.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/NoArgConstructorInstantiation.java
delete mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/ReflectionException.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/SerializableInstantiation.java
delete mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/SpecialSerializationMethods.java
delete mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/SpecialSerializationMethodsCache.java
delete mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/TrackingMarshaller.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/TypedValueWriter.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnmarshallingContext.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UnsafeInstantiation.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/MapBackedIdIndexedDescriptorsTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/BestEffortInstantiationTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshallerWithArbitraryObjectsTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/MarshallingContextTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/NoArgConstructorInstantiationTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/SerializableInstantiationTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/UnsafeInstantiationTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/WithAccessibleNoArgConstructor.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/WithPrivateNoArgConstructor.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/WithoutNoArgConstructor.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/AbstractBasicIntegrationTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItAggregatesTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItDataTypesTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItFunctionsTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItIndexSpoolTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItJoinTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItMetadataTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItMixedQueriesTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItOrToUnionRuleTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItProjectScanMergeRuleTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItSecondaryIndexTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItSetOpTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItSortAggregateTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItSqlExtensionTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestExtension.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestFilterConverterRule.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestPhysFilter.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestPhysTableScan.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/extension/TestTableImpl.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/util/Commons.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/util/QueryChecker.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/AbstractBasicIntegrationTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItAggregatesTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItDataTypesTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItFunctionsTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItIndexSpoolTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItJoinTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItMetadataTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItMixedQueriesTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItOrToUnionRuleTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItProjectScanMergeRuleTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSecondaryIndexTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSetOpTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSortAggregateTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlExtensionTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestExtension.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestFilterConverterRule.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestPhysFilter.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestPhysTableScan.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/extension/TestTableImpl.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/util/CursorUtils.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/util/QueryChecker.java
delete mode 100644 modules/runner/src/integrationTest/resources/META-INF/services/org.apache.ignite.internal.processors.query.calcite.extension.SqlExtension
create mode 100644 modules/runner/src/integrationTest/resources/META-INF/services/org.apache.ignite.internal.processors.query.calcite.org.apache.ignite.internal.sql.engine.extension.SqlExtension
create mode 100644 modules/sql-engine/README.txt
create mode 100644 modules/sql-engine/pom.xml
create mode 100644 modules/sql-engine/src/main/codegen/config.fmpp
rename modules/{calcite => sql-engine}/src/main/codegen/includes/parserImpls.ftl (100%)
rename modules/{calcite => sql-engine}/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java (100%)
rename modules/{calcite => sql-engine}/src/main/java/org/apache/calcite/plan/volcano/package-info.java (100%)
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryCancel.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryCancelledException.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryProcessor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/ResultFieldMetadata.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/ResultSetMetadata.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlCursor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryType.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/Stubs.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/AbstractIndexScan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ArrayRowHandler.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ClosableIteratorsHolder.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExchangeService.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExchangeServiceImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionCancelledException.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionContext.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionService.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/LifecycleAware.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/LogicalRelImplementor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/MailboxRegistry.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/MailboxRegistryImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/QueryTaskExecutor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/QueryTaskExecutorImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/RowHandler.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/RuntimeHashIndex.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/RuntimeIndex.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/RuntimeSortedIndex.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/TableFunctionScan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/TreeIndex.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ddl/DdlCommandHandler.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/BiScalar.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/CallImplementor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ConverterUtils.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ExpressionFactory.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ExpressionFactoryImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/IgniteBuiltInMethod.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/IgniteSqlFunctions.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ImplementableFunction.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/NotNullImplementor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ReflectiveCallNotNullImplementor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/RexExecutorImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/RexImpTable.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/RexToLixTranslator.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/Scalar.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/SingleScalar.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/Accumulator.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/AccumulatorWrapper.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/Accumulators.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/AccumulatorsFactory.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/AggregateType.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/GroupKey.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/AbstractNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/AbstractSetOpNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/CorrelatedNestedLoopJoinNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/Downstream.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/FilterNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/HashAggregateNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/Inbox.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/IndexSpoolNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/IntersectNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/LimitNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/Mailbox.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/MergeJoinNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/MinusNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/ModifyNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/NestedLoopJoinNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/Node.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/Outbox.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/ProjectNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/RootNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/ScanNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/SingleNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/SortAggregateNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/SortNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/TableScanNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/TableSpoolNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/UnionAllNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/extension/CatalogUpdateListener.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/extension/ExternalConvention.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/extension/SqlExtension.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/externalize/RelInputEx.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/externalize/RelJson.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/externalize/RelJsonReader.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/externalize/RelJsonWriter.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/ErrorMessage.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/ExecutionContextAwareMessage.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/InboxCloseMessage.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/MessageListener.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/MessageService.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/MessageServiceImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/OutboxCloseMessage.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/QueryBatchAcknowledgeMessage.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/QueryBatchMessage.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/QueryStartRequest.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/QueryStartResponse.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/SqlQueryMessageGroup.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/AffinityService.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/ColocationGroup.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/ColocationMappingException.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/FragmentDescription.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/FragmentMapping.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/FragmentMappingException.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdCollation.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdCumulativeCost.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdDistinctRowCount.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdDistribution.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdFragmentMapping.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdNonCumulativeCost.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdPercentageOriginalRows.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdPredicates.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdRowCount.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdSelectivity.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMetadata.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/MappingService.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/MappingServiceImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/NodeMappingException.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/RelMetadataQueryEx.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/RemoteException.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/cost/IgniteCost.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/cost/IgniteCostFactory.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/AbstractMultiStepPlan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/CacheKey.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/Cloner.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/DdlPlan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ExecutionPlan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ExplainPlan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/Fragment.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/FragmentPlan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/FragmentSplitter.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/IdGenerator.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/IgnitePlanner.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/IgnitePrograms.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/IgniteRelShuttle.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/IgniteSqlValidator.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/MappingQueryContext.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/MultiStepDmlPlan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/MultiStepPlan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/MultiStepQueryPlan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PlannerHelper.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PlannerPhase.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PlanningContext.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/QueryPlan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/QueryPlanCache.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/QueryPlanCacheImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/QueryPlanFactory.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/QueryTemplate.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ResultFieldMetadataImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ResultSetMetadataImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ResultSetMetadataInternal.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/Splitter.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ValidationResult.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/AbstractTableDdlCommand.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/AlterTableAddCommand.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/AlterTableDropCommand.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/ColumnDefinition.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/CreateIndexCommand.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/CreateTableCommand.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/DdlCommand.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/DdlSqlToCommandConverter.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/DropIndexCommand.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/DropTableCommand.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/AbstractIgniteJoin.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/AbstractIgniteSpool.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/AbstractIndexScan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteAggregate.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteConvention.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteCorrelatedNestedLoopJoin.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteExchange.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteFilter.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteGateway.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteHashIndexSpool.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteIndexScan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteLimit.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteMergeJoin.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteNestedLoopJoin.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteProject.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteReceiver.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteRel.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteRelVisitor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteSender.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteSort.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteSortedIndexSpool.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteTableFunctionScan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteTableModify.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteTableScan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteTableSpool.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteTrimExchange.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteUnionAll.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteValues.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/InternalIgniteRel.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/ProjectableFilterableTableScan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/SourceAwareIgniteRel.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteHashAggregateBase.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteMapAggregateBase.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteMapHashAggregate.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteMapSortAggregate.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteReduceAggregateBase.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteReduceHashAggregate.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteReduceSortAggregate.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteSingleAggregateBase.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteSingleHashAggregate.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteSingleSortAggregate.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/IgniteSortAggregateBase.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/logical/IgniteLogicalIndexScan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/logical/IgniteLogicalTableScan.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteIntersect.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteMapIntersect.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteMapMinus.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteMapSetOp.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteMinus.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteMinusBase.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteReduceIntersect.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteReduceMinus.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteReduceSetOp.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteSetOp.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteSingleIntersect.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteSingleMinus.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteSingleSetOp.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/AbstractIgniteConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/CorrelateToNestedLoopRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/CorrelatedNestedLoopJoinRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/FilterConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/FilterSpoolMergeToHashIndexSpoolRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/FilterSpoolMergeToSortedIndexSpoolRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/HashAggregateConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/LogicalScanConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/MergeJoinConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/MinusConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/NestedLoopJoinConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/ProjectConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/SetOpConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/SortAggregateConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/SortConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/TableFunctionScanConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/TableModifyConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/UnionConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/ValuesConverterRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/logical/ExposeIndexRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/logical/FilterScanMergeRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/logical/LogicalOrToUnionRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/logical/ProjectScanMergeRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/ColumnDescriptor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/ColumnDescriptorImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/IgniteIndex.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/IgniteSchema.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/IgniteTable.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/IgniteTableImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/InternalIgniteTable.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/SqlSchemaManager.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/SqlSchemaManagerImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/TableDescriptor.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/TableDescriptorImpl.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteAbstractSqlAlterTable.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlAlterTableAddColumn.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlAlterTableDropColumn.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlConformance.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlCreateIndex.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlCreateTable.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlCreateTableOption.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlCreateTableOptionEnum.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlDropIndex.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/fun/IgniteSqlOperatorTable.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/fun/SqlSystemRangeFunction.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/AffinityAdapter.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/AllNodes.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/CorrelationTrait.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/CorrelationTraitDef.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/Destination.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/DistributionFunction.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/DistributionTrait.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/DistributionTraitDef.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/IgniteDistribution.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/IgniteDistributions.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/Partitioned.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/RandomNode.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/RelFactory.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/RewindabilityTrait.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/RewindabilityTraitDef.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/TraitUtils.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/TraitsAwareIgniteRel.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/type/IgniteTypeFactory.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/type/IgniteTypeSystem.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/AbstractQueryContext.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/BaseQueryContext.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/Commons.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/FilteringIterator.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/HintUtils.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/IgniteMethod.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/IgniteResource.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/IndexConditions.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/NodeLeaveHandler.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/Primitives.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/RexUtils.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/TransformingIterator.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/TypeUtils.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/IgniteSqlApiTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/StopCalciteModuleTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/TestRow.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/DdlWithMockedManagersTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/RuntimeSortedIndexTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/exp/IgniteSqlFunctionsTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/AbstractExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/AbstractSetOpExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/BaseAggregateTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/ExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/HashAggregateExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/HashAggregateSingleGroupExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/HashIndexSpoolExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/IntersectExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/MergeJoinExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/MinusExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/NestedLoopJoinExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/SortAggregateExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/SortedIndexSpoolExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/TableSpoolExecutionTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/externalize/RelJsonReaderTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/AbstractAggregatePlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/AbstractPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/AggregateDistinctPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/AggregatePlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/CorrelatedNestedLoopJoinPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/HashAggregatePlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/HashIndexSpoolPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/JoinColocationPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/JoinCommutePlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/LimitOffsetPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/MergeJoinPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/PlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/SetOpPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/SortAggregatePlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/SortedIndexSpoolPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/TableDmlPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/TableFunctionPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/TableSpoolPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/UnionPlannerTest.java
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/sql/SqlDdlParserTest.java
delete mode 100644 modules/sql/pom.xml
delete mode 100644 modules/sql/src/test/java/IgniteSqlTest.java
delete mode 100644 modules/sql/src/test/java/TestRow.java