This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-25135
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit cdb827310e1 Avoid using deprecated methods.
add f477c5550be IGNITE-27258 Wait for all nodes in MULTI_NODE disaster
recovery requests (#7156)
add f1f7198f1fa IGNITE-27456 Add test for race between starting index
build and writing committed values (#7311)
add 2f74b03afd8 IGNITE-27458 Stop PartitionReplicaListener being
ReplicaListener (#7313)
add 35d373c931f IGNITE-27452 Add --timed option to CLI (#7314)
add fb591a48fb7 IGNITE-27462 Restore specifics of
ItTxDistributedTestSingleNodeNoCleanupMessage (#7316)
add d25a5c2ac25 IGNITE-27345 NullPointerException in
WriteIntentSwitchRequestHandler (#7315)
add 49b45b03721 IGNITE-27293 Improve test coverage of InternalTable.scan
methods (#7270)
add 4cff628f9bb IGNITE-25836 Suppress client handler logs for cancellation
errors (#7306)
add fbf86d06945 IGNITE-27255 Fixed TxIdMismatchException due to write
attempt by RW transaction after write intent resolution (#7263)
add d90255b5bbe ignite-27446 Extended string and literals in union (#7297)
add 1b1f8af9950 IGNITE-27346 Handle 'LWM below earliest Catalog ts' on
recovery (#7326)
add 04fc38f6f3a IGNITE-27434 Create new RAFT client to wait for group
availability (#7286)
add b5bf0bb452c IGNITE-27453 Handle SafeTimeSyncCommand on zone level
(#7307)
add 87aafb41db1 IGNITE-24345 Defer zone destruction after drop (#7322)
add 0e18f86bf1c IGNITE-27278 .NET: Add mapper support to SQL, Compute,
PartitionManager APIs (#7305)
add 0202698b703 IGNITE-27323 Add suggestion about DDL queries batching
(#7246)
add 7df27a595d8 IGNITE-27188 Java client: Fix node restart handling (#7327)
add d94067c4dda IGNITE-27142 Remove non-clocated code (disaster recovery)
(#7265)
add 51ad1f918d3 IGNITE-27481 Do not take partition snapshot lock in table
raft processor (#7332)
add eed4ba0edd8 IGNITE-27477 Raise LWM on recovery if it lags behind
Catalog history (#7330)
add be5df8031e6 IGNITE-27356 Add checkpoint metrics (#7250)
add 14e03754680 IGNITE-27358 Add page memory metrics (#7320)
add ac18ff2b5e6 IGNITE-27488 Remove TablePartitionKey (#7335)
add 29afe19116b IGNITE-27479 System View. Introduce late materialization
for row from system views (#7333)
add 942e99fa932 IGNITE-26636 Introduce basic API for expression execution
and predicate implementation (#7303)
add 3b43d82d51e IGNITE-27421 Remove
IgniteSystemProperties#colocationEnabled usages from tests (#7334)
add 22ec1841def Bump com.github.siom79.japicmp:japicmp from 0.25.0 to
0.25.1 (#7296)
add b1451f8f189 Bump io.swagger.parser.v3:swagger-parser from 2.1.36 to
2.1.37 (#7281)
add 536a5817590 IGNITE-25801 Sql. Use
CoreRules.JOIN_SUB_QUERY_TO_CORRELATE instead of IgniteSubQueryRemoveRule
(#7337)
add 081a4e1b203 IGNITE-23226 Remove using javax.annotation.Nullable (#7342)
add 0eebf87abf0 Bump org.bouncycastle:bcpkix-jdk18on from 1.82 to 1.83
(#7338)
add 6bbf4137d60 Bump log4j from 2.25.2 to 2.25.3 (#7280)
add 1a958b56e68 Bump org.openapi.generator from 7.17.0 to 7.18.0 (#7339)
add c37bdf2edc5 IGNITE-27480 Flaky
testWriteIntentResolutionAfterTableAlreadyDestroyed (#7331)
add d11e62b50f1 IGNITE-24813 Java client: fix logging on server disconnect
(#7336)
add 8d3ca8cf4b9 IGNITE-27497 Reduce network timeout in
IncomingSnapshotCopier (#7344)
add ff9e052c23d IGNITE-22303 Sql. Retry operation when plan gets outdated
by the time of execution (#7309)
add eb52738326f Bump io.opentelemetry:opentelemetry-exporter-otlp from
1.55.0 to 1.57.0 (#7346)
add 9e435433044 Bump com.google.protobuf:protobuf-java from 4.33.1 to
4.33.2 (#7347)
add 512cf3fa3f1 Bump net.bytebuddy:byte-buddy from 1.18.1 to 1.18.3 (#7348)
add 075e6cef950 IGNITE-27504 Wait for partitions to be healthy before
restarting them in CLI tests (#7354)
add 110b103448e IGNITE-27498 Improve sendServerExceptionStackTraceToClient
message (#7345)
add 4aae911fec0 [IGNITE-27395] remove Todo (#7340)
add 74591aa468c IGNITE-27243 Throw a NullPointerException instead of a
BinaryTupleFormatException when attempting to read a null value into a
primitive (#7319)
add ae7dfca2d25 IGNITE-27486 .NET: Skip intensive tests on Windows (#7359)
add 9b7ebc3b641 IGNITE-27485 Increase timeouts in
ItAbstractDataStreamerTest (#7358)
add c3f458dc95c IGNITE-27509 Remove unnecessary classes in migration-tools
(#7366)
add 1b1df57e0a4 IGNITE-27503 Add DEVNOTES about client connection
management (#7357)
add dd80a5d6810 Bump com.github.spotbugs from 6.4.7 to 6.4.8 (#7352)
add 35c6f4a4fb7 Bump org.junit.platform:junit-platform-testkit from 1.14.0
to 1.14.1 (#7353)
add 7dec3be3789 Bump testcontainers from 2.0.0 to 2.0.3 (#7351)
add 16d400b0c5f IGNITE-27308 Improve the delta file merge pause strategy
(#7360)
add c254ff249a9 IGNITE-27517 Simplify the generic parameter of
TimeoutObject (#7368)
add d20d772b2b4 IGNITE-27505 Clarify OS CpuLoad metric description (#7378)
add 93bd10767d4 IGNITE-27519 Add CLAUDE.md with development guidelines for
AI assistants (#7373)
add 779a6051241 IGNITE-27487 .NET: Fix GetConnections race condition
(#7375)
add 74daeb948eb IGNITE-27525 .NET: Add version to api docs footer (#7376)
add 3977887c2c1 IGNITE-27004 Add tx labels to system views (#7323)
add e997cdf9ec9 IGNITE-27528 Make ConfigOverride repeatable (#7381)
add c8b8b0d287a Bump io.github.bonede:tree-sitter from 0.25.3 to 0.26.3
(#7371)
add 1c7f06d4b28 Bump value from 2.12.0 to 2.12.1 (#7370)
add 42b18d49fe7 IGNITE-22377 Fail one of nodes if a stale node detected
(#7248)
add f668aea589d Bump junit5 from 5.14.1 to 5.14.2 (#7369)
add 0151462aa58 IGNITE-27185 ItMetastorageRaftSnapshotCompatibilityTest is
broken (#7341)
add b246612777f IGNITE-27529 Fix circular exception chain in
ClientFutureUtils.doWithRetryAsync (#7384)
add bb06ba3f279 Avoid using deprecated methods.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (cdb827310e1)
\
N -- N -- N refs/heads/ignite-25135 (bb06ba3f279)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.claude/skills/ignite-cluster-setup/SKILL.md | 60 +
.justfile | 173 +++
.../platform_tests/PlatformDotnetTestsWindows.kt | 4 +-
CLAUDE.md | 124 ++
RELEASE.md | 7 +-
gradle/libs.versions.toml | 28 +-
.../SkipUnsupportedOperationsHandlers.java | 51 -
.../java/org/apache/ignite/lang/ErrorGroups.java | 6 +
.../java/org/apache/ignite/table/TupleImpl.java | 50 +-
.../org/apache/ignite/table/TupleImplTest.java | 5 +
.../ignite/table/AbstractImmutableTupleTest.java | 62 +
.../ignite/table/AbstractMutableTupleTest.java | 33 +
.../internal/binarytuple/BinaryTupleReader.java | 36 +-
modules/catalog-compaction/build.gradle | 4 +
...eryAfterCatalogTruncatedAboveStoredLwmTest.java | 126 ++
.../compaction/CatalogCompactionRunner.java | 20 +-
.../CatalogCompactionRunnerSelfTest.java | 2 +
.../systemviews/TablesSystemViewProvider.java | 23 +-
.../cli/commands/ItNotInitializedClusterTest.java | 4 +-
.../partitions/reset/ItResetPartitionsTest.java | 25 -
.../restart/ItRestartPartitionsTest.java | 44 +-
.../partitions/states/ItPartitionStatesTest.java | 22 +-
.../cli/commands/sql/ItSqlTimedOptionTest.java | 134 +++
.../repl/executor/ItIgnitePicocliCommandsTest.java | 3 +-
.../ignite/internal/cli/ssl/ItJdbcSslTest.java | 6 +-
.../call/recovery/reset/ResetPartitionsCall.java | 21 +-
.../recovery/reset/ResetPartitionsCallInput.java | 20 +-
.../recovery/restart/RestartPartitionsCall.java | 34 +-
.../restart/RestartPartitionsCallInput.java | 20 +-
.../call/recovery/states/PartitionStatesCall.java | 80 +-
.../ignite/internal/cli/commands/Options.java | 12 +-
.../partitions/reset/ResetPartitionsMixin.java | 10 -
.../partitions/restart/RestartPartitionsMixin.java | 12 +-
.../internal/cli/commands/sql/SqlCommand.java | 54 +-
.../internal/cli/commands/sql/SqlExecCommand.java | 7 +-
.../cli/commands/sql/SqlExecReplCommand.java | 7 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 53 +-
.../cli/decorators/SqlQueryResultDecorator.java | 8 +-
.../apache/ignite/internal/cli/sql/SqlManager.java | 2 +
.../ignite/internal/cli/sql/SqlQueryResult.java | 37 +-
.../internal/cli/commands/ProfileMixinTest.java | 4 +-
.../partitions/restart/RestartPartitionsTest.java | 10 +-
.../internal/cli/commands/sql/SqlCommandTest.java | 12 +
.../table/MutableTupleBinaryTupleAdapter.java | 169 ++-
.../client/handler/ItClientHandlerMetricsTest.java | 2 +-
.../ignite/client/handler/ItClientHandlerTest.java | 19 +-
.../apache/ignite/client/handler/TestServer.java | 5 +-
.../ignite/client/handler/ClientHandlerModule.java | 24 +-
.../handler/ClientInboundMessageHandler.java | 39 +-
.../handler/ClientPrimaryReplicaTracker.java | 25 +-
.../client/handler/DdlBatchingSuggester.java | 72 ++
.../requests/sql/ClientSqlExecuteRequest.java | 9 +-
.../handler/ClientPrimaryReplicaTrackerTest.java | 4 +-
.../client/handler/DdlBatchingSuggesterTest.java | 62 +
.../requests/table/ClientHandlerTupleTests.java | 50 +
.../ignite/client/handler/FakePlacementDriver.java | 21 +-
modules/client/DEVNOTES.md | 111 ++
modules/client/build.gradle | 1 +
.../ignite/internal/client/ClientFutureUtils.java | 28 +-
.../ignite/internal/client/ReliableChannel.java | 4 +-
.../ignite/internal/client/TcpClientChannel.java | 17 +-
.../client/io/ClientConnectionStateHandler.java | 2 +-
.../client/io/netty/NettyClientConnection.java | 3 +-
.../client/io/netty/NettyClientMessageHandler.java | 16 +-
.../org/apache/ignite/client/ClientTupleTest.java | 28 +
.../org/apache/ignite/client/ConnectionTest.java | 24 +
.../org/apache/ignite/client/ReconnectTest.java | 30 +-
.../ignite/client/TestClientHandlerModule.java | 7 +-
.../java/org/apache/ignite/client/TestServer.java | 41 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 12 +
.../internal/client/ClientFutureUtilsTest.java | 40 +
.../internal/client/sql/ClientSqlRowTest.java | 100 ++
.../management/topology/ItLogicalTopologyTest.java | 6 +
...ItMetastorageRaftSnapshotCompatibilityTest.java | 5 +-
.../ignite/internal/OpenApiCompatibilityTest.java | 31 +-
.../org/apache/ignite/internal/OpenApiMatcher.java | 22 +-
...SequentialDdlExecutionConfigurationSchema.java} | 14 +-
...stionsClusterExtensionConfigurationSchema.java} | 12 +-
.../SuggestionsConfigurationSchema.java} | 10 +-
...SuggestionsDistributedConfigurationModule.java} | 8 +-
.../components/SystemPropertiesNodeProperties.java | 35 -
.../internal/future/timeout/TimeoutObject.java | 4 +-
.../apache/ignite/internal/type/NativeTypes.java | 12 +-
.../org/apache/ignite/internal/util/Constants.java | 3 +
...teringIterator.java => FlatteningIterator.java} | 74 +-
.../apache/ignite/internal/util/IgniteUtils.java | 24 +
.../ignite/internal/util}/LongPriorityQueue.java | 4 +-
.../internal/util/SafeTimeValuesTracker.java | 2 +
.../internal/future/timeout/TimeoutWorkerTest.java | 29 +-
.../internal/util/FlatteningIteratorTest.java | 225 ++++
.../internal/util}/LongPriorityQueueSelfTest.java | 2 +-
.../util/PendingComparableValuesTrackerTest.java | 87 +-
.../PendingComparableValuesTrackerTestBase.java | 88 ++
.../internal/util/SafeTimeValuesTrackerTest.java | 86 ++
.../ItRebalanceByPendingAssignmentsQueueTest.java | 9 +-
.../rebalance/ItRebalanceDistributedTest.java | 12 +-
.../internal/rebalance/ItRebalanceMetricsTest.java | 2 -
.../distributionzones/DataNodesManager.java | 20 +-
.../distributionzones/DistributionZoneManager.java | 19 +-
...ibutionZoneManagerConfigurationChangesTest.java | 15 -
...istributionZoneManagerScaleUpScaleDownTest.java | 66 --
.../internal/network/file/TestTopologyService.java | 9 +-
.../index/ItIndexBuildCompletenessTest.java | 73 +-
.../ignite/internal/index/ItIndexRecoveryTest.java | 12 +-
.../index/ChangeIndexStatusTaskController.java | 2 +-
.../internal/index/IndexBuildingManager.java | 2 +-
.../apache/ignite/internal/index/IndexManager.java | 2 +-
.../RetryingFinalTransactionStateResolver.java | 4 +-
.../internal/jdbc/ItJdbcMetadataSelfTest.java | 9 +
.../ignite/jdbc/ItJdbcConnectionFailoverTest.java | 1 -
.../ignite/internal/lowwatermark/LowWatermark.java | 11 +
.../internal/lowwatermark/LowWatermarkImpl.java | 18 +-
.../internal/lowwatermark/TestLowWatermark.java | 5 +
.../server/raft/ItMetaStorageRaftGroupTest.java | 2 +-
.../service/ItAbstractListenerSnapshotTest.java | 2 +-
.../internal/metrics/sources/OsMetricSource.java | 2 +-
...des.java => LogicalTopologyEventsListener.java} | 8 +-
.../ignite/internal/network/TopologyService.java | 7 +-
modules/network/build.gradle | 1 +
.../node/ItNodeStalenessAndRestartTest.java | 39 +-
.../internal/network/DefaultMessagingService.java | 8 +-
.../internal/network/netty/ConnectionManager.java | 3 +-
.../network/recovery/HandshakeManagerUtils.java | 29 +
.../recovery/RecoveryAcceptorHandshakeManager.java | 50 +-
.../RecoveryInitiatorHandshakeManager.java | 32 +-
...s.java => StaleNodeHandlingParametersImpl.java} | 20 +-
.../recovery/message/HandshakeStartMessage.java | 5 +-
.../message/HandshakeStartResponseMessage.java | 5 +-
...ssage.java => StaleNodeHandlingParameters.java} | 12 +-
.../scalecube/ScaleCubeTopologyService.java | 14 +-
.../network/netty/RecoveryHandshakeTest.java | 3 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 4 +-
.../pagememory/persistence/PageCacheMetrics.java} | 16 +-
.../persistence/PersistentPageMemory.java | 66 +-
.../PersistentPageMemoryMetricSource.java | 9 +
.../persistence/PersistentPageMemoryMetrics.java | 98 +-
.../persistence/checkpoint/CheckpointManager.java | 5 +-
.../checkpoint/CheckpointReadWriteLock.java | 63 +-
.../checkpoint/CheckpointReadWriteLockMetrics.java | 120 ++
.../persistence/checkpoint/Checkpointer.java | 4 +-
.../persistence/compaction/CompactionRound.java | 66 ++
.../persistence/compaction/Compactor.java | 232 ++--
.../compaction/DeltaFileForCompaction.java} | 46 +-
.../MeteredPageReplacementPolicyFactory.java | 77 ++
.../checkpoint/CheckpointReadWriteLockTest.java | 6 +-
.../checkpoint/CheckpointTimeoutLockTest.java | 72 +-
.../persistence/compaction/CompactorTest.java | 58 +-
.../replacement/AbstractPageReplacementTest.java | 43 +-
.../checkpoint/CheckpointTestUtils.java | 8 +-
modules/partition-replicator/build.gradle | 1 +
.../ItWriteIntentSwitchRequestHandlerTest.java | 106 ++
.../partition/replicator/fixtures/Node.java | 16 +-
.../ItZonePartitionRaftListenerRecoveryTest.java | 7 +-
.../PartitionReplicaLifecycleManager.java | 329 +++++-
.../partition/replicator/ReplicaPrimacy.java | 7 +-
.../replicator/StartedReplicationGroups.java | 19 +
.../replicator/ZonePartitionReplicaListener.java | 26 +-
.../partition/replicator/ZoneResourcesManager.java | 23 +-
...xStateCommitPartitionReplicaRequestHandler.java | 84 +-
.../handlers/WriteIntentSwitchRequestHandler.java | 26 +-
.../network/PartitionReplicationMessageGroup.java | 22 +-
.../disaster/LocalPartitionStateMessage.java | 1 +
...va => LocalPartitionsEstimatedSizeMessage.java} | 3 +-
...va => LocalPartitionsEstimatedSizeRequest.java} | 3 +-
...a => LocalPartitionsEstimatedSizeResponse.java} | 7 +-
...Message.java => OperationCompletedMessage.java} | 19 +-
.../replicator/raft/ZonePartitionRaftListener.java | 35 +-
.../raft/snapshot/PartitionDataStorage.java | 17 +-
.../replicator/raft/snapshot/PartitionKey.java | 60 +-
.../raft/snapshot/PartitionSnapshotStorage.java | 17 +-
.../replicator/raft/snapshot/ZonePartitionKey.java | 82 --
.../snapshot/incoming/IncomingSnapshotCopier.java | 15 +-
.../incoming/ReplicationLogStorageKey.java | 8 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 15 +-
.../PartitionReplicaLifecycleManagerTest.java | 8 +-
.../raft/ZonePartitionRaftListenerTest.java | 214 +++-
.../PartitionSnapshotStorageFactoryTest.java | 2 +-
.../snapshot/PartitionSnapshotStorageTest.java | 2 +-
.../incoming/IncomingSnapshotCopierTest.java | 6 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 3 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 3 +-
.../outgoing/OutgoingSnapshotReaderTest.java | 4 +-
.../outgoing/OutgoingSnapshotStatsTest.java | 4 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 3 +-
.../outgoing/OutgoingSnapshotsManagerTest.java | 6 +-
.../SnapshotAwarePartitionDataStorageTest.java | 27 +-
.../placementdriver/LeasePlacementDriver.java | 1 -
.../placementdriver/BasePlacementDriverTest.java | 25 +-
.../MultiActorPlacementDriverTest.java | 5 +-
.../PlacementDriverManagerTest.java | 13 +-
.../placementdriver/AssignmentsTracker.java | 63 +-
.../placementdriver/PlacementDriverManager.java | 14 +-
.../ignite/internal/placementdriver/Utils.java | 25 +-
.../placementdriver/leases/LeaseTracker.java | 30 +-
.../internal/placementdriver/ActiveActorTest.java | 5 +-
.../placementdriver/AssignmentsTrackerTest.java | 5 +-
.../placementdriver/LeaseNegotiationTest.java | 38 +-
.../internal/placementdriver/LeaseTrackerTest.java | 52 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 33 +-
.../placementdriver/PlacementDriverTest.java | 9 +-
modules/platforms/DEVNOTES.md | 3 +
modules/platforms/build.gradle | 4 +-
modules/platforms/cpp/ignite/common/error_codes.h | 2 +
modules/platforms/cpp/ignite/odbc/common_types.cpp | 2 +
.../Sql/ResultSetBenchmarks.cs | 24 +-
.../Compute/ComputeTests.cs | 25 +-
.../dotnet/Apache.Ignite.Tests.Aot/Sql/SqlTests.cs | 36 +
.../Table/{KeyPoco.cs => IntMapper.cs} | 18 +-
.../Table/PocoAllColumnsSqlNullableMapper.cs | 3 +-
.../CurrentClientWithOldServerCompatibilityTest.cs | 2 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 5 +
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 51 +-
.../Sql/SqlResultSetObjectMappingTests.cs | 80 +-
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 4 +-
.../Table/DataStreamerPlatformReceiverTests.cs | 1 +
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 1 +
.../Table/PartitionManagerTests.cs | 7 +-
.../Table/RecordViewBinaryTests.cs | 4 +-
.../dotnet/Apache.Ignite.Tests/TestUtils.cs | 3 +
.../Apache.Ignite/ApiCompatibilitySuppressions.xml | 14 +
.../dotnet/Apache.Ignite/Compute/JobTarget.cs | 58 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 6 +
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 7 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 19 +-
.../Internal/Linq/IgniteQueryExecutor.cs | 3 +-
.../Apache.Ignite/Internal/Linq/ResultSelector.cs | 18 +-
.../Apache.Ignite/Internal/Sql/ColumnMetadata.cs | 3 +-
.../dotnet/Apache.Ignite/Internal/Sql/ResultSet.cs | 35 +-
.../Internal/Sql/ResultSetMetadata.cs | 29 +-
.../dotnet/Apache.Ignite/Internal/Sql/RowReader.cs | 7 +-
.../Apache.Ignite/Internal/Sql/RowReaderFactory.cs | 7 +-
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 59 +-
.../dotnet/Apache.Ignite/Internal/Table/Column.cs | 3 +
.../Internal/Table/PartitionManager.cs | 6 +
.../Table/Serialization/MapperSerializerHandler.cs | 7 +-
modules/platforms/dotnet/Apache.Ignite/Sql/ISql.cs | 18 +
.../Apache.Ignite/Table/IPartitionManager.cs | 13 +-
.../Apache.Ignite/Table/Mapper/IMapperColumn.cs | 21 +
.../dotnet/Apache.Ignite/Table/Mapper/RowReader.cs | 14 +-
.../raft/ReplicationGroupUnavailableException.java | 81 ++
...Service.java => TimeAwareRaftGroupService.java} | 18 +-
...InterruptedRaftSnapshotStorageRecoveryTest.java | 2 +-
.../raftsnapshot/ItParallelRaftSnapshotsTest.java | 2 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 15 +-
.../ignite/raft/server/ItConnectionErrorTest.java | 2 +-
.../raft/server/ItSimpleCounterServerTest.java | 2 +-
.../ignite/raft/server/JraftAbstractTest.java | 2 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 1 +
.../PhysicalTopologyAwareRaftGroupService.java | 80 +-
.../raft/{ => client}/RaftGroupServiceImpl.java | 13 +-
.../internal/raft/{ => client}/RetryContext.java | 4 +-
...ysicalTopologyAwareRaftGroupServiceRunTest.java | 686 +++++++++++
.../PhysicalTopologyAwareRaftGroupServiceTest.java | 1 -
.../raft/{ => client}/RaftGroupServiceTest.java | 6 +-
.../ChangePeersAndLearnersWithRetryTest.java | 2 +-
.../internal/raft/TestRaftGroupListener.java | 0
.../raft/client/TopologyAwareRaftGroupService.java | 1 -
.../ReplicatorRecoverableExceptions.java | 2 +
.../replicator/message/ReplicaMessageUtils.java | 20 +
.../internal/raft/TestRaftGroupListener.java | 1 +
.../rest/api/recovery/DisasterRecoveryApi.java | 79 --
.../api/recovery/GlobalPartitionStateResponse.java | 86 --
.../recovery/GlobalPartitionStatesResponse.java | 46 -
.../api/recovery/LocalPartitionStateResponse.java | 102 --
.../api/recovery/LocalPartitionStatesResponse.java | 46 -
.../rest/api/recovery/ResetPartitionsRequest.java | 79 --
.../api/recovery/RestartPartitionsRequest.java | 91 --
...terRecoveryControllerRestartPartitionsTest.java | 48 +-
...ControllerRestartPartitionsWithCleanupTest.java | 108 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 229 +---
.../rest/recovery/DisasterRecoveryController.java | 178 +--
.../ItTruncateRaftLogAndRestartNodesTest.java | 7 +-
.../internal/benchmark/FutureTimeoutBenchmark.java | 2 +-
...SqlBenchmark.java => SystemViewsBenchmark.java} | 114 +-
.../client/ItClientDataConsistencyTest.java | 6 +
.../runner/app/ItIgniteNodeRestartTest.java | 10 +-
.../internal/runner/app/ItIndexNodeTest.java | 315 +++++
.../app/client/ItThinClientAuthenticationTest.java | 10 +-
.../runner/app/client/ItThinClientComputeTest.java | 8 +-
.../app/client/ItThinClientConnectionTest.java | 3 +-
.../client/ItThinClientDdlQueriesTrackerTest.java | 156 +++
.../schemasync/ItSchemaSyncAndReplicationTest.java | 4 +-
.../streamer/ItAbstractDataStreamerTest.java | 34 +-
.../internal/table/ItColumnNameMappingTest.java | 3 +-
.../table/ItRebalanceWithPartitionReturnTest.java | 14 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 40 +-
.../internal/app/LowWatermarkRectifier.java} | 51 +-
.../apache/ignite/internal/ConfigOverrideTest.java | 14 +-
.../compatibility/framework/ConfigNode.java | 2 +-
.../framework/ConfigurationTreeComparator.java | 2 +-
.../framework/ConfigurationTreeScanner.java | 2 +-
.../configuration/ignite-snapshot.bin | Bin 5679 -> 5653 bytes
.../java/org/apache/ignite/internal/Cluster.java | 12 +-
.../ignite/internal/ClusterConfiguration.java | 22 +-
.../internal/ClusterPerClassIntegrationTest.java | 16 +-
.../internal/ClusterPerTestIntegrationTest.java | 20 +-
.../org/apache/ignite/internal/ConfigOverride.java | 2 +
.../ignite/internal/schema/SchemaTestUtils.java | 32 +
.../engine/api/expressions/EvaluationContext.java} | 30 +-
.../api/expressions/EvaluationContextBuilder.java} | 25 +-
.../ExpressionEvaluationException.java} | 15 +-
.../engine/api/expressions/ExpressionFactory.java | 106 ++
.../expressions/ExpressionParsingException.java} | 12 +-
.../ExpressionValidationException.java} | 20 +-
.../engine/api/expressions/IgnitePredicate.java} | 28 +-
.../sql/engine/api/expressions}/RowAccessor.java | 2 +-
.../sql/engine/api/expressions}/RowFactory.java | 2 +-
.../engine/api/expressions}/RowFactoryFactory.java | 2 +-
.../ItSqlConcurrentSchemaModificationTest.java | 126 ++
.../engine/datatypes/ItDateTimeCastFormatTest.java | 2 +-
.../systemviews/ItTransactionsSystemViewTest.java | 37 +
.../aggregate/group/test_group_by_distinct.test | 16 +-
.../sql/group1/function/generic/test_coalesce.test | 15 +
.../function/generic/test_coalesce.test_ignore | 15 -
.../sql/group1/function/generic/test_decode.test | 8 +-
.../function/generic/test_decode.test_ignore | 20 -
.../sql/group1/set/test_basic_union.test | 12 +
.../internal/lang/SqlExceptionMapperUtil.java | 4 +
.../internal/sql/api/AsyncResultSetImpl.java | 53 +-
.../internal/sql/engine/SqlOperationContext.java | 37 +-
.../engine/SqlPlanToTxSchemaVersionValidator.java | 91 ++
.../internal/sql/engine/SqlQueryProcessor.java | 23 +-
.../sql/engine/exec/DynamicPartitionProvider.java | 6 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 28 +-
.../internal/sql/engine/exec/ExecutionContext.java | 15 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 132 ++-
.../sql/engine/exec/LogicalRelImplementor.java | 5 +-
.../exec/ProjectedTableRowConverterImpl.java | 1 +
.../internal/sql/engine/exec/RowHandler.java | 1 +
.../internal/sql/engine/exec/ScannableTable.java | 1 +
.../sql/engine/exec/ScannableTableImpl.java | 1 +
.../sql/engine/exec/SqlEvaluationContext.java | 3 +
.../sql/engine/exec/SqlPlanOutdatedException.java} | 23 +-
.../internal/sql/engine/exec/SqlRowHandler.java | 6 +-
.../sql/engine/exec/TableRowConverter.java | 1 +
.../sql/engine/exec/TableRowConverterImpl.java | 1 +
.../sql/engine/exec/UpdatableTableImpl.java | 1 +
.../internal/sql/engine/exec/exp/CodegenUtils.java | 52 +
.../sql/engine/exec/exp/ComparatorImplementor.java | 2 +-
.../engine/exec/exp/JoinPredicateImplementor.java | 16 +-
.../engine/exec/exp/JoinProjectionImplementor.java | 18 +-
.../sql/engine/exec/exp/PredicateImplementor.java | 16 +-
.../sql/engine/exec/exp/ProjectionImplementor.java | 18 +-
.../engine/exec/exp/RowProviderImplementor.java | 18 +-
.../sql/engine/exec/exp/ScalarImplementor.java | 14 +-
...ssionFactory.java => SqlExpressionFactory.java} | 2 +-
...toryImpl.java => SqlExpressionFactoryImpl.java} | 4 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 2 +-
.../exec/exp/func/SystemRangeTableFunction.java | 4 +-
.../exec/exp/func/TableFunctionRegistryImpl.java | 6 +-
.../exec/fsm/CursorPublicationPhaseHandler.java | 10 +-
.../engine/exec/fsm/OptimizingPhaseHandler.java | 40 +-
.../internal/sql/engine/exec/fsm/Program.java | 6 +-
.../sql/engine/exec/fsm/QueryExecutionProgram.java | 45 +-
.../internal/sql/engine/exec/rel/AbstractNode.java | 9 +-
.../sql/engine/exec/rel/AbstractSetOpNode.java | 2 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 2 +-
.../sql/engine/exec/rel/DataSourceScanNode.java | 2 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 2 +-
.../internal/sql/engine/exec/rel/HashJoinNode.java | 2 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 2 +-
.../sql/engine/exec/rel/IndexScanNode.java | 2 +-
.../sql/engine/exec/rel/IntersectNode.java | 2 +-
.../sql/engine/exec/rel/MergeJoinNode.java | 2 +-
.../internal/sql/engine/exec/rel/MinusNode.java | 2 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 4 +-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 2 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 2 +-
.../sql/engine/exec/rel/TableScanNode.java | 2 +-
.../sql/engine/expressions/RowBasedScope.java} | 18 +-
.../sql/engine/expressions/RowFieldNamespace.java | 136 +++
.../sql/engine/expressions/RowNamespace.java | 143 +++
.../expressions/SqlExpressionFactoryAdapter.java | 322 ++++++
.../expressions/ToInternalGenericAdapter.java | 84 ++
.../engine/prepare/IgniteSqlToRelConvertor.java | 25 +
.../sql/engine/prepare/KeyValueGetPlan.java | 9 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 4 +-
.../internal/sql/engine/prepare/QueryPlan.java | 9 +-
.../sql/engine/prepare/SelectCountPlan.java | 2 +-
.../ddl/ClusterWideNodeFilterValidator.java | 2 +-
.../engine/prepare/ddl/NodeFilterValidator.java | 2 +-
.../prepare/pruning/PartitionPruningPredicate.java | 4 +-
.../rule/logical/IgniteSubQueryRemoveRule.java | 998 ----------------
.../internal/sql/engine/sql/IgniteSqlParser.java | 19 +-
.../engine/statistic/SqlStatisticManagerImpl.java | 2 +-
.../sql/engine/type/IgniteTypeFactory.java | 4 +-
.../internal/sql/engine/type/IgniteTypeSystem.java | 5 +
.../ignite/internal/sql/engine/util/Commons.java | 4 +-
.../internal/sql/engine/util/IgniteMethod.java | 4 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 29 +-
.../sql/engine/util/format/ParsedFields.java | 2 +-
.../apache/ignite/internal/sql/api/SqlRowTest.java | 100 ++
.../sql/engine/exec/DummyScannableTable.java | 1 +
.../sql/engine/exec/ExecutionServiceImplTest.java | 8 +-
.../exec/IdentityDistributionFunctionSelfTest.java | 3 +-
.../sql/engine/exec/PartitionsResolutionTest.java | 3 +-
.../exec/ProjectedTableRowConverterSelfTest.java | 3 +-
.../internal/sql/engine/exec/QueryTimeoutTest.java | 12 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../sql/engine/exec/SqlOutdatedPlanTest.java | 255 ++++
.../sql/engine/exec/TableRowConverterSelfTest.java | 7 +-
...Test.java => SqlExpressionFactoryImplTest.java} | 10 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 6 +-
.../engine/exec/rel/AbstractJoinExecutionTest.java | 2 +-
.../exec/rel/AbstractSetOpExecutionTest.java | 2 +-
.../sql/engine/exec/rel/AsyncRootNodeTest.java | 6 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 6 +-
.../rel/CorrelatedNestedLoopJoinExecutionTest.java | 2 +-
.../exec/rel/DataSourceScanNodeExecutionTest.java | 12 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 4 +-
.../sql/engine/exec/rel/ExecutionTest.java | 2 +-
.../sql/engine/exec/rel/FilterExecutionTest.java | 2 +-
.../exec/rel/HashAggregateExecutionTest.java | 2 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 4 +-
.../exec/rel/HashIndexSpoolExecutionTest.java | 2 +-
.../exec/rel/IndexScanNodeExecutionTest.java | 10 +-
.../engine/exec/rel/IntersectExecutionTest.java | 6 +-
.../sql/engine/exec/rel/LimitExecutionTest.java | 2 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 6 +-
.../sql/engine/exec/rel/MinusExecutionTest.java | 4 +-
.../engine/exec/rel/ModifyNodeExecutionTest.java | 20 +-
.../sql/engine/exec/rel/ScanNodeExecutionTest.java | 2 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 2 +-
.../exec/rel/SortAggregateExecutionTest.java | 2 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 2 +-
.../exec/rel/SystemRangeTableFunctionTest.java | 2 +-
.../exec/rel/TableScanNodeExecutionTest.java | 6 +-
.../engine/exec/rel/TableSpoolExecutionTest.java | 2 +-
.../sql/engine/exec/row/SqlRowHandlerTest.java | 16 +-
.../expressions/AbstractExpressionFactoryTest.java | 64 ++
.../engine/expressions/IgnitePredicateTest.java | 1214 ++++++++++++++++++++
.../sql/engine/framework/ArrayRowHandler.java | 6 +-
.../engine/framework/ClusterServiceFactory.java | 9 +-
.../sql/engine/framework/TestBuilders.java | 61 +-
.../sql/engine/framework/TestClusterTest.java | 2 +-
.../internal/sql/engine/framework/TestNode.java | 30 +-
.../planner/AbstractTpcQueryPlannerTest.java | 80 +-
.../sql/engine/planner/DynamicParametersTest.java | 1 -
.../sql/engine/planner/TpcdsQueryPlannerTest.java | 59 +-
.../sql/engine/planner/TpchQueryPlannerTest.java | 28 +-
.../planner/datatypes/BaseTypeCoercionTest.java | 2 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 6 +-
.../sql/engine/type/IgniteTypeFactorySelfTest.java | 2 +-
.../internal/sql/engine/util/TypeUtilsTest.java | 6 +-
.../src/test/resources/tpcds/plan/q13.plan | 6 +-
.../src/test/resources/tpcds/plan/q14.plan | 441 +++----
.../src/test/resources/tpcds/plan/q34.plan | 2 +-
.../src/test/resources/tpcds/plan/q41.plan | 2 +-
.../src/test/resources/tpcds/plan/q5.plan | 99 +-
.../src/test/resources/tpcds/plan/q71.plan | 2 +-
.../src/test/resources/tpcds/plan/q73.plan | 2 +-
.../src/test/resources/tpcds/plan/q76.plan | 53 +-
.../src/test/resources/tpcds/plan/q77.plan | 117 +-
.../src/test/resources/tpcds/plan/q80.plan | 111 +-
.../src/test/resources/tpcds/plan/q85.plan | 6 +-
.../src/test/resources/tpch/plan/q12.plan | 2 +-
.../src/test/resources/tpch/plan/q7.plan | 4 +-
.../src/test/resources/tpch/plan/variant_q12.plan | 2 +-
.../internal/systemview/SystemViewManagerImpl.java | 261 ++++-
.../ItInternalTableReadWriteScanTest.java | 93 --
...xDistributedTestSingleNodeNoCleanupMessage.java | 18 +-
.../ItTxObservableTimePropagationTest.java | 18 +-
.../partition/ItPartitionDestructionTest.java | 291 ++++-
...bstractHighAvailablePartitionsRecoveryTest.java | 7 +-
.../internal/table/AbstractRowTupleAdapter.java | 85 +-
.../internal/table/distributed/TableManager.java | 125 +-
.../disaster/DisasterRecoveryManager.java | 884 +++-----------
.../disaster/DisasterRecoverySystemViews.java | 77 --
.../disaster/GlobalTablePartitionState.java | 61 -
.../distributed/disaster/GroupUpdateRequest.java | 29 +-
.../disaster/GroupUpdateRequestHandler.java | 321 ++----
.../disaster/GroupUpdateRequestSerializer.java | 15 +-
.../disaster/LocalTablePartitionState.java | 67 --
.../disaster/LocalTablePartitionStateByNode.java | 54 -
.../disaster/ManualGroupRestartRequest.java | 37 +-
.../ManualGroupRestartRequestSerializer.java | 26 +-
....java => MultiNodeDisasterRecoveryRequest.java} | 21 +-
.../distributed/disaster/MultiNodeOperations.java | 76 ++
...tFoundException.java => NodeLeftException.java} | 14 +-
...xception.java => RemoteOperationException.java} | 18 +-
.../distributed/raft/TablePartitionProcessor.java | 63 +-
.../raft/handlers/BuildIndexCommandHandler.java | 6 +
.../MinimumActiveTxTimeCommandHandler.java | 2 +
.../SnapshotAwarePartitionDataStorage.java | 24 +-
.../raft/snapshot/TablePartitionKey.java | 84 --
.../replicator/PartitionReplicaListener.java | 105 +-
.../distributed/storage/InternalTableImpl.java | 2 -
.../internal/table/MutableRowTupleAdapterTest.java | 121 ++
.../distributed/TableManagerRecoveryTest.java | 8 +-
.../table/distributed/TableManagerTest.java | 6 -
.../DisasterRecoveryRequestSerializerTest.java | 74 +-
.../raft/PartitionCommandListenerTest.java | 188 ++-
.../PartitionReplicaListenerIndexLockingTest.java | 11 +-
...itionReplicaListenerSortedIndexLockingTest.java | 11 +-
.../replication/PartitionReplicaListenerTest.java | 148 ++-
.../ZonePartitionReplicaListenerTest.java | 34 +-
.../storage/InternalTableEstimatedSizeTest.java | 28 +-
.../distributed/storage/InternalTableImplTest.java | 440 ++++++-
.../apache/ignite/distributed/ItTxTestCluster.java | 23 +-
.../distributed/TestPartitionDataStorage.java | 10 -
.../ignite/internal/table/TxAbstractTest.java | 3 +-
.../internal/table/TxInfrastructureTest.java | 17 +-
.../disaster/TestDisasterRecoveryUtils.java | 66 +-
.../table/impl/DummyInternalTableImpl.java | 17 +-
.../disaster/ItDisasterRecoveryManagerTest.java | 132 +--
.../ItDisasterRecoveryReconfigurationTest.java | 88 +-
.../ItDisasterRecoveryResetPartitionsTest.java | 15 +-
.../disaster/ItDisasterRecoverySystemViewTest.java | 236 ----
...RecoveryZonePartitionsStatesSystemViewTest.java | 3 -
...riteIntentResolutionWhenPrimaryExpiredTest.java | 198 ++++
.../tx/distributed/ItTxResourcesVacuumTest.java | 5 -
.../org/apache/ignite/internal/tx/TxManager.java | 6 +
.../org/apache/ignite/internal/tx/TxStateMeta.java | 6 +-
.../ignite/internal/tx/TxStateMetaAbandoned.java | 12 +-
.../tx/impl}/TransactionStateResolver.java | 153 ++-
.../internal/tx/impl/TxCleanupRequestSender.java | 12 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 32 +-
.../ignite/internal/tx/impl/TxMessageSender.java | 18 +-
.../tx/message/TxStateCommitPartitionRequest.java | 21 +
.../tx/message/TxStateCoordinatorRequest.java | 18 +
.../tx/message/TxStateMetaAbandonedMessage.java | 1 +
.../tx/views/TransactionsViewProvider.java | 12 +-
.../tx/impl}/TransactionStateResolverTest.java | 100 +-
.../ignite/tests/docker/ItDockerConfigTest.java | 2 +-
524 files changed, 13336 insertions(+), 7680 deletions(-)
create mode 100644 .claude/skills/ignite-cluster-setup/SKILL.md
create mode 100644 .justfile
create mode 100644 CLAUDE.md
delete mode 100644
migration-tools/modules/migration-tools-commons-tests/src/main/java/org/apache/ignite/migrationtools/handlers/SkipUnsupportedOperationsHandlers.java
create mode 100644
modules/catalog-compaction/src/integrationTest/java/org/apache/ignite/internal/catalog/compaction/ItNodeRecoveryAfterCatalogTruncatedAboveStoredLwmTest.java
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/sql/ItSqlTimedOptionTest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/DdlBatchingSuggester.java
create mode 100644
modules/client-handler/src/test/java/org/apache/ignite/client/handler/DdlBatchingSuggesterTest.java
create mode 100644 modules/client/DEVNOTES.md
create mode 100644
modules/client/src/test/java/org/apache/ignite/internal/client/sql/ClientSqlRowTest.java
copy
modules/{rest/src/test/java/org/apache/ignite/internal/rest/configuration/TestSubSensitiveConfigurationSchema.java
=>
configuration-system/src/main/java/org/apache/ignite/internal/configuration/SequentialDdlExecutionConfigurationSchema.java}
(78%)
copy
modules/configuration-system/src/main/java/org/apache/ignite/internal/configuration/{SystemDistributedExtensionConfigurationSchema.java
=> SuggestionsClusterExtensionConfigurationSchema.java} (77%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/configuration/distributed/StatisticsConfigurationSchema.java
=>
configuration-system/src/main/java/org/apache/ignite/internal/configuration/SuggestionsConfigurationSchema.java}
(77%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/configuration/distributed/SqlClusterConfigurationModule.java
=>
configuration-system/src/main/java/org/apache/ignite/internal/configuration/SuggestionsDistributedConfigurationModule.java}
(81%)
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/components/SystemPropertiesNodeProperties.java
copy
modules/core/src/main/java/org/apache/ignite/internal/util/{FilteringIterator.java
=> FlatteningIterator.java} (52%)
rename modules/{table/src/main/java/org/apache/ignite/internal/table =>
core/src/main/java/org/apache/ignite/internal/util}/LongPriorityQueue.java (95%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/FlatteningIteratorTest.java
rename modules/{table/src/test/java/org/apache/ignite/internal/table =>
core/src/test/java/org/apache/ignite/internal/util}/LongPriorityQueueSelfTest.java
(99%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/PendingComparableValuesTrackerTestBase.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/SafeTimeValuesTrackerTest.java
rename
modules/network-api/src/main/java/org/apache/ignite/internal/network/{JoinedNodes.java
=> LogicalTopologyEventsListener.java} (79%)
copy
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/{InMemoryStaleIds.java
=> StaleNodeHandlingParametersImpl.java} (59%)
copy
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/message/{InternalMessage.java
=> StaleNodeHandlingParameters.java} (76%)
copy
modules/{metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/configuration/JmxExporterConfigurationSchema.java
=>
page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageCacheMetrics.java}
(70%)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/CheckpointReadWriteLockMetrics.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/compaction/CompactionRound.java
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/core/call/CallOutput.java
=>
page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/compaction/DeltaFileForCompaction.java}
(51%)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/replacement/MeteredPageReplacementPolicyFactory.java
create mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItWriteIntentSwitchRequestHandlerTest.java
rename
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/{LocalTablePartitionStateMessage.java
=> LocalPartitionsEstimatedSizeMessage.java} (94%)
rename
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/{LocalTablePartitionStateRequest.java
=> LocalPartitionsEstimatedSizeRequest.java} (94%)
rename
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/{LocalTablePartitionStateResponse.java
=> LocalPartitionsEstimatedSizeResponse.java} (85%)
copy
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/{DisasterRecoveryResponseMessage.java
=> OperationCompletedMessage.java} (70%)
delete mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/ZonePartitionKey.java
create mode 100644 modules/platforms/DEVNOTES.md
copy modules/platforms/dotnet/Apache.Ignite.Tests.Common/Table/{KeyPoco.cs =>
IntMapper.cs} (74%)
create mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/ReplicationGroupUnavailableException.java
copy
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/service/{RaftGroupService.java
=> TimeAwareRaftGroupService.java} (93%)
rename modules/{replicator =>
raft}/src/main/java/org/apache/ignite/internal/raft/client/PhysicalTopologyAwareRaftGroupService.java
(90%)
rename modules/raft/src/main/java/org/apache/ignite/internal/raft/{ =>
client}/RaftGroupServiceImpl.java (98%)
rename modules/raft/src/main/java/org/apache/ignite/internal/raft/{ =>
client}/RetryContext.java (98%)
create mode 100644
modules/raft/src/test/java/org/apache/ignite/internal/raft/client/PhysicalTopologyAwareRaftGroupServiceRunTest.java
rename modules/{replicator =>
raft}/src/test/java/org/apache/ignite/internal/raft/client/PhysicalTopologyAwareRaftGroupServiceTest.java
(99%)
rename modules/raft/src/test/java/org/apache/ignite/internal/raft/{ =>
client}/RaftGroupServiceTest.java (99%)
copy modules/{replicator =>
raft}/src/testFixtures/java/org/apache/ignite/internal/raft/TestRaftGroupListener.java
(100%)
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/GlobalPartitionStateResponse.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/GlobalPartitionStatesResponse.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/LocalPartitionStateResponse.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/LocalPartitionStatesResponse.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/ResetPartitionsRequest.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/RestartPartitionsRequest.java
copy
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/{SqlBenchmark.java
=> SystemViewsBenchmark.java} (52%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItIndexNodeTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientDdlQueriesTrackerTest.java
copy
modules/{raft/src/main/java/org/apache/ignite/internal/raft/storage/impl/LocalLogStorageFactory.java
=>
runner/src/main/java/org/apache/ignite/internal/app/LowWatermarkRectifier.java}
(52%)
copy modules/{api/src/main/java/org/apache/ignite/table/criteria/Operator.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/EvaluationContext.java}
(69%)
copy
modules/{core/src/testFixtures/java/org/apache/ignite/internal/TestHybridClock.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/EvaluationContextBuilder.java}
(56%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/ColocationMappingException.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/ExpressionEvaluationException.java}
(65%)
create mode 100644
modules/sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/ExpressionFactory.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/MappingException.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/ExpressionParsingException.java}
(70%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/ColocationMappingException.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/ExpressionValidationException.java}
(53%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/SqlPredicate.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/IgnitePredicate.java}
(60%)
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec =>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions}/RowAccessor.java
(95%)
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec =>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions}/RowFactory.java
(98%)
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec =>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions}/RowFactoryFactory.java
(96%)
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlConcurrentSchemaModificationTest.java
delete mode 100644
modules/sql-engine/src/integrationTest/sql/group1/function/generic/test_coalesce.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/group1/function/generic/test_decode.test_ignore
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlPlanToTxSchemaVersionValidator.java
copy
modules/sql-engine/src/{test/java/org/apache/ignite/internal/sql/engine/framework/NoOpTransactionalOperationTracker.java
=>
main/java/org/apache/ignite/internal/sql/engine/exec/SqlPlanOutdatedException.java}
(59%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/CodegenUtils.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{ExpressionFactory.java
=> SqlExpressionFactory.java} (99%)
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{ExpressionFactoryImpl.java
=> SqlExpressionFactoryImpl.java} (98%)
copy
modules/{raft/src/test/java/org/apache/ignite/raft/jraft/entity/codec/v1/LogEntryV1CodecFactoryTest.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/RowBasedScope.java}
(69%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/RowFieldNamespace.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/RowNamespace.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/SqlExpressionFactoryAdapter.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/ToInternalGenericAdapter.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/logical/IgniteSubQueryRemoveRule.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/api/SqlRowTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/SqlOutdatedPlanTest.java
rename
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/exp/{ExpressionFactoryImplTest.java
=> SqlExpressionFactoryImplTest.java} (99%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/expressions/AbstractExpressionFactoryTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/expressions/IgnitePredicateTest.java
delete mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItInternalTableReadWriteScanTest.java
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/GlobalTablePartitionState.java
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/LocalTablePartitionState.java
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/LocalTablePartitionStateByNode.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/{GlobalPartitionStateEnum.java
=> MultiNodeDisasterRecoveryRequest.java} (58%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/MultiNodeOperations.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/{NodesNotFoundException.java
=> NodeLeftException.java} (73%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/{NodesNotFoundException.java
=> RemoteOperationException.java} (61%)
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/TablePartitionKey.java
delete mode 100644
modules/transactions/src/integrationTest/java/org/apache/ignite/internal/disaster/ItDisasterRecoverySystemViewTest.java
create mode 100644
modules/transactions/src/integrationTest/java/org/apache/ignite/tx/distributed/ItTxAbortOnCoordinatorOnWriteIntentResolutionWhenPrimaryExpiredTest.java
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator
=>
transactions/src/main/java/org/apache/ignite/internal/tx/impl}/TransactionStateResolver.java
(71%)
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed/replicator
=>
transactions/src/test/java/org/apache/ignite/internal/tx/impl}/TransactionStateResolverTest.java
(76%)
