This is an automated email from the ASF dual-hosted git repository.
korlov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from e368dc7e84 IGNITE-18609 .NET: Add ContainsKey method to Record API
(#1637)
add c308b68486 IGNITE-18213 Sql. Make exchange rewindable (#1617)
No new revisions were added by this update.
Summary of changes:
.../org/apache/ignite/client/fakes/FakeCursor.java | 3 +-
.../internal/sql/engine/ItCorrelatesTest.java | 23 +-
.../ignite/internal/sql/engine/ItJoinTest.java | 8 +-
.../ignite/internal/sql/engine/SqlCursor.java | 38 ---
.../internal/sql/engine/exec/ExchangeService.java | 6 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 13 +-
.../internal/sql/engine/exec/ExecutionContext.java | 33 ++-
.../sql/engine/exec/ExecutionServiceImpl.java | 3 +-
.../internal/sql/engine/exec/SharedState.java | 57 +++++
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 4 +-
.../sql/engine/exec/rel/AsyncRootNode.java | 2 +
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 7 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 88 +++++--
.../internal/sql/engine/exec/rel/Outbox.java | 47 ++--
.../internal/sql/engine/externalize/RelJson.java | 4 +-
.../engine/message/QueryBatchRequestMessage.java | 7 +
.../sql/engine/metadata/FragmentDescription.java | 41 ++--
.../engine/metadata/IgniteMdFragmentMapping.java | 8 +-
.../sql/engine/prepare/AbstractMultiStepPlan.java | 5 +-
.../ignite/internal/sql/engine/prepare/Cloner.java | 3 +-
.../internal/sql/engine/prepare/Fragment.java | 36 ++-
.../sql/engine/prepare/FragmentSplitter.java | 40 +++-
.../sql/engine/prepare/MappingQueryContext.java | 13 +-
.../internal/sql/engine/prepare/MultiStepPlan.java | 3 +-
.../internal/sql/engine/prepare/QueryTemplate.java | 11 +-
.../internal/sql/engine/prepare/Splitter.java | 34 ++-
.../sql/engine/rel/AbstractIgniteJoin.java | 39 ---
.../sql/engine/rel/AbstractIgniteSpool.java | 2 +-
.../internal/sql/engine/rel/AbstractIndexScan.java | 21 +-
.../internal/sql/engine/rel/IgniteAggregate.java | 2 +-
.../internal/sql/engine/rel/IgniteConvention.java | 2 +-
.../engine/rel/IgniteCorrelatedNestedLoopJoin.java | 79 -------
.../internal/sql/engine/rel/IgniteExchange.java | 2 +-
.../internal/sql/engine/rel/IgniteFilter.java | 48 ----
.../internal/sql/engine/rel/IgniteGateway.java | 144 -----------
.../sql/engine/rel/IgniteHashIndexSpool.java | 9 +
.../internal/sql/engine/rel/IgniteLimit.java | 12 +-
.../internal/sql/engine/rel/IgniteProject.java | 47 ----
.../internal/sql/engine/rel/IgniteReceiver.java | 2 +-
.../ignite/internal/sql/engine/rel/IgniteRel.java | 16 --
.../internal/sql/engine/rel/IgniteSender.java | 2 +-
.../ignite/internal/sql/engine/rel/IgniteSort.java | 2 +-
.../sql/engine/rel/IgniteSortedIndexSpool.java | 11 +-
.../sql/engine/rel/IgniteTableFunctionScan.java | 55 ++++-
.../internal/sql/engine/rel/IgniteTableModify.java | 2 +-
.../internal/sql/engine/rel/IgniteTableScan.java | 6 +-
.../internal/sql/engine/rel/IgniteTableSpool.java | 2 +-
.../internal/sql/engine/rel/IgniteUnionAll.java | 34 ---
.../internal/sql/engine/rel/IgniteValues.java | 54 ++++-
.../internal/sql/engine/rel/InternalIgniteRel.java | 24 --
.../engine/rel/ProjectableFilterableTableScan.java | 9 +
.../sql/engine/rel/SourceAwareIgniteRel.java | 2 +-
.../rel/agg/IgniteColocatedAggregateBase.java | 21 +-
.../sql/engine/rel/agg/IgniteMapAggregateBase.java | 24 --
.../engine/rel/agg/IgniteReduceAggregateBase.java | 21 --
.../sql/engine/rel/set/IgniteColocatedSetOp.java | 38 ---
.../sql/engine/rel/set/IgniteMapSetOp.java | 38 ---
.../sql/engine/rel/set/IgniteReduceSetOp.java | 21 --
.../sql/engine/rule/CorrelateToNestedLoopRule.java | 7 +-
.../engine/rule/CorrelatedNestedLoopJoinRule.java | 9 +-
.../sql/engine/rule/FilterConverterRule.java | 15 +-
.../rule/FilterSpoolMergeToHashIndexSpoolRule.java | 7 -
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 6 -
.../engine/rule/HashAggregateConverterRule.java | 2 +-
.../sql/engine/rule/LogicalScanConverterRule.java | 49 +---
.../sql/engine/rule/ProjectConverterRule.java | 13 -
.../engine/rule/SortAggregateConverterRule.java | 2 +-
.../rule/TableFunctionScanConverterRule.java | 12 -
.../sql/engine/rule/TableModifyConverterRule.java | 2 -
.../sql/engine/rule/ValuesConverterRule.java | 4 +-
.../sql/engine/schema/IgniteTableImpl.java | 5 +-
.../sql/engine/trait/CorrelationTrait.java | 121 ----------
.../sql/engine/trait/CorrelationTraitDef.java | 60 -----
.../sql/engine/trait/RewindabilityTrait.java | 110 ---------
.../sql/engine/trait/RewindabilityTraitDef.java | 60 -----
.../internal/sql/engine/trait/TraitUtils.java | 96 +-------
.../sql/engine/trait/TraitsAwareIgniteRel.java | 48 +---
.../internal/sql/engine/util/BaseQueryContext.java | 13 +-
.../ignite/internal/sql/engine/util/Commons.java | 116 +--------
.../internal/sql/engine/util/IgniteMethod.java | 4 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 4 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 263 +++++++++++++++++++--
.../sql/engine/framework/TestBuilders.java | 2 +-
.../sql/engine/planner/AbstractPlannerTest.java | 4 +-
.../engine/planner/HashIndexSpoolPlannerTest.java | 2 +
.../internal/sql/engine/planner/PlannerTest.java | 22 +-
.../planner/ProjectFilterScanMergePlannerTest.java | 2 +
.../planner/SortedIndexSpoolPlannerTest.java | 2 +
.../sql/engine/planner/TableSpoolPlannerTest.java | 2 +
89 files changed, 840 insertions(+), 1552 deletions(-)
delete 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/exec/SharedState.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteGateway.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/InternalIgniteRel.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/CorrelationTrait.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/CorrelationTraitDef.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/RewindabilityTrait.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/RewindabilityTraitDef.java
