This is an automated email from the ASF dual-hosted git repository.
mpochatkin pushed a change to branch IGNITE-23054
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 124a6f77fc Fix comments
add fb97554d0c IGNITE-23494 Do not use ByteUtils#toBytes to serialize
assignments (#4596)
add a86c71d114 IGNITE-23503 Add maxObservableSafeTime awaiting logic on
SafeTimeReorderException (#4612)
add 57a0bbafac IGNITE-23520 Fix flaky
IndexAvailabilityControllerTest#testMetastoreKeysAfterDropIndexWithTwoRemainingPartitions
(#4618)
add b37b538100 IGNITE-23524 Remove clock in favour of clockService in
TableManager (#4616)
add 4b32c57135 IGNITE-23384 Improve client data streamer performance
(#4617)
add 4406359522 IGNITE-23527 Move system properties configuration to new
module ignite-configuration-system (#4622)
add fd00e07350 IGNITE-23214 Valid error for unsupported types for dynamic
parameters (#4613)
add d1c4bbe4ea IGNITE-23301 Improved concurrency for coarse locks.
add f1720d672d IGNITE-21563 Replace ENGINE based aprroach by
STORAGE_PROFILES in docs (#4619)
add 23a77713c8 Bump net.bytebuddy:byte-buddy from 1.15.5 to 1.15.7 (#4620)
add 230683cdfc IGNITE-23164 Improve ClientTuple validation for KV view
(#4627)
add a67066301a IGNITE-23140 .NET: Fix TestBasicLogging flakiness (#4631)
add 71f592b92e IGNITE-23531 Improve messages in REST API for MG disaster
recovery (#4626)
add d9c4e9c243 IGNITE-23124 Configurable deadlock prevention policies and
retry count after LockException (#4590)
add 5afa1adc84 IGNITE-23422 .NET: Update to .NET 8 (#4633)
add f5eb71574f IGNITE-23536 Fix PartitionScanPublisher (#4630)
add 9c9b61eee3 IGNITE-23432 Sql. Introduce registry of running queries
(#4591)
add 9e21f50be0 IGNITE-23496 Optimize lease batch serialization (#4608)
add f4b2384f81 IGNITE-23530 Do not include node name in Raft group
identifier in storages (#4625)
add 6935ca8cc4 IGNITE-22897 Add CLI for initiating MG repair (#4611)
add d8db84df26 IGNITE-23293 Implement the algorithm of Metastorage
Compaction Trigger (#4632)
add 8537e7e45d IGNITE-22916 Validate Metastorage for divergency during
join (#4624)
add 939a1a31e5 IGNITE-23546 Fix long handling of
EvictIdempotentCommandsCacheCommand (#4637)
add 36a7414767 IGNITE-23443 Create Gradle task to update versions (#4628)
add 667979b1ed IGNITE-23543 Add validation of local and distributed system
properties value (#4638)
add 7ff9534a53 IGNITE-23484 Do not use ByteUtils#toBytes in zones
management (#4594)
add 0beb4bdb73 Bump JetBrains.Annotations in /modules/platforms/dotnet
(#4635)
add e68e435dd6 Bump org.rocksdb:rocksdbjni from 9.6.1 to 9.7.3 (#4643)
add 144b2f944e IGNITE-23538 `ItRebalanceDistributedTest` is fixed and
corresponding changes are made also for `ItReplicaLifecycleTest` (#4647)
add d8503f65af IGNITE-23553 Only notify FailureHandler about first watch
notification failure (#4642)
add 1fafc2558e IGNITE-23208 Cluster wide CLI management of metrics (#4598)
add 201ef8cb11 IGNITE-23342 :platforms:zipCppClient task fails (#4639)
add f0a2e0d7f2 IGNITE-23552 Fix flaky
ItThinClientTupleComputeMarshallingTest (#4641)
add 66fc9254ee IGNITE-23450 Implement partitionDistributionResetTimeout
system distributed property (#4644)
add 434f6326b9 IGNITE-23279 Add Metastorage Compaction Trigger
Configuration (#4623)
add 344d25dd69 IGNITE-23285 Fix Mapper.nativelySupported (#4645)
add c81b60bac8 IGNITE-23574 Fix for cluster configurations of
ItRebalanceDistributedTest (#4651)
add 480ffe8f84 Bump jackson from 2.18.0 to 2.18.1 (#4650)
add 0341f563f5 IGNITE-23570 Improve tasks dependencies (#4648)
add fe53e7d5c5 IGNITE-23575 Fix docfx build on CI (#4656)
add f21ce1cae3 IGNITE-23268 Fix Catalog API temporal type mapping (#4646)
add 779549e133 IGNITE-23576 Fix :packaging-odbc:distZip (#4655)
add f648c847a4 IGNITE-19713 Start partition storages only for locally
assigned partitions (#4649)
add 599470a6c1 IGNITE-23567 Store Metastorage checksums durably (#4654)
add faad7e2992 IGNITE-23579 Improve diagnostics of CMG/MG disaster
recovery (#4658)
add d46219739f IGNITE-23456 Fix RetryLimitPolicy behavior (#4657)
add 8c893682b1 Bump bouncycastle from 1.78.1 to 1.79 (#4659)
add 8682358369 IGNITE-23128 Use a placeholder StorageEngine for tables
with unknown storage engine (#4640)
add ac40e77614 IGNITE-23581 Fix
ItMetastorageGroupDisasterRecoveryTest#oldMgLeaderDoesNotHijackLeadership()
(#4661)
add 721055eab5 IGNITE-23586 Update DEVNOTES.md according to current CLI
implementation (#4666)
add 3f91738073 IGNITE-23583 Optimize HybridTimestamp serialization (#4664)
add 3c4313265e IGNITE-23585 Fix flaky DeploymentUnitAcquiredWaiterTest
(#4665)
add 0f03f4ba38 Bump com.github.spotbugs from 6.0.25 to 6.0.26 (#4669)
add f1b1b6061f IGNITE-23544 Sql. Rework query execution pipeline (#4653)
add d09ea51466 IGNITE-23353 Improve CREATE TABLE syntax (#4599)
add 4484002869 Bump net.bytebuddy:byte-buddy from 1.15.7 to 1.15.10 (#4674)
add 7de32e8c60 IGNITE-23292 Local startup of metastorage compaction on
node startup after recovery (#4663)
add d68ae13df7 IGNITE-23446 Fix false-positive hasNext flag returned from
sql cursor (#4662)
add 038f12f5ad IGNITE-23592 Align serialization methods of HybridTimestamp
(#4670)
add e95f577501 IGNITE-23582 Fix missing memory and GC settings (#4668)
add b509e8fb8b IGNITE-23596 Start of Metastorage Raft node blocks a
network thread (#4673)
add 75d060b19d IGNITE-23610 Log WriteCommand class when logging about long
WriteActionRequest processing (#4678)
add a5d5bd0c9c IGNITE-23614 Declare IGNITE3_EXTRA_JVM_ARGS as an ENV
variable in Dockerfile (#4680)
add 46a4462d45 IGNITE-23549 Flush Metastorage underlying storage to disk
after taking snapshot (#4679)
add 2f67393d28 IGNITE-23618 Fix dead lock when restoring metastorage
(#4682)
add 75d93a2482 IGNITE-23449 Add support of the new flag HA in zone
description (#4667)
add a404b155c8 IGNITE-22969 Sql. Gather execution nodes information from
placement driver (#4629)
add c04828abd1 IGNITE-23294 Handle Metastorage leader change case for
Compaction Trigger (#4687)
add 5ce4d3f70a IGNITE-23282 Clear the VersionedValue after metastorage
compaction is completed (#4671)
add 9bf62487d4 IGNITE-23523 Sql. Fixed incorrect time formatting in sql
logic tests (#4683)
add adbf87dfc6 IGNITE-23600 Extend GLOBAL_PARTITION_STATES and
LOCAL_PARTITION_STATES system views (#4681)
add 9d4b2852cb IGNITE-23571 resetPartitions improvements: do not try to
recover replica factor after not manual reset (#4686)
add d6212ea6b2 IGNITE-23631 Optimize NetworkMessageChunkedInput
constructor (#4689)
add a936ffa476 IGNITE-22759 Do not do partition SafeTime sync if previous
attempt is not finished (#4684)
add 67b3167075 IGNITE-23621 Data Streamer: report failed entries on error
(#4691)
add 7ba3503318 Ignite-23644 Unmute testDropColumn and
testMergeChangesAddDropAdd in ItSchemaChangeKvViewTest (#4695)
add ec70aea639 IGNITE-23430: Sql. Provide an ability to cancel query
before first page ready (#4615)
add 29d30b2fc9 IGNITE-23616 Found a performance drop in Ignite benchmarks
(#4694)
add 48de8ec84f IGNITE-23643 Improve logging on
ClusterManagementGroupManager startup (#4693)
add 78472d85c1 IGNITE-23652 Don't swallow component stop exception (#4703)
add 6ac539cb3f IGNITE-20322 Add ability to pass an observable timestamp to
an implicit transaction (#2537)
add aef712f605 IGNITE-23317 Sql. Added additional dynamic parameters
validation for internal testing (#4692)
add e3cc2bebef IGNITE-23649 Check whether leader host is null within
refreshAndGetLeaderWithTerm. (#4701)
add b695bfeec0 IGNITE-23638 Remove unnecessary shrink calls in the
big_number C++ implementation (#4702)
add f764b2d5d4 IGNITE-23134 Add transactional benchmarks to measure
operations with lock conficts (#4685)
add 3cf4d806d9 IGNITE-23568 Setting the partition reset timer on topology
or configuration updates (#4675)
add 4abfb8a74f IGNITE-22742 DB API Driver: Implement execution with a
batch of parameters (#4704)
add 52df5378d1 IGNITE-23659 Remove dubious sneakyThrow usages (#4709)
add 7004eac141 Bump netty from 4.1.114.Final to 4.1.115.Final (#4705)
add 58477dfccb Bump MessagePack from 2.5.187 to 2.5.192 in
/modules/platforms/dotnet (#4708)
add fe5b642c63 IGNITE-23662 Mute several flaky tests in
ItIgniteDistributionZoneManagerNodeRestartTest (#4710)
add 6dc84b0ae9 IGNITE-23664 Simplify working with locks in
PartitionReplicaLifecycleManager (#4712)
add 5e47e6b31f IGNITE-23663 Sql. Make TestNode to use QueryExecutor (#4711)
add 7d056984a7 IGNITE-23423 Provide system view for running compute jobs
(#4699)
add 3f8ccfc9fb IGNITE-23667 Stop already started components if start phase
fails (#4715)
add d999902b9e IGNITE-23665 Sql. Introduce query execution program (#4714)
add f1863bf680 IGNITE-23668 Fix ItReplicaLifecycleTest class cast
exception (#4716)
add fa7ff3f85a IGNITE-23672 Remove ClusterTime#now() (#4721)
add d48115f9d3 IGNITE-23385 Move fields added to SnapshotMeta from JRaft
to our own message (#4720)
add 8cecf78e30 IGNITE-23669 Add missing busy locks to
ClusterManagementGroupManager (#4717)
add 1a4e662b5f IGNITE-23666 Fix data streamer failed items (#4722)
add 4c36fbb9db IGNITE-23671 Fix IterableToPublisherAdapter (#4719)
add 16a312dcf9 IGNITE-23615 Use shared threadpools in RocksDbFlusher for
RocksDbKeyValueStorage (#4713)
add e247ad1047 IGNITE-22768 Sql. Worker node left the cluster before
fragment has been sent (#4697)
add 16bac8d2e4 IGNITE-23661 Eliminate race in onBeforeApply within
StandaloneMetaStorageManager (#4723)
add 3c1cab2b06 IGNITE-23431 Added TRANSACTIONS system view (#4690)
add d6d402d84e IGNITE-23379 Pass lease information with Raft snapshot of
partition (#4725)
add 2d26566bac IGNITE-23686 Fix updateVersion task (#4728)
add ca0d2b5bc3 IGNITE-23691 Disable
ItTableRaftSnapshotsTest.txSemanticsIsMaintained (#4734)
add 323aa55d8e IGNITE-23697 Fix negative pin avgWriteSpeed in message
Checkpoint finished (#4735)
add 9238f27658 IGNITE-23683 Support format versioning when storing lease
data in RocksDB partitions (#4732)
add 435ffc218d IGNITE-23687 Add missing tests (#4729)
add 5ee728e1dc IGNITE-23689 Add tests for standalone compute (#4731)
add 56614d4e6a IGNITE-23076 Add shared timeout worker for all client
channels (#4730)
add b60a4e728b Bump Microsoft.Extensions.Logging.Console in
/modules/platforms/dotnet (#4718)
add 6884b67f87 IGNITE-23569 Fix TcpClientChannel.close reliability (#4737)
add 4ce7094b84 Bump io.swagger.core.v3:swagger-annotations from 2.2.25 to
2.2.26 (#4740)
add df8dd7a56d Bump org.openapi.generator from 7.9.0 to 7.10.0 (#4741)
add 31d3a200d4 IGNITE-22940 Expose partition size to public API (#4733)
add 9f7fe69434 Bump docfx from 2.77.0 to 2.78.0 in
/modules/platforms/dotnet (#4739)
add e66a33e016 IGNITE-23403 Remove Unused error codes (#4742)
add eedb6fc6de IGNITE-23587 Make PlacementDriver able to choose lease
candidate from pendings (#4707)
add b96da28e99 IGNITE-23700 Fix NPE in
AbstractTopologyAwareGroupServiceTest (#4743)
add 51df7cc1e2 IGNITE-17443 Implement OpenTelemetry metric exporter.
(#4531)
add 4d905ef98a IGNITE-23701 Add output of execution duration LogSyncer to
message "Checkpoint finished" (#4744)
add f9659dd3f6 IGNITE-23690 Fix
ItTableRaftSnapshotsTest.txSemanticsIsMaintained (#4745)
add 35eaa844f6 Merge branch 'main' into IGNITE-23054
No new revisions were added by this update.
Summary of changes:
DEVNOTES.md | 10 +-
build.gradle | 7 +-
docs/_docs/developers-guide/java-to-tables.adoc | 9 +-
docs/_docs/sql-reference/ddl.adoc | 43 +-
docs/_docs/sql-reference/distribution-zones.adoc | 16 +-
docs/_docs/sql-reference/grammar-reference.adoc | 12 +-
.../example/storage/StorageEngineExample.java | 2 +-
gradle.properties | 4 +
gradle/libs.versions.toml | 19 +-
modules/api/build.gradle | 17 +-
.../java/org/apache/ignite/catalog/ColumnType.java | 23 +-
.../org/apache/ignite/catalog/IgniteCatalog.java | 2 +-
.../apache/ignite/catalog/annotations/Zone.java | 7 +
.../catalog/definitions/TableDefinition.java | 2 +-
.../ignite/catalog/definitions/ZoneDefinition.java | 35 +-
.../java/org/apache/ignite/lang/CancelHandle.java | 62 ++
.../org/apache/ignite/lang/CancelHandleImpl.java | 163 +++++
.../org/apache/ignite/lang/CancellationToken.java} | 12 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 63 +-
.../main/java/org/apache/ignite/sql/IgniteSql.java | 189 ++++-
.../apache/ignite/table/DataStreamerException.java | 84 +++
.../org/apache/ignite/table/mapper/Mapper.java | 36 +-
.../apache/ignite/table/mapper/MapperBuilder.java | 2 +-
.../compaction/AbstractCatalogCompactionTest.java | 5 +-
.../internal/catalog/AllColumnTypesPojo.java} | 46 +-
.../ignite/internal/catalog/ItCatalogDslTest.java | 62 ++
.../internal/matcher/ZoneDefinitionMatcher.java | 18 +-
.../catalog/sql/CreateFromAnnotationsImpl.java | 4 +
.../catalog/sql/CreateFromDefinitionImpl.java | 4 +
.../internal/catalog/sql/CreateTableImpl.java | 11 +-
.../internal/catalog/sql/CreateZoneImpl.java | 15 +
.../internal/catalog/sql/IgniteCatalogSqlImpl.java | 7 +-
.../apache/ignite/internal/catalog/sql/Option.java | 8 +-
.../apache/ignite/internal/catalog/sql/Zone.java} | 21 +-
.../catalog/sql/CreateFromAnnotationsTest.java | 94 ++-
.../catalog/sql/CreateFromDefinitionTest.java | 28 +-
.../internal/catalog/sql/CreateTableTest.java | 2 +-
.../ignite/internal/catalog/sql/QueryPartTest.java | 12 -
.../internal/catalog/it/ItConcurrentDdlsTest.java | 2 +-
.../apache/ignite/internal/catalog/Catalog.java | 16 +-
.../catalog/CatalogParamsValidationUtils.java | 13 +
.../catalog/commands/AlterZoneCommand.java | 3 +-
.../internal/catalog/commands/CatalogUtils.java | 3 +
.../catalog/commands/CreateZoneCommand.java | 26 +-
.../catalog/commands/CreateZoneCommandBuilder.java | 9 +
.../catalog/commands/RenameZoneCommand.java | 3 +-
.../catalog/descriptors/CatalogZoneDescriptor.java | 27 +-
.../catalog/descriptors/ConsistencyMode.java | 66 ++
.../internal/catalog/storage/UpdateLogImpl.java | 9 +-
.../systemviews/ZonesSystemViewProvider.java | 1 +
.../catalog/CatalogManagerRecoveryTest.java | 22 +-
.../commands/AbstractCommandValidationTest.java | 13 +-
.../commands/CreateZoneCommandValidationTest.java | 10 +
.../descriptors/CatalogZoneDescriptorTest.java | 4 +-
.../storage/CatalogEntrySerializationTest.java | 4 +-
.../catalog/storage/UpdateLogImplTest.java | 4 +-
.../internal/catalog/BaseCatalogManagerTest.java | 6 +-
.../ignite/internal/catalog/CatalogTestUtils.java | 6 +-
modules/cli/build.gradle | 1 +
.../ignite/internal/cli/CliIntegrationTest.java | 16 +-
.../cli/call/metric/ItEnabledMetricCallsTest.java | 3 +-
.../cli/call/metric/ItMetricCallsTest.java | 56 +-
.../cli/commands/ItNonInitializedClusterTest.java | 161 -----
...t.java => ItNotInitializedClusterReplTest.java} | 9 +-
.../cli/commands/ItNotInitializedClusterTest.java | 80 +++
.../ItTopologyCommandInitializedClusterTest.java | 2 +-
...ItTopologyCommandNotInitializedClusterTest.java | 15 -
.../metric/ItClusterMetricCommandReplTest.java} | 19 +-
.../metric/ItClusterMetricCommandTest.java | 119 ++++
.../ItEnabledNodeMetricCommandReplTest.java} | 14 +-
.../metric/ItEnabledNodeMetricCommandTest.java | 6 +-
.../metric/ItNodeMetricCommandReplTest.java} | 19 +-
.../commands/metric/ItNodeMetricCommandTest.java | 76 +-
.../cluster/ItSystemDisasterRecoveryCliTest.java | 12 +-
.../partitions/reset/ItResetPartitionsTest.java | 2 +-
.../restart/ItRestartPartitionsTest.java | 2 +-
.../partitions/states/ItPartitionStatesTest.java | 33 +-
.../cli/commands/sql/ItSqlCommandTest.java | 12 -
.../repl/executor/ItIgnitePicocliCommandsTest.java | 3 +-
.../internal/rest/ItGeneratedRestClientTest.java | 9 +-
.../metric/ClusterMetricSourceEnableCall.java} | 30 +-
.../metric/ClusterMetricSourceListCall.java} | 36 +-
.../MetricSourceEnableCallInput.java} | 30 +-
.../node/metric/NodeMetricSourceEnableCall.java | 16 +-
.../call/recovery/cluster/ResetClusterCall.java | 1 +
.../recovery/cluster/ResetClusterCallInput.java | 33 +-
.../call/recovery/states/PartitionStatesCall.java | 7 +-
.../ignite/internal/cli/commands/Options.java | 5 +
.../cli/commands/cluster/ClusterCommand.java | 4 +-
.../cli/commands/cluster/ClusterReplCommand.java | 4 +-
.../cluster/metric/ClusterMetricCommand.java} | 14 +-
.../cluster/metric/ClusterMetricReplCommand.java} | 14 +-
.../metric/ClusterMetricSourceCommand.java} | 27 +-
.../metric/ClusterMetricSourceDisableCommand.java} | 34 +-
.../ClusterMetricSourceDisableReplCommand.java} | 37 +-
.../metric/ClusterMetricSourceEnableCommand.java} | 34 +-
.../ClusterMetricSourceEnableReplCommand.java} | 37 +-
.../metric/ClusterMetricSourceListCommand.java} | 25 +-
.../ClusterMetricSourceListReplCommand.java} | 26 +-
.../metric/ClusterMetricSourceReplCommand.java} | 27 +-
.../cli/commands/metric/MetricSourceMixin.java | 10 +-
.../node/metric/NodeMetricSourceListCommand.java | 2 +-
.../metric/NodeMetricSourceListReplCommand.java | 2 +-
.../recovery/cluster/reset/ResetClusterMixin.java | 25 +-
.../cli/commands/sql/help/IgniteSqlCommand.java | 4 +-
....java => ClusterMetricSourceListDecorator.java} | 28 +-
.../cli/decorators/MetricSourceListDecorator.java | 2 +-
.../cli/commands/node/metric/NodeMetricTest.java | 2 +-
.../cluster/reset/ResetClusterCommandTest.java | 130 ++++
.../handler/ClientInboundMessageHandler.java | 47 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 2 +
.../requests/sql/ClientSqlExecuteRequest.java | 9 +-
.../handler/requests/table/ClientTableCommon.java | 33 +-
.../table/ClientTupleDeleteAllExactRequest.java | 20 +-
.../table/ClientTupleDeleteAllRequest.java | 21 +-
.../table/ClientTupleDeleteExactRequest.java | 16 +-
.../requests/table/ClientTupleDeleteRequest.java | 16 +-
.../requests/table/ClientTupleGetAllRequest.java | 1 +
.../table/ClientTupleGetAndDeleteRequest.java | 21 +-
.../table/ClientTupleGetAndReplaceRequest.java | 21 +-
.../table/ClientTupleGetAndUpsertRequest.java | 21 +-
.../requests/table/ClientTupleGetRequest.java | 19 +-
.../table/ClientTupleInsertAllRequest.java | 21 +-
.../requests/table/ClientTupleInsertRequest.java | 16 +-
.../table/ClientTupleReplaceExactRequest.java | 16 +-
.../requests/table/ClientTupleReplaceRequest.java | 16 +-
.../table/ClientTupleUpsertAllRequest.java | 20 +-
.../requests/table/ClientTupleUpsertRequest.java | 21 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 4 +-
.../ignite/client/handler/FakeCatalogService.java | 14 +-
.../ignite/client/handler/FakePlacementDriver.java | 5 +
.../org/apache/ignite/client/RetryLimitPolicy.java | 8 +-
.../internal/client/ClientTimeoutWorker.java | 91 +++
.../ignite/internal/client/TcpClientChannel.java | 104 +--
.../ignite/internal/client/sql/ClientSql.java | 41 +-
...ctClientStreamerPartitionAwarenessProvider.java | 13 +-
.../ignite/internal/client/table/ClientTuple.java | 8 +
.../client/ClientKeyValueBinaryViewTest.java | 4 +
.../apache/ignite/client/ClientMetricsTest.java | 4 +-
.../org/apache/ignite/client/ClientTupleTest.java | 25 +
.../org/apache/ignite/client/ConnectionTest.java | 17 +-
.../org/apache/ignite/client/DataStreamerTest.java | 19 +-
.../org/apache/ignite/client/HeartbeatTest.java | 2 +-
.../client/ObservableTimestampPropagationTest.java | 4 +-
.../org/apache/ignite/client/SchemaUpdateTest.java | 2 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 10 +-
.../ignite/client/fakes/FakeIgniteTables.java | 10 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 20 +-
.../management/ClusterManagementGroupManager.java | 107 +--
.../ClusterStatePersistentSerializer.java | 38 -
.../cluster/management/MetaStorageInfo.java | 17 +-
.../raft/ClusterStateStorageManager.java | 19 +-
.../management/raft/CmgRaftGroupListener.java | 7 +-
.../cluster/management/raft/CmgRaftService.java | 8 +-
.../commands/ChangeMetaStorageInfoCommand.java | 7 -
.../management/raft/CmgRaftGroupListenerTest.java | 9 +-
.../build.gradle | 8 +-
.../metrics/message/MetricDisableRequest.java} | 13 +-
.../metrics/message/MetricDisableResponse.java} | 32 +-
.../metrics/message/MetricEnableRequest.java} | 13 +-
.../metrics/message/MetricEnableResponse.java} | 32 +-
.../internal/metrics/message/MetricSourceDto.java} | 26 +-
.../metrics/message/MetricSourcesRequest.java} | 12 +-
.../metrics/message/MetricSourcesResponse.java} | 35 +-
.../metrics/messaging/MetricMessageTypes.java | 55 ++
.../metrics/messaging/MetricMessaging.java | 290 ++++++++
.../metastore/DeploymentUnitStoreImplTest.java | 15 +-
.../DeploymentUnitAcquiredWaiterTest.java | 2 +-
modules/compute/build.gradle | 2 +
.../ignite/internal/compute/ItComputeBaseTest.java | 83 +++
.../internal/compute/ItComputeTestEmbedded.java | 83 ---
.../internal/compute/ItWorkerShutdownTest.java | 2 +-
.../internal/compute/ComputeComponentImpl.java | 13 +-
.../internal/compute/ComputeViewProvider.java | 79 +++
modules/{api => configuration-system}/build.gradle | 26 +-
.../SystemDistributedConfigurationModule.java} | 11 +-
.../SystemDistributedConfigurationSchema.java | 0
...temDistributedExtensionConfigurationSchema.java | 0
.../SystemLocalConfigurationModule.java | 5 +-
.../SystemLocalConfigurationSchema.java | 0
.../SystemLocalExtensionConfigurationSchema.java | 0
.../SystemPropertyConfigurationSchema.java | 16 +-
.../LongNumberSystemPropertyValueValidator.java | 67 ++
...eIntegerNumberSystemPropertyValueValidator.java | 66 ++
...LongNumberSystemPropertyValueValidatorTest.java | 106 +++
.../validation/TestValidationUtil.java | 9 +-
modules/core/build.gradle | 1 +
.../internal/causality/BaseVersionedValue.java | 67 +-
.../causality/CompletableVersionedValue.java | 10 +
.../DeletionListener.java} | 15 +-
.../causality/IncrementalVersionedValue.java | 100 ++-
.../internal/causality/OutdatedTokenException.java | 14 +-
.../internal/causality/RevisionListener.java} | 24 +-
.../RevisionListenerRegistry.java} | 13 +-
.../ignite/internal/causality/VersionedValue.java | 6 +
.../ignite/internal/components/LogSyncer.java | 1 +
.../NoOpLogSyncer.java} | 14 +-
.../internal/future/timeout/TimeoutWorker.java | 16 +-
.../ignite/internal/hlc/HybridTimestamp.java | 141 +++-
.../internal/lang/SafeTimeReorderException.java | 15 +-
...plicationGroupId.java => PartitionGroupId.java} | 11 +-
.../internal/replicator/ReplicationGroupId.java | 4 +-
.../internal/replicator/TablePartitionId.java | 9 +-
.../ignite/internal/streamer/StreamerBuffer.java | 32 +-
.../internal/streamer/StreamerSubscriber.java | 87 ++-
.../org/apache/ignite/internal/util/ByteUtils.java | 58 +-
.../apache/ignite/internal/util/Cancellable.java | 1 +
.../ignite/internal/util/CollectionUtils.java | 37 +-
.../apache/ignite/internal/util/GridUnsafe.java | 2 +-
.../internal/util/IgniteStripedReadWriteLock.java | 222 ++++++
.../ignite/internal/util/SubscriptionUtils.java | 28 +-
.../apache/ignite/internal/util/VarIntUtils.java | 24 +
.../subscription/IterableToPublisherAdapter.java | 35 +-
.../internal/versioned/VersionedSerializer.java | 40 ++
.../org/apache/ignite/lang/CancelHandleHelper.java | 71 ++
.../causality/IncrementalVersionedValueTest.java | 82 +--
.../internal/future/timeout/TimeoutWorkerTest.java | 2 +-
.../ignite/internal/hlc/HybridTimestampTest.java | 100 +++
.../ExecutorServiceExtensionTest.java | 238 +++++++
.../ignite/internal/util/CollectionUtilsTest.java | 10 +-
.../util/IgniteStripedReadWriteLockSelfTest.java | 326 +++++++++
.../IterableToPublisherAdapterTest.java | 93 +++
.../ignite/lang/CancelHandleHelperSelfTest.java | 292 ++++++++
.../causality/TestRevisionListenerRegistry.java | 48 ++
.../ignite/internal/streamer/DirectPublisher.java | 64 ++
.../testframework/ExecutorServiceExtension.java | 257 +++++++
.../testframework/InjectExecutorService.java | 66 ++
.../CompletableFutureExceptionMatcher.java | 7 +-
modules/distribution-zones/build.gradle | 3 +
.../ItDistributionZonesFiltersTest.java | 13 +-
...niteDistributionZoneManagerNodeRestartTest.java | 56 +-
.../distributionzones/AugmentationSerializer.java | 66 ++
.../distributionzones/DataNodesMapSerializer.java | 79 +++
.../distributionzones/DistributionZoneManager.java | 219 +++++-
.../distributionzones/DistributionZonesUtil.java | 23 +-
.../LogicalTopologySetSerializer.java | 75 ++
.../ignite/internal/distributionzones/Node.java | 5 +-
.../internal/distributionzones/NodeSerializer.java | 46 ++
.../distributionzones/NodeWithAttributes.java | 5 +-
.../NodeWithAttributesSerializer.java | 85 +++
.../NodesAttributesSerializer.java | 88 +++
.../TopologyAugmentationMapSerializer.java | 76 ++
.../CausalityDataNodesEngine.java | 18 +-
.../DistributionZonesConfigurationModule.java} | 21 +-
...ributionZonesHighAvailabilityConfiguration.java | 103 +++
.../rebalance/DistributionZoneRebalanceEngine.java | 15 +-
.../DistributionZoneRebalanceEngineV2.java | 5 +-
.../BaseDistributionZoneManagerTest.java | 27 +-
.../DataNodesMapSerializerTest.java | 57 ++
...istributionZoneManagerScaleUpScaleDownTest.java | 70 ++
.../DistributionZonesSchedulersTest.java | 92 ++-
.../LogicalTopologySetSerializerTest.java | 93 +++
.../NodeWithAttributesSerializerTest.java | 63 ++
.../NodesAttributesSerializerTest.java | 97 +++
.../TopologyAugmentationMapSerializerTest.java | 82 +++
.../DistributionZoneCausalityDataNodesTest.java | 15 +-
...tionZonesHighAvailabilityConfigurationTest.java | 111 +++
.../DistributionZoneRebalanceEngineTest.java | 11 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 4 +-
.../DistributionZonesTestUtil.java | 47 +-
.../internal/index/ItBuildIndexOneNodeTest.java | 2 +-
.../ignite/internal/index/ItBuildIndexTest.java | 2 +-
.../internal/index/IndexBuildingManager.java | 5 +-
.../apache/ignite/internal/index/IndexManager.java | 5 +-
.../internal/index/ChangeIndexStatusTaskTest.java | 7 +-
.../IndexAvailabilityControllerRestorerTest.java | 43 +-
.../index/IndexAvailabilityControllerTest.java | 29 +-
.../ignite/internal/index/IndexManagerTest.java | 40 +-
.../internal/index/TestIndexManagementUtils.java | 9 +-
.../ignite/internal/index/TestPlacementDriver.java | 5 +
modules/jdbc/build.gradle | 1 +
.../ignite/internal/lowwatermark/LowWatermark.java | 19 +-
.../internal/lowwatermark/LowWatermarkImpl.java | 14 +-
.../internal/lowwatermark/TestLowWatermark.java | 14 +-
.../CompactionRevisionUpdateListener.java} | 32 +-
.../internal/metastorage/MetaStorageManager.java | 10 +-
.../ignite/internal/metastorage/Revisions.java | 57 ++
...java => MetaStorageApiConfigurationModule.java} | 2 +-
.../metastorage/server/time/ClusterTime.java | 10 -
modules/metastorage/build.gradle | 7 +
.../metastorage/TestMetasStorageUtils.java | 67 ++
.../impl/ItIdempotentCommandCacheTest.java | 71 +-
.../ItMetaStorageCompactionTriggerOneNodeTest.java | 128 ++++
.../impl/ItMetaStorageCompactionTriggerTest.java | 184 +++++
.../impl/ItMetaStorageMaintenanceTest.java | 2 +
.../impl/ItMetaStorageManagerImplTest.java | 16 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 15 +-
.../ItMetaStorageMultipleNodesRocksDbTest.java | 16 +-
.../ItMetaStorageMultipleNodesVsStorageTest.java | 24 +-
...MetaStorageSafeTimePropagationAbstractTest.java | 9 +-
...tMetaStorageSafeTimePropagationRocksDbTest.java | 15 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 19 +-
.../metastorage/impl/ItMetaStorageServiceTest.java | 8 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 26 +-
.../server/raft/ItMetaStorageRaftGroupTest.java | 13 +-
.../service/ItAbstractListenerSnapshotTest.java | 4 +-
...RevisionCommand.java => CompactionCommand.java} | 14 +-
...evisionCommand.java => GetChecksumCommand.java} | 15 +-
...ommand.java => GetCurrentRevisionsCommand.java} | 11 +-
.../command/MetastorageCommandsMessageGroup.java | 10 +-
.../metastorage/command/response/ChecksumInfo.java | 69 ++
.../command/response/RevisionsInfo.java | 71 ++
.../MetaStorageConfigurationModule.java | 18 +-
.../impl/MetaStorageCompactionTrigger.java | 390 +++++++++++
.../MetaStorageCompactionTriggerConfiguration.java | 133 ++++
.../metastorage/impl/MetaStorageManagerImpl.java | 376 ++++++----
.../impl/MetaStorageRevisionListenerRegistry.java} | 25 +-
.../metastorage/impl/MetaStorageService.java | 11 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 58 +-
.../impl/MetastorageDivergedException.java} | 16 +-
.../impl/MetastorageDivergencyValidator.java | 60 ++
.../impl/RecoveryRevisionsListenerImpl.java | 102 +++
.../server/AbstractKeyValueStorage.java | 200 ++++--
.../metastorage/server/ChecksumAndRevisions.java | 51 ++
.../metastorage/server/KeyValueStorage.java | 101 +--
.../metastorage/server/KeyValueUpdateContext.java | 10 +
.../server/NotifyWatchProcessorEvent.java} | 24 +-
.../server/RecoveryRevisionsListener.java} | 26 +-
.../server/UpdateCompactionRevisionEvent.java} | 37 +-
.../metastorage/server/UpdateEntriesEvent.java} | 38 +-
...llback.java => WatchEventHandlingCallback.java} | 15 +-
.../metastorage/server/WatchProcessor.java | 93 ++-
.../server/persistence/RocksDbKeyValueStorage.java | 336 +++++----
.../server/raft/CommandResultAndTimestamp.java} | 18 +-
.../server/raft/MetaStorageListener.java | 44 +-
.../server/raft/MetaStorageWriteHandler.java | 101 +--
.../server/raft/MetastorageGroupId.java | 3 +-
.../metastorage/server/time/ClusterTimeImpl.java | 12 +-
.../impl/IdempotentCommandCacheTest.java | 2 +-
...aStorageCompactionTriggerConfigurationTest.java | 90 +++
.../MetaStorageDeployWatchesCorrectnessTest.java | 8 +-
.../impl/MetaStorageManagerRecoveryTest.java | 11 +-
.../impl/MetaStorageRocksDbRangeTest.java | 16 +-
.../impl/MetastorageDivergencyValidatorTest.java | 87 +++
.../AbstractCompactionKeyValueStorageTest.java | 103 ++-
.../server/BasicOperationsKeyValueStorageTest.java | 16 +-
.../RocksDbCompactionKeyValueStorageTest.java | 11 +-
.../server/RocksDbKeyValueStorageTest.java | 80 ++-
.../metastorage/server/WatchProcessorTest.java | 12 +-
.../metastorage/server/time/ClusterTimeTest.java | 15 +-
.../impl/StandaloneMetaStorageManager.java | 40 +-
.../server/SimpleInMemoryKeyValueStorage.java | 103 ++-
.../{core => metrics-exporter-otlp}/build.gradle | 51 +-
.../configuration/HeadersConfigurationSchema.java} | 14 +-
.../OtlpExporterConfigurationModule.java} | 20 +-
.../OtlpExporterConfigurationSchema.java | 65 ++
.../otlp/IgniteDistributionMetricData.java | 150 ++++
.../exporters/otlp/IgniteDoubleMetricData.java | 71 ++
.../metrics/exporters/otlp/IgniteGaugeData.java} | 26 +-
.../exporters/otlp/IgniteIntMetricData.java | 71 ++
.../exporters/otlp/IgniteLongMetricData.java | 71 ++
.../metrics/exporters/otlp/IgniteMetricData.java | 68 ++
.../metrics/exporters/otlp/IgnitePointData.java} | 24 +-
.../metrics/exporters/otlp/MetricReporter.java | 244 +++++++
.../exporters/otlp/OtlpPushMetricExporter.java | 116 +++
.../exporters/validator/EndpointValidator.java} | 15 +-
.../exporters/validator/EndpointValidatorImpl.java | 52 ++
.../exporters/otlp/OtlpPushMetricExporterTest.java | 159 +++++
.../validator/EndpointValidatorImplTest.java | 103 +++
.../metrics/exporters/ItJvmMetricSourceTest.java | 3 +-
.../exporters/ItMetricExportersLoadingTest.java | 3 +-
.../metrics/exporters/ItOsMetricSourceTest.java | 3 +-
.../metrics/exporters/TestDoubleStartExporter.java | 7 +-
.../metrics/exporters/TestPullMetricExporter.java | 6 +-
.../metrics/exporters/TestPushMetricExporter.java | 7 +-
.../ignite/internal/metrics/MetricManager.java | 14 +-
.../ignite/internal/metrics/MetricManagerImpl.java | 16 +-
.../metrics/exporters/BasicMetricExporter.java | 24 +-
.../internal/metrics/exporters/MetricExporter.java | 14 +-
.../metrics/exporters/PushMetricExporter.java | 7 +-
.../LogPushExporterConfigurationSchema.java | 3 +-
.../metrics/exporters/jmx/JmxExporter.java | 7 +-
.../metrics/exporters/log/LogPushExporter.java | 7 +-
.../internal/metrics/MetricConfigurationTest.java | 3 +-
.../internal/metrics/exporters/TestExporter.java | 6 +-
.../{ => exporters/jmx}/JmxExporterTest.java | 28 +-
.../ignite/internal/metrics/NoOpMetricManager.java | 4 +-
.../ignite/internal/network/NetworkMessage.java | 2 +-
.../internal/network/DefaultMessagingService.java | 1 -
.../internal/network/netty/OutboundEncoder.java | 36 +-
.../checkpoint/CheckpointMetricsTracker.java | 20 +
.../persistence/checkpoint/Checkpointer.java | 26 +-
.../persistence/compaction/Compactor.java | 2 +-
.../checkpoint/CheckpointMetricsTrackerTest.java | 15 +
modules/partition-distribution/build.gradle | 2 +
.../internal/partitiondistribution/Assignment.java | 5 +-
.../partitiondistribution/Assignments.java | 12 +-
.../AssignmentsSerializer.java | 79 +++
.../AssignmentsSerializerTest.java | 116 +++
.../RendezvousDistributionFunctionTest.java | 37 -
modules/partition-replicator/build.gradle | 1 +
.../replicator/ItReplicaLifecycleTest.java | 62 +-
.../replicator/utils/TestPlacementDriver.java | 5 +
.../PartitionReplicaLifecycleManager.java | 133 ++--
.../network/PartitionReplicationMessageGroup.java | 6 +
.../disaster/LocalPartitionStateMessage.java | 3 +
...etaResponse.java => PartitionSnapshotMeta.java} | 27 +-
.../network/raft/SnapshotMetaResponse.java | 3 +-
.../internal/placementdriver/PlacementDriver.java | 7 +
.../internal/placementdriver/ReplicaMeta.java | 3 +-
.../placementdriver/TestPlacementDriver.java | 5 +
modules/placement-driver/build.gradle | 2 +
.../internal/placementdriver/ActiveActorTest.java | 3 +-
.../ItPrimaryReplicaChoiceTest.java | 2 +-
.../MultiActorPlacementDriverTest.java | 2 +
.../PlacementDriverManagerTest.java | 2 +
.../placementdriver/AssignmentsTracker.java | 203 ++++--
.../internal/placementdriver/LeaseUpdater.java | 98 ++-
.../placementdriver/PlacementDriverManager.java | 10 +-
.../internal/placementdriver/leases/Lease.java | 111 ---
.../placementdriver/leases/LeaseBatch.java | 10 +-
.../leases/LeaseBatchSerializer.java | 534 ++++++++++++++
.../placementdriver/leases/NodesDictionary.java | 161 +++++
.../internal/placementdriver/LeaseUpdaterTest.java | 67 +-
.../placementdriver/PlacementDriverTest.java | 15 +-
.../leases/LeaseBatchSerializerTest.java | 258 +++++++
.../leases/LeaseSerializationTest.java | 32 +-
.../leases/NodesDictionaryTest.java | 169 +++++
modules/platforms/build.gradle | 112 ++-
modules/platforms/cpp/CMakeLists.txt | 9 +-
modules/platforms/cpp/_version.txt | 1 +
.../platforms/cpp/ignite/common/big_integer.cpp | 12 +-
.../platforms/cpp/ignite/common/bignum_test.cpp | 171 +++--
modules/platforms/cpp/ignite/common/detail/mpi.cpp | 16 +-
modules/platforms/cpp/ignite/common/detail/mpi.h | 21 +-
modules/platforms/cpp/ignite/common/error_codes.h | 45 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 10 +-
modules/platforms/dotnet/.config/dotnet-tools.json | 2 +-
modules/platforms/dotnet/.editorconfig | 2 +
.../Apache.Ignite.Benchmarks.csproj | 2 +-
.../Sql/ResultSetBenchmarks.cs | 2 +-
.../ExceptionTemplate.cs | 12 -
.../dotnet/Apache.Ignite.Tests/.editorconfig | 3 +
.../Apache.Ignite.Tests/Apache.Ignite.Tests.csproj | 6 +-
.../dotnet/Apache.Ignite.Tests/ExceptionsTests.cs | 37 -
.../Apache.Ignite.Tests/Linq/LinqTests.Dml.cs | 2 +-
.../Linq/LinqTests.Functions.cs | 1 +
.../Apache.Ignite.Tests/Linq/LinqTests.Join.cs | 8 +-
.../dotnet/Apache.Ignite.Tests/Linq/LinqTests.cs | 2 +
.../dotnet/Apache.Ignite.Tests/LoggingTests.cs | 2 -
.../dotnet/Apache.Ignite.Tests/SslTests.cs | 4 +-
.../dotnet/Apache.Ignite.Tests/VersionTests.cs | 4 +-
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 4 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 63 +-
.../IgniteClientConnectionException.cs | 12 -
.../dotnet/Apache.Ignite/IgniteClientException.cs | 12 -
.../dotnet/Apache.Ignite/IgniteException.cs | 25 -
.../Apache.Ignite/Internal/Buffers/PooledBuffer.cs | 8 +-
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 8 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 4 +-
.../Internal/Common/IgniteArgumentCheck.cs | 6 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 4 +-
.../Internal/Linq/IgniteQueryExpressionVisitor.cs | 4 +-
.../Internal/Linq/IgniteQueryParser.cs | 2 +-
.../BinaryTuple/BinaryTupleIgniteTupleAdapter.cs | 2 +-
.../Apache.Ignite/Internal/Proto/UuidSerializer.cs | 6 +-
.../Internal/Sql/ColumnTypeExtensions.cs | 2 +-
.../dotnet/Apache.Ignite/Internal/Sql/ResultSet.cs | 5 +-
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 4 +-
.../Apache.Ignite/Internal/Table/DataStreamer.cs | 2 +-
.../Internal/Table/DataStreamerWithReceiver.cs | 2 +-
.../Apache.Ignite/Internal/Table/RecordView.cs | 1 +
.../Table/Serialization/BinaryTupleMethods.cs | 4 +-
.../Table/Serialization/ReflectionUtils.cs | 9 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 5 +
modules/platforms/dotnet/Directory.Build.props | 4 +-
modules/platforms/dotnet/global.json | 2 +-
modules/platforms/dotnet/version.json | 21 +-
modules/platforms/python/CMakeLists.txt | 2 +-
modules/platforms/python/cpp_module/py_cursor.cpp | 230 +++++-
modules/platforms/python/pyignite3/__init__.py | 23 +-
modules/platforms/python/pyignite3/_version.txt | 1 +
modules/platforms/python/setup.py | 15 +-
.../python/tests/test_dbapi_compliance.py | 3 +-
.../platforms/python/tests/test_executemany.py | 30 +-
.../python/tests/test_fetch_parameters.py | 2 +-
modules/raft/build.gradle | 1 +
.../apache/ignite/internal/raft/ItLozaTest.java | 2 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 5 +-
.../internal/raft/server/impl/JraftServerImpl.java | 17 +-
.../storage/impl/DefaultLogStorageFactory.java | 16 +-
.../raft/storage/impl/RocksDbSharedLogStorage.java | 68 +-
.../storage/impl/RocksDbSharedLogStorageUtils.java | 16 +-
.../raft/storage/impl/RocksDbSpillout.java | 56 +-
.../storage/impl/VolatileLogStorageFactory.java | 10 +-
.../ignite/raft/jraft/entity/RaftOutter.java | 6 -
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 8 +
.../ignite/raft/jraft/rpc/WriteActionRequest.java | 7 +-
.../jraft/rpc/impl/ActionRequestProcessor.java | 7 +-
.../raft/jraft/rpc/WriteActionRequestTest.java | 81 +++
.../raft/client/TopologyAwareRaftGroupService.java | 22 +-
.../ignite/internal/replicator/ReplicaManager.java | 60 +-
.../ignite/internal/replicator/ReplicaService.java | 9 +-
.../ReplicationConfigurationSchema.java | 4 +
.../message/ReplicaSafeTimeSyncRequest.java | 3 +
.../AbstractTopologyAwareGroupServiceTest.java | 5 +-
modules/rest-api/build.gradle | 4 +-
.../ignite/internal/rest/api/Definition.java | 4 +-
.../internal/rest/api/metric/ClusterMetricApi.java | 83 +++
.../internal/rest/api/metric/MetricSource.java | 27 +
.../rest/api/metric/NodeMetricSources.java | 52 ++
.../api/recovery/GlobalPartitionStateResponse.java | 20 +-
.../api/recovery/LocalPartitionStateResponse.java | 32 +-
.../api/recovery/system/ResetClusterRequest.java | 6 +-
modules/rest/build.gradle | 1 +
.../rest/compute/ItComputeControllerTest.java | 87 +--
.../rest/metrics/ItMetricControllerTest.java | 182 +++++
...asterRecoveryControllerResetPartitionsTest.java | 3 +-
...terRecoveryControllerRestartPartitionsTest.java | 2 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 41 +-
.../rest/metrics/ClusterMetricController.java | 89 +++
.../internal/rest/metrics/MetricRestFactory.java | 13 +-
.../rest/recovery/DisasterRecoveryController.java | 26 +-
.../ignite/internal/rocksdb/ColumnFamily.java | 14 +
.../internal/rocksdb/flush/RocksDbFlusher.java | 22 +-
modules/runner/build.gradle | 4 +
.../benchmark/AbstractMultiNodeBenchmark.java | 29 +-
.../internal/benchmark/FutureTimeoutBenchmark.java | 3 -
.../internal/benchmark/LockManagerBenchmark.java | 2 +
.../ignite/internal/benchmark/SelectBenchmark.java | 4 +-
.../internal/benchmark/SqlIndexScanBenchmark.java | 2 +-
.../benchmark/SqlMultiStatementBenchmark.java | 4 +-
.../TxBalanceRetryOperationBenchmark.java | 226 ++++++
.../benchmark/TxUpsertRetryOperationBenchmark.java | 215 ++++++
.../internal/benchmark/UpsertKvBenchmark.java | 59 +-
.../ItDistributedConfigurationPropertiesTest.java | 21 +-
.../ItDistributedConfigurationStorageTest.java | 22 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 16 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 2 +-
.../runner/app/ItIgniteNodeRestartTest.java | 45 +-
.../runner/app/ItReplicaStateManagerTest.java | 2 +-
.../runner/app/ItSchemaChangeKvViewTest.java | 2 -
.../app/client/ItAbstractThinClientTest.java | 8 +-
.../app/client/ItThinClientObservationTsTest.java | 68 ++
.../ItThinClientTupleComputeMarshallingTest.java | 26 +-
.../schemasync/ItSchemaSyncAndReplicationTest.java | 2 +-
.../schemasync/ItSchemaSyncMultiNodeTest.java | 2 +-
.../streamer/ItAbstractDataStreamerTest.java | 94 ++-
.../streamer/ItClientDataStreamerLoadTest.java | 150 ++++
.../ignite/internal/table/ItDurableFinishTest.java | 2 +-
.../ignite/internal/table/ItInternalTableTest.java | 6 +-
.../internal/table/ItReadOnlyTransactionTest.java | 2 +-
.../ignite/internal/table/ItTableScanTest.java | 62 +-
.../partition/ItAbstractPartitionManagerTest.java | 2 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 132 ++--
.../ignite/internal/app/IgniteServerImpl.java | 37 +-
.../ignite/internal/app/LifecycleManager.java | 17 +-
.../storage/DistributedConfigurationStorage.java | 4 +-
.../internal/restart/RestartProofIgniteSql.java | 76 +-
.../ignite/internal/app/LifecycleManagerTest.java | 62 ++
.../ignite/internal/BaseIgniteRestartTest.java | 7 +-
.../java/org/apache/ignite/internal/Cluster.java | 8 +
.../internal/ClusterPerClassIntegrationTest.java | 12 +-
.../internal/ClusterPerTestIntegrationTest.java | 2 +-
.../ignite/internal/schema/SchemaManager.java | 5 +-
.../ignite/internal/schema/SchemaManagerTest.java | 18 +-
.../internal/schema/marshaller/MapperTest.java | 9 +-
modules/sql-engine/build.gradle | 2 +
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 4 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 98 +++
.../sql/api/ItSqlClientAsynchronousApiTest.java | 13 +
.../sql/api/ItSqlClientSynchronousApiTest.java | 13 +
.../internal/sql/api/ItSqlSynchronousApiTest.java | 88 +++
.../sql/engine/BaseSqlMultiStatementTest.java | 2 +-
.../internal/sql/engine/ItAggregatesTest.java | 2 +-
.../sql/engine/ItComputeSystemViewTest.java | 301 ++++++++
.../internal/sql/engine/ItCreateTableDdlTest.java | 34 +-
.../sql/engine/ItDynamicParameterTest.java | 14 +
.../internal/sql/engine/ItIndexSpoolTest.java | 4 +-
.../sql/engine/ItNotNullConstraintTest.java | 5 +-
.../sql/engine/ItPkOnlyTableCrossApiTest.java | 2 +-
.../internal/sql/engine/ItQueryCancelTest.java | 255 +++++++
.../sql/engine/ItSqlQueriesSystemViewTest.java | 354 ++++++++++
.../sql/engine/ItTransactionsSystemViewTest.java | 138 ++++
.../sql/engine/ItUnstableTopologyTest.java | 92 +++
.../internal/sql/engine/ItZonesSystemViewTest.java | 118 +++-
.../apache/ignite/internal/sql/sqllogic/Query.java | 8 +
.../aggregates/test_aggregate_types_scalar.test | 70 +-
.../test_aggregate_types_scalar.test_ignored | 111 ---
.../integrationTest/sql/cast/test_cast_format.test | 6 +-
.../sql/cast/test_cast_timestamp.test | 10 +-
...stampadd.test_ignore => test_timestampadd.test} | 33 +-
.../integrationTest/sql/set/test_basic_union.test | 2 -
...nstants.test_ignore => interval_constants.test} | 13 +-
...ion.test_ignore => test_interval_addition.test} | 7 +-
.../integrationTest/sql/types/time/test_time.test | 2 +-
.../sql/types/timestamp/test_timestamp.test | 74 +-
.../sql/types/timestamp/test_timestamp.test_ignore | 144 ----
...stamp_ms.test_ignore => test_timestamp_ms.test} | 1 -
modules/sql-engine/src/main/codegen/config.fmpp | 5 +-
.../src/main/codegen/includes/parserImpls.ftl | 44 +-
.../internal/lang/SqlExceptionMapperUtil.java | 12 +
.../ignite/internal/sql/api/IgniteSqlImpl.java | 65 +-
.../sql/api/PublicApiThreadingIgniteSql.java | 37 +-
.../sql/engine/InflightTransactionTracker.java} | 28 +-
.../ignite/internal/sql/engine/QueryCancel.java | 120 +---
.../ignite/internal/sql/engine/QueryProcessor.java | 15 +-
.../internal/sql/engine/SqlOperationContext.java | 42 +-
.../sql/engine/SqlQueriesViewProvider.java | 109 +++
.../internal/sql/engine/SqlQueryProcessor.java | 647 ++---------------
.../internal/sql/engine/exec/ExecutionContext.java | 43 +-
.../internal/sql/engine/exec/ExecutionService.java | 11 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 258 ++++---
.../TransactionTracker.java} | 16 +-
.../exec/fsm/CursorInitializationPhaseHandler.java | 94 +++
.../sql/engine/exec/fsm/ExecutionPhase.java | 50 ++
.../engine/exec/fsm/ExecutionPhaseHandler.java} | 12 +-
.../sql/engine/exec/fsm/MultiStatementHandler.java | 280 ++++++++
.../internal/sql/engine/exec/fsm/NoOpHandler.java} | 16 +-
.../engine/exec/fsm/OptimizingPhaseHandler.java | 105 +++
.../sql/engine/exec/fsm/ParsingPhaseHandler.java | 82 +++
.../internal/sql/engine/exec/fsm/Program.java | 139 ++++
.../{ExecutionService.java => fsm/Programs.java} | 19 +-
.../ignite/internal/sql/engine/exec/fsm/Query.java | 140 ++++
.../sql/engine/exec/fsm/QueryExecutionProgram.java | 102 +++
.../sql/engine/exec/fsm/QueryExecutor.java | 347 +++++++++
.../internal/sql/engine/exec/fsm/QueryInfo.java | 114 +++
.../engine/exec/fsm/RegisteredPhaseHandler.java} | 16 +-
.../internal/sql/engine/exec/fsm/Result.java | 63 ++
.../fsm/ScriptInitializationPhaseHandler.java} | 32 +-
.../exec/fsm/ScriptItemExecutionProgram.java | 55 ++
.../internal/sql/engine/exec/fsm/Transition.java} | 38 +-
.../sql/engine/exec/fsm/ValidationHelper.java | 76 ++
...der.java => ExecutionDistributionProvider.java} | 20 +-
.../ExecutionDistributionProviderImpl.java} | 59 +-
.../sql/engine/exec/mapping/MappingContext.java | 11 +-
.../sql/engine/exec/mapping/MappingException.java} | 14 +-
.../sql/engine/exec/mapping/MappingParameters.java | 28 +-
.../engine/exec/mapping/MappingServiceImpl.java | 437 +++++++-----
.../mapping/largecluster/LargeClusterFactory.java | 24 +-
.../mapping/smallcluster/SmallClusterFactory.java | 25 +-
.../sql/engine/exec/rel/AsyncRootNode.java | 26 +-
.../sql/engine/message/MessageService.java | 3 +
.../sql/engine/message/MessageServiceImpl.java | 13 +-
.../sql/engine/message/UnknownNodeException.java} | 31 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 2 -
.../prepare/ddl/DdlSqlToCommandConverter.java | 66 +-
.../sql/engine/prepare/ddl/ZoneOptionEnum.java | 5 +-
.../sql/engine/sql/IgniteSqlCreateTable.java | 37 +-
.../sql/engine/sql/IgniteSqlCreateTableOption.java | 120 ----
.../sql/engine/tx/QueryTransactionContextImpl.java | 17 +-
.../sql/engine/tx/QueryTransactionWrapperImpl.java | 24 +-
.../sql/engine/tx/ScriptTransactionContext.java | 16 +-
.../engine/tx/ScriptTransactionWrapperImpl.java | 10 +-
.../ignite/internal/sql/engine/util/Commons.java | 7 +
.../ignite/internal/sql/engine/util/TypeUtils.java | 17 +-
.../ignite/internal/sql/api/IgniteSqlImplTest.java | 20 +-
.../engine/QueryTransactionWrapperSelfTest.java | 64 +-
.../sql/engine/benchmarks/SqlBenchmark.java | 31 +-
.../exec/ExecutableTableRegistrySelfTest.java | 10 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 156 ++---
.../sql/engine/exec/QueryRecoveryTest.java | 231 ++++++
.../sql/engine/exec/TransactionEnlistTest.java | 51 +-
.../sql/engine/exec/TxAwareCursorSelfTest.java | 3 +-
.../exec/coercion/BaseTypeCheckExecutionTest.java | 20 +-
.../mapping/ExecutionTargetFactorySelfTest.java | 21 +-
.../engine/exec/mapping/FragmentMappingTest.java | 7 +-
.../exec/mapping/MappingServiceImplTest.java | 261 +++----
.../sql/engine/exec/mapping/MappingTestRunner.java | 22 +-
.../exec/mapping/MappingTestRunnerSelfTest.java | 2 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 2 +-
.../sql/engine/exec/rel/AsyncRootNodeTest.java | 122 ++++
.../engine/exec/rel/ScannableTableSelfTest.java | 8 +-
.../exec/rel/TableScanNodeExecutionTest.java | 18 +-
.../engine/framework/ClusterServiceFactory.java | 31 +-
.../sql/engine/framework/ExplicitTxContext.java | 16 +-
.../sql/engine/framework/ImplicitTxContext.java | 16 +-
.../sql/engine/framework/NoOpTransaction.java | 43 +-
.../engine/framework/NoOpTransactionTracker.java} | 20 +-
.../sql/engine/framework/TestBuilders.java | 401 ++++++-----
.../internal/sql/engine/framework/TestCluster.java | 17 +
.../sql/engine/framework/TestClusterTest.java | 120 +++-
.../internal/sql/engine/framework/TestNode.java | 148 ++--
.../sql/engine/planner/SelectCountPlannerTest.java | 4 +-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 96 ++-
.../DistributionZoneSqlToCommandConverterTest.java | 57 ++
.../sql/engine/sql/CommentParsingTest.java | 2 +-
.../sql/DistributionZoneSqlDdlParserTest.java | 7 +-
.../internal/sql/engine/sql/SqlDdlParserTest.java | 76 +-
.../internal/sql/engine/util/QueryCheckerTest.java | 52 +-
.../internal/sql/engine/util/QueryChecker.java | 2 +
.../internal/sql/engine/util/QueryCheckerImpl.java | 27 +-
.../internal/sql/engine/util/SqlTestUtils.java | 15 +-
modules/storage-api/README.md | 43 +-
.../internal/storage/DataStorageManager.java | 4 +-
.../internal/storage/engine/MvPartitionMeta.java} | 35 +-
.../internal/storage/engine/MvTableStorage.java | 12 +-
.../storage/engine/PrimitivePartitionMeta.java | 69 ++
.../engine/ThreadAssertingMvTableStorage.java | 9 +-
.../ignite/internal/storage/lease/LeaseInfo.java} | 37 +-
.../storage/lease/LeaseInfoSerializer.java | 48 ++
.../storage/lease/LeaseInfoSerializerTest.java | 61 ++
.../storage/AbstractMvTableStorageTest.java | 24 +-
.../storage/impl/TestMvPartitionStorage.java | 9 +-
.../internal/storage/impl/TestMvTableStorage.java | 20 +-
.../pagememory/AbstractPageMemoryTableStorage.java | 21 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 13 +
.../mv/PersistentPageMemoryMvPartitionStorage.java | 62 +-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 17 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 95 +--
.../storage/rocksdb/RocksDbTableStorage.java | 10 +-
modules/system-disaster-recovery/build.gradle | 1 +
.../disaster/system/ItCmgDisasterRecoveryTest.java | 14 +-
.../ItMetastorageGroupDisasterRecoveryTest.java | 152 +++-
.../system/ItSystemGroupDisasterRecoveryTest.java | 23 +-
.../system/SystemDisasterRecoveryClient.java | 34 +-
.../ResetClusterMessagePersistentSerializer.java | 31 -
.../system/SystemDisasterRecoveryManager.java | 2 +-
modules/table/build.gradle | 2 +
.../ItInternalTableReadOnlyScanTest.java | 2 +-
.../ItInternalTableReadWriteScanTest.java | 2 +-
.../apache/ignite/distributed/ItLockTableTest.java | 8 +-
.../distributed/ItPartitionStoragesTest.java | 77 ++
.../disaster/ItDisasterRecoveryManagerTest.java | 2 +-
.../ItDisasterRecoveryReconfigurationTest.java | 248 ++++++-
.../disaster/ItDisasterRecoverySystemViewTest.java | 83 ++-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 73 +-
.../rebalance/ItRebalanceDistributedTest.java | 62 +-
.../rebalance/ItRebalanceRecoveryTest.java | 2 +-
.../ignite/internal/rebalance/ItRebalanceTest.java | 2 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 6 +-
.../ignite/internal/table/ItColocationTest.java | 12 +-
.../ignite/internal/table/ItEstimatedSizeTest.java | 2 +-
.../internal/table/ItOperationRetryTest.java | 2 +-
.../table/ItTransactionPrimaryChangeTest.java | 2 +-
.../internal/table/ItTransactionRecoveryTest.java | 52 +-
.../internal/table/ItTxResourcesVacuumTest.java | 25 +-
.../internal/table/distributed/PartitionSet.java | 7 +-
.../internal/table/distributed/TableManager.java | 87 ++-
.../disaster/DisasterRecoveryManager.java | 83 ++-
.../DisasterRecoveryRequestSerializer.java | 6 +-
.../disaster/DisasterRecoverySystemViews.java | 6 +
.../distributed/disaster/GlobalPartitionState.java | 17 +-
...pUpdateRequest.java => GroupUpdateRequest.java} | 33 +-
...izer.java => GroupUpdateRequestSerializer.java} | 14 +-
.../distributed/disaster/LocalPartitionState.java | 22 +-
.../ManualGroupRestartRequestSerializer.java | 29 +-
.../distributed/index/IndexMetaSerializer.java | 10 +-
.../table/distributed/index/IndexMetaStorage.java | 5 +-
.../table/distributed/raft/PartitionListener.java | 11 +-
.../distributed/raft/snapshot/PartitionAccess.java | 29 +-
.../raft/snapshot/PartitionAccessImpl.java | 69 +-
.../snapshot/PartitionSnapshotStorageFactory.java | 56 +-
.../raft/snapshot/RaftSnapshotPartitionMeta.java | 79 +++
.../snapshot/incoming/IncomingSnapshotCopier.java | 11 +-
.../snapshot/incoming/IncomingSnapshotReader.java | 5 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 26 +-
.../raft/snapshot/outgoing/SnapshotMetaUtils.java | 24 +-
.../replicator/PartitionReplicaListener.java | 227 +++---
.../distributed/storage/InternalTableImpl.java | 244 ++++---
.../distributed/storage/NullMvTableStorage.java} | 107 ++-
.../distributed/storage/NullStorageEngine.java | 71 ++
.../storage/PartitionScanPublisher.java | 176 +++--
.../wrappers/DelegatingPlacementDriver.java | 5 +
.../internal/table/InteropOperationsTest.java | 10 +-
.../internal/table/TableKvOperationsTestBase.java | 10 +-
.../table/distributed/SortedIndexLockerTest.java | 10 +-
.../distributed/TableManagerRecoveryTest.java | 27 +-
.../table/distributed/TableManagerTest.java | 23 +-
.../DisasterRecoveryRequestSerializerTest.java | 37 +-
.../index/BaseIndexMetaStorageTest.java | 5 +-
.../distributed/index/IndexMetaSerializerTest.java | 14 +-
.../index/IndexMetaStorageRecoveryTest.java | 20 +-
.../FullStateTransferIndexChooserTest.java | 7 +-
.../incoming/IncomingSnapshotCopierTest.java | 31 +-
.../incoming/IncomingSnapshotReaderTest.java | 4 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 9 +-
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 27 +-
.../PartitionReplicaListenerIndexLockingTest.java | 9 +-
...itionReplicaListenerSortedIndexLockingTest.java | 9 +-
.../replication/PartitionReplicaListenerTest.java | 9 +-
.../storage/InternalTableEstimatedSizeTest.java | 2 +-
.../distributed/storage/InternalTableImplTest.java | 6 +-
.../storage/PartitionScanPublisherTest.java | 309 ++++++++
.../apache/ignite/distributed/ItTxTestCluster.java | 27 +-
.../ignite/internal/table/TxAbstractTest.java | 2 +-
.../table/impl/DummyInternalTableImpl.java | 2 +-
modules/transactions/build.gradle | 1 +
.../ignite/internal/tx/InternalTransaction.java | 15 +-
.../org/apache/ignite/internal/tx/LockKey.java | 2 +-
.../org/apache/ignite/internal/tx/LockManager.java | 7 +
.../org/apache/ignite/internal/tx/TxManager.java | 11 +-
.../ignite/internal/tx/TxMetaSerializer.java | 6 +-
.../org/apache/ignite/internal/tx/TxPriority.java | 13 +
...adlockPreventionPolicyConfigurationSchema.java} | 19 +-
.../TransactionConfigurationSchema.java | 4 +
.../tx/impl/DeadlockPreventionPolicyImpl.java | 92 +++
.../ignite/internal/tx/impl/HeapLockManager.java | 613 ++++++++++++----
.../internal/tx/impl/HeapUnboundedLockManager.java | 775 ---------------------
.../tx/impl/IgniteAbstractTransactionImpl.java | 34 +-
.../internal/tx/impl/IgniteTransactionsImpl.java | 14 +-
.../tx/impl/PublicApiThreadingTransaction.java | 10 +
.../internal/tx/impl/ReadOnlyTransactionImpl.java | 25 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 42 +-
.../internal/tx/impl/TransactionsViewProvider.java | 141 ++++
.../ignite/internal/tx/impl/TxManagerImpl.java | 42 +-
.../tx/impl/VolatileTxStateMetaStorage.java | 6 +
.../tx/AbstractDeadlockPreventionTest.java | 3 +-
.../internal/tx/AbstractLockManagerTest.java | 4 +-
.../ignite/internal/tx/AbstractLockingTest.java | 7 +
.../internal/tx/CoarseGrainedLockManagerTest.java | 368 ++++++++++
.../DeadlockPreventionPolicyConfigurationTest.java | 130 ++++
.../internal/tx/HeapLockManagerEventsTest.java | 2 +-
.../ignite/internal/tx/HeapLockManagerTest.java | 4 +-
.../internal/tx/NoWaitDeadlockPreventionTest.java | 12 +-
.../tx/ReversedDeadlockPreventionTest.java | 17 +-
.../internal/tx/TimeoutDeadlockPreventionTest.java | 9 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 64 +-
.../ignite/internal/tx/TxMetaSerializerTest.java | 15 +-
.../internal/tx/impl/OrphanDetectorTest.java | 9 +-
.../tx/impl/ReadOnlyTransactionImplTest.java | 1 +
.../tx/impl/ReadWriteTransactionImplTest.java | 4 +-
.../worker/ItCriticalWorkerMonitoringTest.java | 3 +-
packaging/build.gradle | 4 +-
packaging/cli/build.gradle | 4 +-
packaging/client/cpp/build.gradle | 4 +-
packaging/client/dotnet/build.gradle | 3 +-
packaging/client/java/build.gradle | 4 +-
packaging/common/linux/bootstrap-functions.sh | 6 +
packaging/common/windows/bootstrap-functions.bat | 12 +-
packaging/db/build.gradle | 4 +-
packaging/db/linux/service/vars.env | 4 +-
packaging/db/zip/linux/vars.env | 4 +-
packaging/db/zip/windows/vars.bat | 4 +-
packaging/docker/Dockerfile | 9 +
packaging/docker/docker-compose.yml | 3 +
packaging/docker/docker-entrypoint.sh | 6 +
settings.gradle | 6 +
828 files changed, 26518 insertions(+), 8746 deletions(-)
create mode 100644
modules/api/src/main/java/org/apache/ignite/lang/CancelHandle.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/lang/CancelHandleImpl.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/TableOptionEnum.java
=> api/src/main/java/org/apache/ignite/lang/CancellationToken.java} (76%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/DataStreamerException.java
copy
modules/{placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/ReplicaMeta.java
=>
catalog-dsl/src/integrationTest/java/org/apache/ignite/internal/catalog/AllColumnTypesPojo.java}
(53%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/TableOptionEnum.java
=> catalog-dsl/src/main/java/org/apache/ignite/internal/catalog/sql/Zone.java}
(75%)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/ConsistencyMode.java
delete mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/ItNonInitializedClusterTest.java
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/{ItReplNonInitializedClusterTest.java
=> ItNotInitializedClusterReplTest.java} (89%)
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/ItNotInitializedClusterTest.java
copy
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/ReversedDeadlockPreventionUnboundedTest.java
=>
cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/metric/ItClusterMetricCommandReplTest.java}
(66%)
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/metric/ItClusterMetricCommandTest.java
rename
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/NoWaitDeadlockPreventionUnboundedTest.java
=>
cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/metric/ItEnabledNodeMetricCommandReplTest.java}
(69%)
rename
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/ReversedDeadlockPreventionUnboundedTest.java
=>
cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/metric/ItNodeMetricCommandReplTest.java}
(67%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/{node/metric/NodeMetricSourceEnableCall.java
=> cluster/metric/ClusterMetricSourceEnableCall.java} (58%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/{node/metric/NodeMetricSourceEnableCall.java
=> cluster/metric/ClusterMetricSourceListCall.java} (54%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/{node/metric/NodeMetricSourceEnableCallInput.java
=> metric/MetricSourceEnableCallInput.java} (64%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/replicator/ReplicationGroupId.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/cluster/metric/ClusterMetricCommand.java}
(67%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/replicator/ReplicationGroupId.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/cluster/metric/ClusterMetricReplCommand.java}
(67%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/lang/SafeTimeReorderException.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/cluster/metric/ClusterMetricSourceCommand.java}
(59%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/{node/metric/NodeMetricSourceListCommand.java
=> cluster/metric/ClusterMetricSourceDisableCommand.java} (53%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/{node/metric/NodeMetricSourceListReplCommand.java
=> cluster/metric/ClusterMetricSourceDisableReplCommand.java} (54%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/{node/metric/NodeMetricSourceListCommand.java
=> cluster/metric/ClusterMetricSourceEnableCommand.java} (53%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/{node/metric/NodeMetricSourceListReplCommand.java
=> cluster/metric/ClusterMetricSourceEnableReplCommand.java} (54%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/{node/metric/NodeMetricSourceListCommand.java
=> cluster/metric/ClusterMetricSourceListCommand.java} (68%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/{node/metric/NodeMetricSourceListReplCommand.java
=> cluster/metric/ClusterMetricSourceListReplCommand.java} (69%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/lang/SafeTimeReorderException.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/cluster/metric/ClusterMetricSourceReplCommand.java}
(58%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/decorators/{MetricSourceListDecorator.java
=> ClusterMetricSourceListDecorator.java} (59%)
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/recovery/cluster/reset/ResetClusterCommandTest.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/ClientTimeoutWorker.java
copy modules/{partition-distribution => cluster-metrics}/build.gradle (83%)
copy
modules/{metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/GetCurrentRevisionCommand.java
=>
cluster-metrics/src/main/java/org/apache/ignite/internal/metrics/message/MetricDisableRequest.java}
(69%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/LocalPartitionStateMessage.java
=>
cluster-metrics/src/main/java/org/apache/ignite/internal/metrics/message/MetricDisableResponse.java}
(55%)
copy
modules/{metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/GetCurrentRevisionCommand.java
=>
cluster-metrics/src/main/java/org/apache/ignite/internal/metrics/message/MetricEnableRequest.java}
(69%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/LocalPartitionStateMessage.java
=>
cluster-metrics/src/main/java/org/apache/ignite/internal/metrics/message/MetricEnableResponse.java}
(55%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/replicator/ReplicationGroupId.java
=>
cluster-metrics/src/main/java/org/apache/ignite/internal/metrics/message/MetricSourceDto.java}
(61%)
copy
modules/{metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/GetCurrentRevisionCommand.java
=>
cluster-metrics/src/main/java/org/apache/ignite/internal/metrics/message/MetricSourcesRequest.java}
(71%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/LocalPartitionStateMessage.java
=>
cluster-metrics/src/main/java/org/apache/ignite/internal/metrics/message/MetricSourcesResponse.java}
(51%)
create mode 100644
modules/cluster-metrics/src/main/java/org/apache/ignite/internal/metrics/messaging/MetricMessageTypes.java
create mode 100644
modules/cluster-metrics/src/main/java/org/apache/ignite/internal/metrics/messaging/MetricMessaging.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/ComputeViewProvider.java
copy modules/{api => configuration-system}/build.gradle (62%)
copy
modules/{runner/src/main/java/org/apache/ignite/internal/configuration/SystemLocalConfigurationModule.java
=>
configuration-system/src/main/java/org/apache/ignite/internal/configuration/SystemDistributedConfigurationModule.java}
(81%)
rename modules/{runner =>
configuration-system}/src/main/java/org/apache/ignite/internal/configuration/SystemDistributedConfigurationSchema.java
(100%)
rename modules/{runner =>
configuration-system}/src/main/java/org/apache/ignite/internal/configuration/SystemDistributedExtensionConfigurationSchema.java
(100%)
copy modules/{runner =>
configuration-system}/src/main/java/org/apache/ignite/internal/configuration/SystemLocalConfigurationModule.java
(94%)
rename modules/{runner =>
configuration-system}/src/main/java/org/apache/ignite/internal/configuration/SystemLocalConfigurationSchema.java
(100%)
rename modules/{runner =>
configuration-system}/src/main/java/org/apache/ignite/internal/configuration/SystemLocalExtensionConfigurationSchema.java
(100%)
copy modules/{runner =>
configuration-system}/src/main/java/org/apache/ignite/internal/configuration/SystemPropertyConfigurationSchema.java
(60%)
create mode 100644
modules/configuration-system/src/main/java/org/apache/ignite/internal/configuration/validation/LongNumberSystemPropertyValueValidator.java
create mode 100644
modules/configuration-system/src/main/java/org/apache/ignite/internal/configuration/validation/NonNegativeIntegerNumberSystemPropertyValueValidator.java
create mode 100644
modules/configuration-system/src/test/java/org/apache/ignite/internal/configuration/validation/LongNumberSystemPropertyValueValidatorTest.java
copy
modules/core/src/main/java/org/apache/ignite/internal/{util/Cancellable.java =>
causality/DeletionListener.java} (63%)
copy
modules/{raft/src/main/java/org/apache/ignite/internal/raft/storage/impl/RocksDbSharedLogStorageUtils.java
=>
core/src/main/java/org/apache/ignite/internal/causality/RevisionListener.java}
(58%)
copy
modules/core/src/main/java/org/apache/ignite/internal/{replicator/ReplicationGroupId.java
=> causality/RevisionListenerRegistry.java} (78%)
copy
modules/core/src/main/java/org/apache/ignite/internal/{replicator/ReplicationGroupId.java
=> components/NoOpLogSyncer.java} (79%)
copy
modules/core/src/main/java/org/apache/ignite/internal/replicator/{ReplicationGroupId.java
=> PartitionGroupId.java} (75%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/IgniteStripedReadWriteLock.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/lang/CancelHandleHelper.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/testframework/ExecutorServiceExtensionTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/IgniteStripedReadWriteLockSelfTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/subscription/IterableToPublisherAdapterTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/lang/CancelHandleHelperSelfTest.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/causality/TestRevisionListenerRegistry.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/streamer/DirectPublisher.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/ExecutorServiceExtension.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/InjectExecutorService.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/AugmentationSerializer.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DataNodesMapSerializer.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/LogicalTopologySetSerializer.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/NodeSerializer.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/NodeWithAttributesSerializer.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/NodesAttributesSerializer.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/TopologyAugmentationMapSerializer.java
copy
modules/{metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/configuration/MetaStorageConfigurationModule.java
=>
distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/configuration/DistributionZonesConfigurationModule.java}
(59%)
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/configuration/DistributionZonesHighAvailabilityConfiguration.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/DataNodesMapSerializerTest.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/LogicalTopologySetSerializerTest.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/NodeWithAttributesSerializerTest.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/NodesAttributesSerializerTest.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/TopologyAugmentationMapSerializerTest.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/configuration/DistributionZonesHighAvailabilityConfigurationTest.java
copy
modules/{metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/raft/MetastorageGroupId.java
=>
metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/CompactionRevisionUpdateListener.java}
(56%)
create mode 100644
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/Revisions.java
copy
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/configuration/{MetaStorageConfigurationModule.java
=> MetaStorageApiConfigurationModule.java} (94%)
create mode 100644
modules/metastorage/src/integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageCompactionTriggerOneNodeTest.java
create mode 100644
modules/metastorage/src/integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageCompactionTriggerTest.java
copy
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/{GetCurrentRevisionCommand.java
=> CompactionCommand.java} (68%)
copy
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/{GetCurrentRevisionCommand.java
=> GetChecksumCommand.java} (69%)
rename
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/{GetCurrentRevisionCommand.java
=> GetCurrentRevisionsCommand.java} (73%)
create mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/response/ChecksumInfo.java
create mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/response/RevisionsInfo.java
copy modules/{metastorage-api =>
metastorage}/src/main/java/org/apache/ignite/internal/metastorage/configuration/MetaStorageConfigurationModule.java
(63%)
create mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetaStorageCompactionTrigger.java
create mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetaStorageCompactionTriggerConfiguration.java
copy
modules/metastorage/src/{test/java/org/apache/ignite/internal/metastorage/impl/MetaStorageRocksDbRangeTest.java
=>
main/java/org/apache/ignite/internal/metastorage/impl/MetaStorageRevisionListenerRegistry.java}
(52%)
copy
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerEventsTest.java
=>
metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetastorageDivergedException.java}
(62%)
create mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetastorageDivergencyValidator.java
create mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/RecoveryRevisionsListenerImpl.java
create mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/ChecksumAndRevisions.java
copy
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerTest.java
=>
metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/NotifyWatchProcessorEvent.java}
(61%)
copy
modules/{raft/src/main/java/org/apache/ignite/internal/raft/storage/impl/RocksDbSharedLogStorageUtils.java
=>
metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/RecoveryRevisionsListener.java}
(57%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/GlobalPartitionState.java
=>
metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/UpdateCompactionRevisionEvent.java}
(54%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/GlobalPartitionState.java
=>
metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/UpdateEntriesEvent.java}
(53%)
rename
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/{OnRevisionAppliedCallback.java
=> WatchEventHandlingCallback.java} (81%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/replicator/ReplicationGroupId.java
=>
metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/raft/CommandResultAndTimestamp.java}
(60%)
create mode 100644
modules/metastorage/src/test/java/org/apache/ignite/internal/metastorage/impl/MetaStorageCompactionTriggerConfigurationTest.java
create mode 100644
modules/metastorage/src/test/java/org/apache/ignite/internal/metastorage/impl/MetastorageDivergencyValidatorTest.java
copy modules/{core => metrics-exporter-otlp}/build.gradle (50%)
copy
modules/{runner/src/main/java/org/apache/ignite/internal/configuration/SystemPropertyConfigurationSchema.java
=>
metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/configuration/HeadersConfigurationSchema.java}
(76%)
rename
modules/{metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/configuration/MetaStorageConfigurationModule.java
=>
metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/configuration/OtlpExporterConfigurationModule.java}
(63%)
create mode 100644
modules/metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/configuration/OtlpExporterConfigurationSchema.java
create mode 100644
modules/metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/otlp/IgniteDistributionMetricData.java
create mode 100644
modules/metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/otlp/IgniteDoubleMetricData.java
copy
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerTest.java
=>
metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/otlp/IgniteGaugeData.java}
(59%)
create mode 100644
modules/metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/otlp/IgniteIntMetricData.java
create mode 100644
modules/metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/otlp/IgniteLongMetricData.java
create mode 100644
modules/metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/otlp/IgniteMetricData.java
rename
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapUnboundedLockManagerTest.java
=>
metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/otlp/IgnitePointData.java}
(60%)
create mode 100644
modules/metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/otlp/MetricReporter.java
create mode 100644
modules/metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/otlp/OtlpPushMetricExporter.java
copy
modules/{replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaSafeTimeSyncRequest.java
=>
metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/validator/EndpointValidator.java}
(69%)
create mode 100644
modules/metrics-exporter-otlp/src/main/java/org/apache/ignite/internal/metrics/exporters/validator/EndpointValidatorImpl.java
create mode 100644
modules/metrics-exporter-otlp/src/test/java/org/apache/ignite/internal/metrics/exporters/otlp/OtlpPushMetricExporterTest.java
create mode 100644
modules/metrics-exporter-otlp/src/test/java/org/apache/ignite/internal/metrics/exporters/validator/EndpointValidatorImplTest.java
rename modules/metrics/src/test/java/org/apache/ignite/internal/metrics/{ =>
exporters/jmx}/JmxExporterTest.java (86%)
create mode 100644
modules/partition-distribution/src/main/java/org/apache/ignite/internal/partitiondistribution/AssignmentsSerializer.java
create mode 100644
modules/partition-distribution/src/test/java/org/apache/ignite/internal/partitiondistribution/AssignmentsSerializerTest.java
copy
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft/{SnapshotMetaResponse.java
=> PartitionSnapshotMeta.java} (52%)
create mode 100644
modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/LeaseBatchSerializer.java
create mode 100644
modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/NodesDictionary.java
create mode 100644
modules/placement-driver/src/test/java/org/apache/ignite/internal/placementdriver/leases/LeaseBatchSerializerTest.java
create mode 100644
modules/placement-driver/src/test/java/org/apache/ignite/internal/placementdriver/leases/NodesDictionaryTest.java
create mode 100644 modules/platforms/cpp/_version.txt
create mode 100644 modules/platforms/python/pyignite3/_version.txt
copy packaging/docker/docker-entrypoint.sh =>
modules/platforms/python/tests/test_executemany.py (53%)
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/rpc/WriteActionRequestTest.java
create mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/metric/ClusterMetricApi.java
create mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/metric/NodeMetricSources.java
create mode 100644
modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/metrics/ItMetricControllerTest.java
create mode 100644
modules/rest/src/main/java/org/apache/ignite/internal/rest/metrics/ClusterMetricController.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/TxBalanceRetryOperationBenchmark.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/TxUpsertRetryOperationBenchmark.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientObservationTsTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/streamer/ItClientDataStreamerLoadTest.java
create mode 100644
modules/runner/src/test/java/org/apache/ignite/internal/app/LifecycleManagerTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItComputeSystemViewTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItQueryCancelTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlQueriesSystemViewTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItTransactionsSystemViewTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItUnstableTopologyTest.java
delete mode 100644
modules/sql-engine/src/integrationTest/sql/aggregate/aggregates/test_aggregate_types_scalar.test_ignored
rename
modules/sql-engine/src/integrationTest/sql/function/timestamp/{test_timestampadd.test_ignore
=> test_timestampadd.test} (78%)
rename
modules/sql-engine/src/integrationTest/sql/types/interval/{interval_constants.test_ignore
=> interval_constants.test} (82%)
rename
modules/sql-engine/src/integrationTest/sql/types/interval/{test_interval_addition.test_ignore
=> test_interval_addition.test} (96%)
delete mode 100644
modules/sql-engine/src/integrationTest/sql/types/timestamp/test_timestamp.test_ignore
rename
modules/sql-engine/src/integrationTest/sql/types/timestamp/{test_timestamp_ms.test_ignore
=> test_timestamp_ms.test} (86%)
copy
modules/{runner/src/main/java/org/apache/ignite/internal/configuration/SystemLocalConfigurationModule.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/InflightTransactionTracker.java}
(54%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueriesViewProvider.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{prepare/ddl/TableOptionEnum.java
=> exec/TransactionTracker.java} (69%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/CursorInitializationPhaseHandler.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/ExecutionPhase.java
copy
modules/{core/src/main/java/org/apache/ignite/internal/replicator/ReplicationGroupId.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/ExecutionPhaseHandler.java}
(74%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/MultiStatementHandler.java
rename
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/NoneDeadlockPreventionUnboundedTest.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/NoOpHandler.java}
(69%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/OptimizingPhaseHandler.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/ParsingPhaseHandler.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/Program.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{ExecutionService.java
=> fsm/Programs.java} (57%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/Query.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/QueryExecutionProgram.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/QueryExecutor.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/QueryInfo.java
rename
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/TimeoutDeadlockPreventionUnboundedTest.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/RegisteredPhaseHandler.java}
(69%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/Result.java
rename
modules/{runner/src/main/java/org/apache/ignite/internal/configuration/SystemLocalConfigurationModule.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/ScriptInitializationPhaseHandler.java}
(51%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/ScriptItemExecutionProgram.java
copy
modules/{placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/LeaseBatch.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/Transition.java}
(52%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/ValidationHelper.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{ExecutionTargetProvider.java
=> ExecutionDistributionProvider.java} (73%)
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{ExecutionTargetProviderImpl.java
=> exec/mapping/ExecutionDistributionProviderImpl.java} (79%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/replicator/ReplicationGroupId.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/MappingException.java}
(69%)
copy
modules/{raft/src/main/java/org/apache/ignite/internal/raft/storage/impl/RocksDbSharedLogStorageUtils.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/UnknownNodeException.java}
(56%)
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlCreateTableOption.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/QueryRecoveryTest.java
copy
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerTest.java
=>
sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/framework/NoOpTransactionTracker.java}
(64%)
copy
modules/{placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/ReplicaMeta.java
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/engine/MvPartitionMeta.java}
(51%)
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/PrimitivePartitionMeta.java
copy
modules/{placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/LeaseBatch.java
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/lease/LeaseInfo.java}
(50%)
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/lease/LeaseInfoSerializer.java
create mode 100644
modules/storage-api/src/test/java/org/apache/ignite/internal/storage/lease/LeaseInfoSerializerTest.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItPartitionStoragesTest.java
rename
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/{ManualGroupUpdateRequest.java
=> GroupUpdateRequest.java} (94%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/{ManualGroupUpdateRequestSerializer.java
=> GroupUpdateRequestSerializer.java} (73%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/RaftSnapshotPartitionMeta.java
copy
modules/{storage-api/src/main/java/org/apache/ignite/internal/storage/engine/ThreadAssertingMvTableStorage.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/storage/NullMvTableStorage.java}
(50%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/storage/NullStorageEngine.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/storage/PartitionScanPublisherTest.java
rename
modules/{runner/src/main/java/org/apache/ignite/internal/configuration/SystemPropertyConfigurationSchema.java
=>
transactions/src/main/java/org/apache/ignite/internal/tx/configuration/DeadlockPreventionPolicyConfigurationSchema.java}
(69%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/DeadlockPreventionPolicyImpl.java
delete mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/HeapUnboundedLockManager.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TransactionsViewProvider.java
create mode 100644
modules/transactions/src/test/java/org/apache/ignite/internal/tx/CoarseGrainedLockManagerTest.java
create mode 100644
modules/transactions/src/test/java/org/apache/ignite/internal/tx/DeadlockPreventionPolicyConfigurationTest.java
