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%)