This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-21172
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 49a87dd341 Styles.
add 15a3cd3028 Bump io.dropwizard.metrics:metrics-core from 4.0.2 to
4.2.25 (#3457)
add fd3d6a909b Bump com.github.spotbugs from 6.0.7 to 6.0.8 (#3456)
add a643a9ff9c IGNITE-21795 Unconditionally update storage with proper
raft index within PartitionListener (#3454)
add 500c5d286b IGNITE-21819 Clear nextRowIdToBuild on rebalance (#3451)
add ed64c5c3c4 IGNITE-21754 Remove destroyed tables on recovery - Page
Memory (#3446)
add 7060006355 IGNITE-21708 Fix
CatalogManagerSelfTest::testPkAvailableIndexEvent flaky test (#3450)
add c02b3ea7eb IGNITE-18617 Clear rw tx context and cleanup ready futures
on tx finish (#3436)
add c3de575204 IGNITE-21521 Fix update order in upsertAll and DataStreamer
for a new key (#3439)
add cbc84ebce0 IGNITE-21815 Client handler: use QueryProcessor instead of
IgniteSql (#3459)
add 3a374adfd9 IGNITE-21817 CriteriaException must keep error code for
mapping from SqlException. (#3449)
add 20359d3a12 IGNITE-21540 Handle lock exception for transaction
operations (#3462)
add 07cebb426f IGNITE-21804 Fix macos build of Ignite CPP client (#3440)
add 384eb85497 IGNITE-21666 Define base Eventlog classes (#3430)
add 104b4903ba IGNITE-21674 Fix subcommand completion in CLI (#3461)
add 20d296db59 IGNITE-21669 Sql. Remove sessions from SQL API
add f27a761dc7 IGNITE-21834 Add more details to assertions in recovery
handhake managers (#3471)
add 5f8d882aef Merge branch 'main' into ignite-21172
No new revisions were added by this update.
Summary of changes:
check-rules/spotbugs-excludes.xml | 5 +-
.../apache/ignite/example/sql/SqlApiExample.java | 261 ++++----
gradle/libs.versions.toml | 4 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 7 +-
.../main/java/org/apache/ignite/sql/IgniteSql.java | 240 +++++++-
.../main/java/org/apache/ignite/sql/ResultSet.java | 4 +-
.../main/java/org/apache/ignite/sql/Session.java | 441 --------------
.../main/java/org/apache/ignite/sql/Statement.java | 19 +
.../apache/ignite/sql/async/AsyncResultSet.java | 6 +-
.../internal/catalog/sql/AbstractCatalogQuery.java | 5 +-
.../internal/catalog/CatalogManagerSelfTest.java | 5 +-
.../core/repl/executor/IgnitePicocliCommands.java | 80 ++-
modules/client-handler/build.gradle | 1 +
.../apache/ignite/client/handler/TestServer.java | 4 +-
.../ignite/client/handler/ClientHandlerModule.java | 9 -
.../handler/ClientInboundMessageHandler.java | 14 +-
.../handler/requests/sql/ClientSqlCommon.java | 50 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 86 +--
.../requests/sql/ClientSqlExecuteRequest.java | 84 ++-
.../sql/ClientSqlExecuteScriptRequest.java | 14 +-
.../handler/requests/sql/ClientSqlProperties.java | 73 +++
.../handler/requests/sql/ClientSqlResultSet.java | 11 +-
modules/client/build.gradle | 1 +
.../apache/ignite/client/ClientOperationType.java | 10 +-
.../ignite/internal/client/sql/ClientSession.java | 381 ------------
.../internal/client/sql/ClientSessionBuilder.java | 153 -----
.../ignite/internal/client/sql/ClientSql.java | 288 ++++++++-
.../internal/client/sql/ClientStatement.java | 9 +
.../client/sql/ClientStatementBuilder.java | 13 +
.../internal/client/table/AbstractClientView.java | 19 +-
.../client/table/ClientKeyValueBinaryView.java | 6 +-
.../internal/client/table/ClientKeyValueView.java | 6 +-
.../client/table/ClientRecordBinaryView.java | 6 +-
.../internal/client/table/ClientRecordView.java | 6 +-
.../ignite/internal/client/table/ClientTable.java | 12 +-
.../apache/ignite/client/ClientMetricsTest.java | 4 +-
.../org/apache/ignite/client/ClientSqlTest.java | 80 +--
.../client/ObservableTimestampPropagationTest.java | 2 +-
.../apache/ignite/client/ServerMetricsTest.java | 11 +-
.../ignite/client/TestClientHandlerModule.java | 6 +-
.../java/org/apache/ignite/client/TestServer.java | 4 +-
.../ignite/client/fakes/FakeAsyncResultSet.java | 251 --------
.../org/apache/ignite/client/fakes/FakeCursor.java | 144 ++++-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 2 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 30 +-
.../apache/ignite/client/fakes/FakeIgniteSql.java | 52 --
.../ignite/client/fakes/FakeIgniteTables.java | 4 +-
.../apache/ignite/client/fakes/FakeSession.java | 290 ---------
.../ignite/client/fakes/FakeSessionBuilder.java | 136 -----
.../org/apache/ignite/client/fakes/FakeSqlRow.java | 290 ---------
.../ignite/internal/sql/AbstractSession.java | 171 ------
.../criteria/CriteriaExceptionMapperUtil.java | 7 -
.../criteria/CriteriaExceptionMapperUtilTest.java | 2 +-
.../internal/testframework/IgniteTestUtils.java | 13 +-
.../ItDistributionZonesFilterTest.java | 39 +-
.../distributionzones/DistributionZoneManager.java | 2 +-
modules/{affinity => eventlog}/build.gradle | 6 +-
.../apache/ignite/internal/eventlog/api/Event.java | 46 ++
.../internal/eventlog/api/EventFactory.java} | 23 +-
.../ignite/internal/eventlog/api/EventLog.java} | 15 +-
.../internal/eventlog/event/EventBuilder.java | 124 ++++
.../ignite/internal/eventlog/event/EventImpl.java | 100 +++
.../internal/eventlog/event/EventTypeRegistry.java | 56 ++
.../ignite/internal/eventlog/event/EventUser.java | 78 +++
.../internal/eventlog/event/IgniteEventTypes.java} | 10 +-
.../internal/eventlog/event/IgniteEvents.java | 56 ++
.../exception/InvalidEventTypeException.java} | 20 +-
.../exception/InvalidProductVersionException.java} | 21 +-
.../exception/MissingEventTypeException.java} | 20 +-
.../exception/MissingEventUserException.java} | 20 +-
.../exception/NotUniqueEventTypeException.java} | 23 +-
.../internal/eventlog/event/EventBuilderTest.java | 143 +++++
.../eventlog/event/EventTypeRegistryTest.java | 60 ++
.../internal/eventlog/event/IgniteEventsTest.java | 65 ++
.../recovery/RecoveryClientHandshakeManager.java | 8 +-
.../recovery/RecoveryServerHandshakeManager.java | 5 +-
.../persistence/store/FilePageStoreManager.java | 31 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 2 +-
.../store/FilePageStoreManagerTest.java | 32 +-
modules/platforms/cpp/ignite/common/error_codes.h | 5 +-
.../detail/macos/macos_async_worker_thread.cpp | 6 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 1 -
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 7 +-
modules/rest/build.gradle | 1 +
.../ignite/internal/rest/RestComponentTest.java | 2 +-
.../ClusterConfigurationControllerTest.java | 2 +-
.../NodeConfigurationControllerTest.java | 2 +-
modules/runner/build.gradle | 1 +
.../benchmark/CriteriaEmbeddedNodeBenchmark.java | 18 +-
.../benchmark/CriteriaThinClientBenchmark.java | 10 +-
.../ignite/internal/benchmark/InsertBenchmark.java | 33 +-
.../ignite/internal/benchmark/SelectBenchmark.java | 36 +-
.../ignite/internal/benchmark/SqlBenchmark.java | 18 +-
.../benchmark/SqlMultiStatementBenchmark.java | 41 +-
.../benchmark/SqlPartitionPruningBenchmark.java | 26 +-
.../ignite/internal/benchmark/TpchBenchmark.java | 16 +-
.../runner/app/AbstractSchemaChangeTest.java | 23 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 37 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 24 +-
.../runner/app/ItIgniteNodeRestartTest.java | 113 ++--
.../internal/runner/app/ItNoThreadsLeftTest.java | 7 +-
.../internal/runner/app/ItSingleNodeTest.java | 5 +-
.../internal/runner/app/ItTablesApiTest.java | 5 +-
.../runner/app/PlatformTestNodeRunner.java | 9 +-
.../app/client/ItAbstractThinClientTest.java | 12 +-
.../app/client/ItThinClientAuthenticationTest.java | 7 +-
.../runner/app/client/ItThinClientComputeTest.java | 3 +-
.../app/client/ItThinClientConnectionTest.java | 8 +-
.../app/client/ItThinClientMarshallingTest.java | 10 +-
.../ItThinClientSchemaSynchronizationTest.java | 44 +-
.../runner/app/client/ItThinClientSqlTest.java | 108 ++--
.../streamer/ItAbstractDataStreamerTest.java | 12 +-
.../ignite/internal/table/ItInternalTableTest.java | 33 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 7 +-
.../java/org/apache/ignite/internal/Cluster.java | 32 +-
.../internal/ClusterPerClassIntegrationTest.java | 22 +-
.../org/apache/ignite/internal/SessionUtils.java | 22 +-
modules/security/build.gradle | 1 +
.../authentication/AuthenticationManagerImpl.java | 17 +-
.../AuthenticationManagerImplTest.java | 2 +-
.../ignite/internal/sql/api/ItCommonApiTest.java | 80 +--
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 452 +++++++-------
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 61 +-
.../sql/api/ItSqlClientAsynchronousApiTest.java | 32 +-
.../internal/sql/api/ItSqlClientMetricsTest.java | 64 +-
.../sql/api/ItSqlClientSynchronousApiTest.java | 20 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 51 +-
.../internal/sql/engine/ItFunctionsTest.java | 2 +
.../internal/sql/engine/ItKeyValueGetTest.java | 23 +-
.../internal/sql/engine/ItKeyValuePutTest.java | 11 +-
.../internal/sql/engine/ItLimitOffsetTest.java | 21 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 4 +-
.../internal/sql/engine/ItMultistatementTest.java | 19 +-
.../internal/sql/sqllogic/ItSqlLogicTest.java | 7 +-
.../internal/sql/sqllogic/ScriptContext.java | 33 +-
.../internal/sql/api/AsyncResultSetImpl.java | 14 +-
.../internal/sql/api/IdleExpirationTracker.java | 99 ---
.../ignite/internal/sql/api/IgniteSqlImpl.java | 664 ++++++++++++++++++--
.../internal/sql/api/SessionBuilderImpl.java | 232 -------
.../ignite/internal/sql/api/SessionImpl.java | 667 ---------------------
.../internal/sql/api/StatementBuilderImpl.java | 19 +
.../ignite/internal/sql/api/StatementImpl.java | 8 +
.../ignite/internal/sql/api/IgniteSqlImplTest.java | 346 +++++++++--
.../ignite/internal/sql/api/SessionImplTest.java | 522 ----------------
.../exec/rel/TableScanNodeExecutionTest.java | 4 +-
.../internal/storage/engine/StorageEngine.java | 8 +
.../engine/ThreadAssertingStorageEngine.java | 5 +
.../internal/storage/index/IndexStorage.java | 3 +-
.../ignite/internal/storage/util/StorageUtils.java | 8 +
.../storage/AbstractMvTableStorageTest.java | 73 ++-
.../storage/engine/AbstractStorageEngineTest.java | 60 +-
.../internal/storage/impl/TestStorageEngine.java | 5 +
.../index/impl/AbstractTestIndexStorage.java | 19 +-
.../PersistentPageMemoryStorageEngine.java | 14 +
.../VolatilePageMemoryStorageEngine.java | 5 +
.../index/AbstractPageMemoryIndexStorage.java | 129 ++--
.../index/hash/PageMemoryHashIndexStorage.java | 45 +-
...> UpdateLastRowIdUuidToBuildInvokeClosure.java} | 4 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 51 +-
.../storage/pagememory/mv/IndexStorageFactory.java | 9 +-
.../storage/pagememory/mv/PageMemoryIndexes.java | 6 +-
.../storage/rocksdb/RocksDbMetaStorage.java | 27 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 6 +
.../rocksdb/index/AbstractRocksDbIndexStorage.java | 22 +-
.../rocksdb/index/RocksDbHashIndexStorage.java | 2 +-
.../rocksdb/index/RocksDbSortedIndexStorage.java | 2 +-
.../rocksdb/engine/RocksDbStorageEngineTest.java | 7 +
.../ItTxAbstractDistributedTestSingleNode.java | 44 ++
.../rebalance/ItRebalanceDistributedTest.java | 2 +
.../ignite/internal/table/ItColocationTest.java | 4 +-
.../ignite/internal/table/ItCriteriaQueryTest.java | 32 +-
.../internal/table/ItOperationRetryTest.java | 132 ++++
.../internal/table/ItTransactionRecoveryTest.java | 7 +-
.../ignite/internal/table/AbstractTableView.java | 11 +-
.../table/distributed/DroppedTableInfo.java} | 45 +-
.../internal/table/distributed/TableManager.java | 47 +-
.../internal/table/distributed/TableUtils.java | 39 ++
.../table/distributed/raft/PartitionListener.java | 18 +-
.../replicator/PartitionReplicaListener.java | 141 ++++-
.../distributed/storage/InternalTableImpl.java | 234 +++++---
.../distributed/TableManagerRecoveryTest.java | 39 +-
.../table/distributed/TableManagerTest.java | 5 +
.../internal/table/distributed/TableUtilsTest.java | 215 +++++--
.../raft/PartitionCommandListenerTest.java | 244 +++++---
.../distributed/storage/InternalTableImplTest.java | 8 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../ignite/internal/table/TableTestUtils.java | 48 ++
.../table/impl/DummyInternalTableImpl.java | 4 +-
.../ignite/internal/tx/ItMultipleLocksTest.java | 25 +-
.../TransactionConfigurationSchema.java | 10 +
.../internal/tx/impl/TransactionInflights.java | 13 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 2 +-
settings.gradle | 2 +
193 files changed, 5141 insertions(+), 5824 deletions(-)
delete mode 100644 modules/api/src/main/java/org/apache/ignite/sql/Session.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlProperties.java
delete mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSession.java
delete mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSessionBuilder.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeAsyncResultSet.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeIgniteSql.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSessionBuilder.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSqlRow.java
delete mode 100755
modules/core/src/main/java/org/apache/ignite/internal/sql/AbstractSession.java
copy modules/{affinity => eventlog}/build.gradle (88%)
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/Event.java
copy modules/{api/src/main/java/org/apache/ignite/catalog/annotations/Id.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/EventFactory.java}
(60%)
copy
modules/{api/src/main/java/org/apache/ignite/table/DataStreamerOperationType.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/EventLog.java}
(76%)
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/EventBuilder.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/EventImpl.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/EventTypeRegistry.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/EventUser.java
copy modules/{api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java =>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/IgniteEventTypes.java}
(71%)
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/IgniteEvents.java
copy
modules/{rest/src/main/java/org/apache/ignite/internal/rest/compute/exception/ComputeJobStateException.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/InvalidEventTypeException.java}
(60%)
copy
modules/{rest/src/main/java/org/apache/ignite/internal/rest/compute/exception/ComputeJobStateException.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/InvalidProductVersionException.java}
(58%)
copy
modules/{rest/src/main/java/org/apache/ignite/internal/rest/compute/exception/ComputeJobNotFoundException.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/MissingEventTypeException.java}
(69%)
copy
modules/{rest/src/main/java/org/apache/ignite/internal/rest/compute/exception/ComputeJobNotFoundException.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/MissingEventUserException.java}
(67%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/raft/CmgStorageException.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/NotUniqueEventTypeException.java}
(63%)
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/event/EventBuilderTest.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/event/EventTypeRegistryTest.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/event/IgniteEventsTest.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/IdleExpirationTracker.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/SessionBuilderImpl.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/SessionImpl.java
delete mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/api/SessionImplTest.java
rename
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/meta/{UpdateLastRowIdUuidToBuiltInvokeClosure.java
=> UpdateLastRowIdUuidToBuildInvokeClosure.java} (94%)
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItOperationRetryTest.java
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/api/SessionId.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/DroppedTableInfo.java}
(57%)
