This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch catalog-feature
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 209698938f IGNITE-19641 Catalog events are triggered too early. (#2231)
add 683f9a6f20 IGNITE-16004 Preserve key order in
InternalTableImpl#collectMultiRowsResponses (#2236)
add e674c16add IGNITE-19799 Refactoring classes associated with the
catalog (#2243)
add 7f5bda1cb8 IGNITE-19209 Implement installing table schema updates
(#2228)
add 5afdeec51e IGNITE-19815 Make ItTableScanTest resilient (#2244)
No new revisions were added by this update.
Summary of changes:
modules/api/build.gradle | 1 +
.../java/org/apache/ignite/sql/SqlException.java | 13 +
.../testframework/IntegrationTestBase.java | 2 +-
.../testframework/TestIgnitionManager.java | 39 ++
.../ignite/internal/catalog/CatalogService.java | 2 +-
.../internal/catalog/CatalogServiceImpl.java | 616 +++++++++++----------
.../ignite/internal/catalog/ClockWaiter.java | 171 ++++++
.../commands/AbstractIndexCommandParams.java | 41 ++
.../internal/catalog/commands/CatalogUtils.java | 33 +-
.../catalog/commands/CreateHashIndexParams.java | 22 -
.../catalog/commands/CreateSortedIndexParams.java | 41 --
.../SchemaSynchronizationConfigurationSchema.java | 3 +-
.../internal/catalog/storage/AlterColumnEntry.java | 4 +-
.../internal/catalog/storage/DropColumnsEntry.java | 4 +-
.../internal/catalog/storage/DropIndexEntry.java | 4 +-
.../internal/catalog/storage/DropTableEntry.java | 4 +-
.../internal/catalog/storage/NewColumnsEntry.java | 4 +-
.../internal/catalog/storage/NewIndexEntry.java | 4 +-
.../internal/catalog/storage/NewTableEntry.java | 4 +-
.../ignite/internal/catalog/storage/UpdateLog.java | 4 +-
.../internal/catalog/storage/UpdateLogImpl.java | 31 +-
.../internal/catalog/storage/VersionedUpdate.java | 15 +-
.../internal/catalog/CatalogServiceSelfTest.java | 246 ++++----
.../ignite/internal/catalog/ClockWaiterTest.java | 97 ++++
.../catalog/storage/UpdateLogImplTest.java | 24 +-
.../internal/cli/commands/ItConfigCommandTest.java | 2 +-
.../internal/rest/ItGeneratedRestClientTest.java | 2 +-
.../ignite/internal/hlc/ClockUpdateListener.java} | 15 +-
.../apache/ignite/internal/hlc/HybridClock.java | 14 +
.../ignite/internal/hlc/HybridClockImpl.java | 23 +-
.../ignite/internal/hlc/HybridTimestamp.java | 8 +
.../apache/ignite/internal/HybridClockTest.java | 60 ++
.../apache/ignite/internal/TestHybridClock.java | 24 +-
.../apache/ignite/jdbc/AbstractJdbcSelfTest.java | 2 +-
.../internal/metastorage/MetaStorageManager.java | 20 +
.../ignite/internal/metastorage/WatchEvent.java | 22 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 26 +
.../metastorage/server/KeyValueStorage.java | 8 +
.../metastorage/server/WatchProcessor.java | 8 +-
.../server/persistence/RocksDbKeyValueStorage.java | 3 +-
.../server/SimpleInMemoryKeyValueStorage.java | 8 +
modules/rest-api/openapi/openapi.yaml | 2 +-
.../java/org/apache/ignite/internal/Cluster.java | 4 +-
.../benchmark/AbstractOneNodeBenchmark.java | 2 +-
.../cluster/management/ItClusterInitTest.java | 4 +-
.../component/ItRestAddressReportTest.java | 3 +-
.../storage/ItRebalanceDistributedTest.java | 19 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 2 +-
.../runner/app/AbstractSchemaChangeTest.java | 2 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 2 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 2 +-
.../runner/app/ItIgniteNodeRestartTest.java | 13 +-
.../runner/app/ItTableApiContractTest.java | 28 +
.../internal/runner/app/ItTableCreationTest.java | 2 +-
.../internal/runner/app/ItTablesApiTest.java | 2 +-
.../runner/app/PlatformTestNodeRunner.java | 2 +-
.../app/client/ItAbstractThinClientTest.java | 2 +-
.../sql/engine/ClusterPerClassIntegrationTest.java | 2 +-
.../ignite/internal/sqllogic/ItSqlLogicTest.java | 2 +-
.../org/apache/ignite/internal/ssl/ItSslTest.java | 4 +-
.../ignite/internal/table/ItRoReadsTest.java | 6 +-
.../ignite/internal/table/ItTableScanTest.java | 72 ++-
.../org/apache/ignite/internal/app/IgniteImpl.java | 17 +-
.../DistributedConfigurationCatchUpTest.java | 3 +-
.../sql/engine/schema/CatalogSqlSchemaManager.java | 6 +-
.../engine/schema/CatalogSqlSchemaManagerTest.java | 9 +-
modules/table/build.gradle | 1 +
.../ItAbstractInternalTableScanTest.java | 6 -
.../ItInternalTableReadOnlyOperationsTest.java | 56 +-
.../ItInternalTableReadWriteScanTest.java | 8 +-
.../replicator/PartitionReplicaListener.java | 4 +-
.../distributed/storage/InternalTableImpl.java | 127 +++--
.../table/distributed/storage/RowBatch.java | 77 +++
.../replication/PartitionReplicaListenerTest.java | 2 +-
.../distributed/storage/InternalTableImplTest.java | 76 +++
.../internal/table/RollbackTxOnErrorPublisher.java | 89 +++
76 files changed, 1647 insertions(+), 685 deletions(-)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/ClockWaiter.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/ClockWaiterTest.java
copy
modules/{client/src/main/java/org/apache/ignite/internal/client/PayloadReader.java
=> core/src/main/java/org/apache/ignite/internal/hlc/ClockUpdateListener.java}
(66%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/storage/RowBatch.java
create mode 100644
modules/table/src/testFixtures/java/org/apache/ignite/internal/table/RollbackTxOnErrorPublisher.java
