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 5212ae6ca58 IGNITE-27330 Remove unused localAssignment from
PartitionReplicaLifecycleManager (#7221)
add 2414dcdd275 IGNITE-26635 Sql. Decouple ExpressionExecution part from
ExecutionContext (#7212)
No new revisions were added by this update.
Summary of changes:
.../internal/sql/engine/InternalSqlRowImpl.java | 2 +-
.../internal/sql/engine/SqlQueryProcessor.java | 1 +
.../internal/sql/engine/exec/ExecutionContext.java | 30 ++---
.../sql/engine/exec/ExecutionServiceImpl.java | 11 +-
.../sql/engine/exec/LogicalRelImplementor.java | 27 +++--
.../exec/ProjectedTableRowConverterImpl.java | 1 -
...leRowConverterFactory.java => RowAccessor.java} | 19 +--
.../internal/sql/engine/exec/RowFactory.java | 118 +++++++++++++++++++
...{ExecutablePlan.java => RowFactoryFactory.java} | 27 ++---
.../internal/sql/engine/exec/RowHandler.java | 127 +--------------------
.../internal/sql/engine/exec/RuntimeHashIndex.java | 2 +-
.../sql/engine/exec/RuntimeSortedIndex.java | 4 +-
.../internal/sql/engine/exec/ScannableTable.java | 1 -
.../sql/engine/exec/ScannableTableImpl.java | 7 +-
.../sql/engine/exec/SqlEvaluationContext.java | 40 +++++++
.../internal/sql/engine/exec/SqlRowHandler.java | 17 +--
.../sql/engine/exec/TableRowConverter.java | 2 +-
.../sql/engine/exec/TableRowConverterImpl.java | 6 +-
.../sql/engine/exec/UpdatableTableImpl.java | 34 ++++--
.../sql/engine/exec/exp/BiFieldGetter.java | 2 +-
.../sql/engine/exec/exp/ComparatorImplementor.java | 16 +--
.../internal/sql/engine/exec/exp/FieldGetter.java | 2 +-
.../engine/exec/exp/JoinPredicateImplementor.java | 4 +-
.../engine/exec/exp/JoinProjectionImplementor.java | 14 +--
.../sql/engine/exec/exp/PredicateImplementor.java | 4 +-
.../sql/engine/exec/exp/ProjectionImplementor.java | 14 +--
.../engine/exec/exp/RowProviderImplementor.java | 20 ++--
.../sql/engine/exec/exp/ScalarImplementor.java | 6 +-
.../engine/exec/exp/SearchBoundsImplementor.java | 16 +--
.../sql/engine/exec/exp/SqlComparator.java | 6 +-
.../sql/engine/exec/exp/SqlJoinPredicate.java | 6 +-
.../sql/engine/exec/exp/SqlJoinProjection.java | 6 +-
.../internal/sql/engine/exec/exp/SqlPredicate.java | 6 +-
.../sql/engine/exec/exp/SqlProjection.java | 6 +-
.../exec/exp/SqlRangeConditionsProvider.java | 8 +-
.../sql/engine/exec/exp/SqlRowProvider.java | 6 +-
.../internal/sql/engine/exec/exp/SqlScalar.java | 6 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 18 +--
.../sql/engine/exec/exp/agg/AggregateRow.java | 2 +-
.../exec/exp/func/SystemRangeTableFunction.java | 4 +-
.../sql/engine/exec/rel/AbstractSetOpNode.java | 6 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 2 +-
.../sql/engine/exec/rel/DataSourceScanNode.java | 4 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 4 +-
.../internal/sql/engine/exec/rel/HashJoinNode.java | 20 ++--
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 2 +-
.../sql/engine/exec/rel/IndexScanNode.java | 6 +-
.../sql/engine/exec/rel/IntersectNode.java | 2 +-
.../sql/engine/exec/rel/MergeJoinNode.java | 25 ++--
.../internal/sql/engine/exec/rel/MinusNode.java | 2 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 12 +-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 10 +-
.../internal/sql/engine/exec/rel/Outbox.java | 4 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 6 +-
.../sql/engine/exec/rel/TableScanNode.java | 5 +-
.../sql/engine/prepare/KeyValueGetPlan.java | 6 +-
.../sql/engine/prepare/SelectCountPlan.java | 4 +-
.../internal/sql/engine/util/IgniteMethod.java | 15 +--
.../ignite/internal/sql/engine/util/TypeUtils.java | 18 ++-
.../sql/engine/exec/DummyScannableTable.java | 1 -
.../sql/engine/exec/ExecutionServiceImplTest.java | 1 +
.../exec/IdentityDistributionFunctionSelfTest.java | 11 +-
.../sql/engine/exec/PartitionsResolutionTest.java | 5 +-
.../exec/ProjectedTableRowConverterSelfTest.java | 3 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 1 +
.../sql/engine/exec/TableRowConverterSelfTest.java | 11 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 11 +-
.../engine/exec/rel/AbstractJoinExecutionTest.java | 8 +-
.../exec/rel/AbstractSetOpExecutionTest.java | 6 +
.../sql/engine/exec/rel/AsyncRootNodeTest.java | 14 ++-
.../sql/engine/exec/rel/BaseAggregateTest.java | 6 +
.../rel/CorrelatedNestedLoopJoinExecutionTest.java | 14 ++-
.../exec/rel/DataSourceScanNodeExecutionTest.java | 34 +++---
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 10 +-
.../sql/engine/exec/rel/ExecutionTest.java | 12 +-
.../sql/engine/exec/rel/FilterExecutionTest.java | 6 +
.../exec/rel/HashAggregateExecutionTest.java | 8 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 10 +-
.../exec/rel/HashIndexSpoolExecutionTest.java | 6 +
.../exec/rel/IndexScanNodeExecutionTest.java | 12 +-
.../engine/exec/rel/IntersectExecutionTest.java | 4 +-
.../sql/engine/exec/rel/LimitExecutionTest.java | 6 +
.../engine/exec/rel/MergeJoinExecutionTest.java | 6 +
.../sql/engine/exec/rel/MinusExecutionTest.java | 2 +-
.../engine/exec/rel/ModifyNodeExecutionTest.java | 30 +++--
.../sql/engine/exec/rel/ScanNodeExecutionTest.java | 6 +
.../engine/exec/rel/ScannableTableSelfTest.java | 14 +--
.../exec/rel/SortAggregateExecutionTest.java | 8 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 6 +
.../exec/rel/SystemRangeTableFunctionTest.java | 6 +
.../exec/rel/TableScanNodeExecutionTest.java | 12 +-
.../engine/exec/rel/TableSpoolExecutionTest.java | 6 +
.../sql/engine/exec/row/SqlRowHandlerTest.java | 35 +++---
.../sql/engine/framework/ArrayRowHandler.java | 17 ++-
.../sql/engine/framework/TestBuilders.java | 3 +-
.../sql/engine/framework/TestClusterTest.java | 2 +-
.../internal/sql/engine/framework/TestNode.java | 3 +
.../internal/sql/engine/util/TypeUtilsTest.java | 1 +
98 files changed, 666 insertions(+), 492 deletions(-)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{TableRowConverterFactory.java
=> RowAccessor.java} (67%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/RowFactory.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{ExecutablePlan.java
=> RowFactoryFactory.java} (51%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/SqlEvaluationContext.java
