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 2024/02/26 12:34:19 UTC

(ignite-3) branch ignite-20680 updated (156f614205 -> a45814cc4a)

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-20680
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


    from 156f614205 Fix test.
     add 4915e29280 IGNITE-21545 Introduce a cursor registry (#3228)
     add 870c2c2311 IGNITE-21279: Sql. Partition pruning. Integrate static partition pruning into READ statements execution pipeline (#3187)
     add 71b24675d2 IGNITE-21551 Sql. Enable TIMESTAMP_WITH_LOCAL_TIME_ZONE type (#3229)
     add a45814cc4a Merge branch 'main' into ignite-20680

No new revisions were added by this update.

Summary of changes:
 .../apache/ignite/lang/CursorClosedException.java  |   4 +-
 .../java/org/apache/ignite/lang/ErrorGroups.java   |   5 +-
 .../main/java/org/apache/ignite/sql/Session.java   |  16 ++
 .../ignite/internal/client/sql/ClientSession.java  |   8 +
 .../internal/client/sql/ClientSessionBuilder.java  |   7 +
 .../ignite/client/fakes/FakeInternalTable.java     |   9 +-
 .../apache/ignite/client/fakes/FakeSession.java    |   8 +
 .../ignite/client/fakes/FakeSessionBuilder.java    |   7 +
 .../apache/ignite/client/fakes/FakeTxManager.java  |   6 -
 .../ItPrimaryReplicaChoiceTest.java                |   8 +-
 modules/platforms/cpp/ignite/common/error_codes.h  |   3 +-
 modules/platforms/cpp/ignite/odbc/common_types.cpp |   3 +-
 .../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs |   7 +-
 .../dotnet/Apache.Ignite/Internal/Sql/ResultSet.cs |   4 +-
 .../benchmark/AbstractMultiNodeBenchmark.java      |  43 ++-
 .../benchmark/SqlPartitionPruningBenchmark.java    | 174 +++++++++++
 .../runner/app/ItIgniteNodeRestartTest.java        |   9 +-
 .../ignite/internal/table/ItInternalTableTest.java |   2 +-
 .../internal/table/ItPublicApiColocationTest.java  |   4 +-
 .../ignite/internal/table/ItTableScanTest.java     |   5 +-
 .../org/apache/ignite/internal/app/IgniteImpl.java |   9 +-
 .../internal/ClusterPerClassIntegrationTest.java   |  14 +-
 .../internal/ClusterPerTestIntegrationTest.java    |   2 +-
 .../ignite/internal/sql/api/ItCommonApiTest.java   |  39 ++-
 .../ignite/internal/sql/api/ItSqlApiBaseTest.java  |   4 +-
 .../internal/sql/engine/ItCreateTableDdlTest.java  |   6 +-
 .../internal/sql/engine/ItDataTypesTest.java       | 122 ++++----
 .../internal/sql/engine/ItFunctionsTest.java       |  57 ++--
 .../ignite/internal/sql/engine/ItIntervalTest.java | 318 +++++++++++++++++----
 .../ignite/internal/sql/engine/ItMetadataTest.java |  14 +-
 .../src/main/codegen/includes/parserImpls.ftl      |  10 +-
 .../internal/sql/api/SessionBuilderImpl.java       |  11 +
 .../ignite/internal/sql/api/SessionImpl.java       |  17 +-
 .../ignite/internal/sql/engine/QueryProperty.java  |   2 +
 .../internal/sql/engine/SqlQueryProcessor.java     |  24 +-
 .../internal/sql/engine/exec/ExecutionContext.java |  22 +-
 .../sql/engine/exec/ExecutionServiceImpl.java      |  18 +-
 .../sql/engine/exec/LogicalRelImplementor.java     |  11 +-
 .../sql/engine/exec/NodeWithConsistencyToken.java  |   5 +-
 .../engine/exec/PartitionWithConsistencyToken.java |  31 ++
 .../sql/engine/exec/ScannableTableImpl.java        |   9 +-
 .../sql/engine/exec/exp/ExpressionFactoryImpl.java |   7 +
 .../sql/engine/exec/exp/IgniteSqlFunctions.java    |  18 +-
 .../internal/sql/engine/exec/exp/RexImpTable.java  |   2 +
 .../sql/engine/exec/exp/RexToLixTranslator.java    |  17 +-
 .../sql/engine/exec/mapping/ColocationGroup.java   |  38 ++-
 .../sql/engine/exec/mapping/FragmentSplitter.java  |  16 +-
 .../sql/engine/exec/mapping/MappedFragment.java    |  66 +++++
 .../sql/engine/exec/mapping/MappingParameters.java |  53 ++++
 .../sql/engine/exec/mapping/MappingService.java    |   2 +-
 .../engine/exec/mapping/MappingServiceImpl.java    |  23 +-
 .../sql/engine/exec/mapping/QuerySplitter.java     |  26 +-
 .../sql/engine/message/QueryStartRequest.java      |   5 +
 .../internal/sql/engine/prepare/Fragment.java      |  10 +-
 .../engine/prepare/pruning/PartitionPruner.java}   |  35 +--
 .../prepare/pruning/PartitionPrunerImpl.java       | 208 ++++++++++++++
 .../prepare/pruning/PartitionPruningColumns.java   |   4 +-
 .../prepare/pruning/PartitionPruningMetadata.java  |  10 +-
 .../pruning/PartitionPruningMetadataExtractor.java |  77 ++++-
 .../prepare/pruning/PartitionPruningPredicate.java | 198 +++++++++++++
 .../internal/sql/engine/util/BaseQueryContext.java |  28 +-
 .../engine/util/IgniteCustomAssignmentsRules.java  |  14 +-
 .../internal/sql/engine/util/IgniteMethod.java     |   4 +
 .../ignite/internal/sql/engine/util/TypeUtils.java |   3 +-
 .../ignite/internal/sql/api/SessionImplTest.java   |  35 ++-
 .../sql/engine/exec/ExecutionServiceImplTest.java  |  37 +--
 .../sql/engine/exec/RuntimeSortedIndexTest.java    |   4 +-
 .../engine/exec/exp/IgniteSqlFunctionsTest.java    |  34 +++
 .../engine/exec/mapping/FragmentMappingTest.java   |  33 ++-
 .../sql/engine/exec/mapping/FragmentPrinter.java   |  60 +++-
 .../exec/mapping/MappingServiceImplTest.java       |  44 +--
 .../sql/engine/exec/mapping/MappingTestRunner.java |   6 +-
 .../sql/engine/exec/rel/AbstractExecutionTest.java |   4 +-
 .../engine/exec/rel/MergeJoinExecutionTest.java    |   5 +-
 .../engine/exec/rel/ScannableTableSelfTest.java    |  25 +-
 .../exec/rel/TableScanNodeExecutionTest.java       |   7 +-
 .../sql/engine/framework/TestBuilders.java         |  77 ++++-
 .../internal/sql/engine/framework/TestNode.java    |   2 +
 .../sql/engine/planner/CastResolutionTest.java     |  37 +--
 .../sql/engine/planner/PartitionPruningTest.java   |  91 +++++-
 .../pruning/PartitionPruningPredicateSelfTest.java | 302 +++++++++++++++++++
 .../internal/sql/engine/sql/SqlDdlParserTest.java  |  19 +-
 .../src/test/resources/mapping/correlated.test     |  42 ++-
 .../sql-engine/src/test/resources/mapping/dml.test |  21 +-
 .../src/test/resources/mapping/merge_join.test     |  20 +-
 .../src/test/resources/mapping/set_ops.test        |  13 +-
 .../src/test/resources/mapping/table_affinity.test |  32 ++-
 .../src/test/resources/mapping/table_identity.test |  28 +-
 .../resources/mapping/table_identity_single.test   |  30 +-
 .../src/test/resources/mapping/table_single.test   |  27 +-
 .../resources/mapping/test_partition_pruning.test  | 110 +++++++
 .../src/test/resources/mapping/union.test          |  26 +-
 .../internal/sql/engine/util/QueryChecker.java     |   3 +
 .../internal/sql/engine/util/QueryCheckerImpl.java |  33 ++-
 .../ItInternalTableReadOnlyScanTest.java           |   2 +-
 .../apache/ignite/distributed/ItLockTableTest.java |   7 +-
 ...xDistributedTestSingleNodeNoCleanupMessage.java |  13 +-
 .../rebalance/ItRebalanceDistributedTest.java      |   9 +-
 .../ignite/internal/table/ItColocationTest.java    |   4 +-
 .../ignite/internal/table/ItCriteriaQueryTest.java |   6 +-
 .../internal/table/ItTransactionRecoveryTest.java  |   3 +-
 .../ignite/internal/table/InternalTable.java       |  14 +-
 .../internal/table/distributed/TableManager.java   |  10 +-
 .../table/distributed/raft/PartitionListener.java  |   6 +-
 .../ReadOnlyScanRetrieveBatchReplicaRequest.java   |   7 +
 .../distributed/replicator/CursorResource.java}    |  29 +-
 .../replicator/PartitionReplicaListener.java       | 188 ++++++------
 ...SchemaException.java => RemoteResourceIds.java} |  21 +-
 .../distributed/storage/InternalTableImpl.java     |  26 +-
 .../table/distributed/TableManagerTest.java        |   4 +-
 .../PartitionReplicaListenerIndexLockingTest.java  |   4 +-
 .../replication/PartitionReplicaListenerTest.java  |  14 +-
 .../apache/ignite/distributed/ItTxTestCluster.java |  29 +-
 .../ignite/internal/table/TxAbstractTest.java      |   9 +-
 .../table/impl/DummyInternalTableImpl.java         |  73 ++---
 .../org/apache/ignite/internal/tx/TxManager.java   |   9 -
 .../internal/tx/impl/FullyQualifiedResourceId.java | 142 +++++++++
 .../tx/impl/RemotelyTriggeredResourceRegistry.java | 157 ++++++++++
 .../internal/tx/impl/ResourceCloseException.java}  |  26 +-
 .../internal/tx/impl/TxCleanupRequestHandler.java  |  10 +-
 .../ignite/internal/tx/impl/TxManagerImpl.java     |  25 +-
 .../apache/ignite/internal/tx/TxManagerTest.java   |   4 +-
 122 files changed, 3254 insertions(+), 745 deletions(-)
 create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/SqlPartitionPruningBenchmark.java
 create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/MappingParameters.java
 copy modules/{error-code-annotation-processor/src/main/java/org/apache/ignite/internal/error/code/processor/ErrorCodeGroupDescriptor.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/pruning/PartitionPruner.java} (60%)
 create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/pruning/PartitionPrunerImpl.java
 create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/pruning/PartitionPruningPredicate.java
 create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/prepare/pruning/PartitionPruningPredicateSelfTest.java
 create mode 100644 modules/sql-engine/src/test/resources/mapping/test_partition_pruning.test
 copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/RuntimeIndex.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/CursorResource.java} (60%)
 copy modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/{IncompatibleSchemaException.java => RemoteResourceIds.java} (62%)
 create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/FullyQualifiedResourceId.java
 create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/RemotelyTriggeredResourceRegistry.java
 copy modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/InternalInitException.java => transactions/src/main/java/org/apache/ignite/internal/tx/impl/ResourceCloseException.java} (56%)