This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/org.openapi.generator-7.17.0
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard c099fd361dc Bump org.openapi.generator from 7.12.0 to 7.17.0
add 83f52170e56 IGNITE-27023 define aggregated spotbugs & pmd tasks (#6943)
add 3f68eea4a99 IGNITE-27028 Fix consistency of last applied index on
start rebalance for aipersist (#6947)
add 55114300509 IGNITE-26837 Introduce configuration update versioning
token (#6850)
add 601746edcac IGNITE-26626 Added debug information output to the
testGlobalMinimumTxRequiredTime) test (#6901)
add 77994ec6dfb IGNITE-26990 Fix ClassCastException in Criteria API with
BigDecimal (#6949)
add 3eceb6e0f66 IGNITE-27035 Fix metastorage safeTime duplication after
retry (#6954)
add 4da0f314c90 IGNITE-26425 Implement lazy default zone creation on table
creation (#6712)
add 6f489d5083a IGNITE-26997 Always use random access IO for checkpoint in
aipersist (#6951)
add 015b2752bcf IGNITE-27025 C++ 3.0: Remove invalid UTF-8 sequences from
the test names (#6953)
add b0adb1acc87 IGNITE-26343 Fixed flaky
ItTxResourcesVacuumTest.testVacuumWithCleanupDelay (#6952)
add 4ff66be7b33 IGNITE-27041 Remove "createPartitionStorage" from
TxStateStorage (#6962)
add 843cb32a3e7 IGNITE-27044 Extract tests restarting nodes from
ItBuildIndexTest (#6966)
add 8b3c35ef73c IGNITE-27046 Update docker image name resolution for
migration tools subprojects (#6969)
add 0759c8d58a3 IGNITE-26069 Sql. Add data staleness check to statistic
manager (#6649)
add 9b395e48306 IGNITE-27047 Remove "initialClusterConfiguration" from
cluster logs (#6970)
add aed3e9efc8e IGNITE-26722 Slowdown compactor when running checkpoint
for aipersist (#6799)
add 728bbec130c IGNITE-26999 Add total IO speed to checkpoint finished
message (#6961)
add efdb1c16507 IGNITE-27037 Add jdbc to artifact bundle (#6975)
add 3438c301536 IGNITE-26968 Sql. Left join of 3 tables produces incorrect
result (#6945)
add 19c6dada703 IGNITE-27038 Read rows for indexing in batches (#6964)
add e516650d37f IGNITE-27064 Fix missing distribution zone doc (#6982)
add 164cf167523 IGNITE-27062 Update progressbar (#6981)
add 9a7ba974ed1 IGNITE-27067 Fix TOC issue in documentation (#6984)
add 00e6e7337be IGNITE-25437 .NET: Improve exception when job assembly
requires higher runtime version (#6979)
add 603c74c807a IGNITE-27052 Fix IncrementalVersionedValueTest.testUpdate
with assertions disabled (#6987)
add 49ca44bd1f0 IGNITE-27053 Get rid of unused SameValueLongSupplier
(#6988)
add 25e1ffa3940 IGNITE-27051 Fix
StorageCleanupTest.testCleanupBeforeUpdateError when assertions disabled (#6986)
add ee62bfdb4de IGNITE-18681 Remove an irrelevant TODO (#6989)
add 2a36e657c25 IGNITE-26105 Add CMG Raft log compatibility test (#6948)
add 9b64914eee9 IGNITE-26995 Introduce Locker.shouldRelease method (#6973)
add 84c04db1861 IGNITE-26927 Fix SQL next page prefetch logic (#6950)
add 175f869a67d IGNITE-27069 .NET: Add NoDelay to IgniteProxy to speed
tests up (#6990)
add 385e65d2e9f IGNITE-27074 Fix kotlin version for TC dsl (#6991)
add d7027e28497 IGNITE-26996 Use Locker.shouldRelease in MV GC (#6983)
add 73cbbddc18d IGNITE-27048 Stop partition scan on index build early
(#6976)
add a7cc7fe448b IGNITE-24744 Java client: fix
ClientFutureUtils.doWithRetryAsync logic (#6992)
add b3e057d04a8 IGNITE-27036 fix artifact path for C++ tests (#6959)
add d2403e847d9 IGNITE-26512 ItAggregatesTest#testGroupingFunction failed
if statistics return table size greater than 1 (#6980)
add 739edab386d IGNITE-26930 Catalog.
CatalogSerializationCompatibilityTest snapshot file writes should not perform
version checks (#6972)
add a547cd69d9b IGNITE-27081 Make NodeOptions#snapshotIntervalSecs
configurable (#6995)
add 0257d293139 Bump net.bytebuddy:byte-buddy from 1.17.8 to 1.18.0 (#6955)
add 67396d56fa6 IGNITE-27017 Prevent a node from starting in
non-colocation mode (#6971)
add 85205f6f1b3 IGNITE-27045 Dropping a table right after dropping index
leads to catalog update failure (#6967)
add 19fae974c3c IGNITE-27059 Revise SQL-related tests that fail with
disabled assertions (#6978)
add 2f31d322c3c IGNITE-27085 Fix changePeersAndLearnersAsyncResponses test
(#7003)
add 0f4112df9f8 IGNITE-26957 fix a bug in
testChangePeersAndLearnersAddMultiNodes test (#6999)
add 6673c876183 IGNITE-27090 Add compatibility test for write intent
storage format (#7005)
add d3e51e10bb6 IGNITE-27077 Sql. Support prefix LIKE condition in search
bounds (#6996)
add 673ef12bdc7 IGNITE-27055 Sql. Await cursor closing before query
termination in case of cancellation (#7010)
add 3445dfd80f3 IGNITE-27018 Remove !colocationEnabled() branches in some
tests (#6998)
add 577f02ab6e7 IGNITE-27058 Remove code related to non-colocated case
(catalog compaction) (#6977)
add 565171b8804 IGNITE-27104 Add a reproducer of inconsistency to the raft
log after its truncating and rebalance abort (#7016)
add 1d44838da20 IGNITE-26950 Causality token mismatch error when zone
creation (#7009)
add f7da486c25c IGNITE-26488 Sql. Introduce configuration to override
CREATE TABLE defaults for data staleness configuration (#6927)
add afa3536d60c IGNITE-27093 Add a test for possible data loss due to
pending rows loss (#7011)
add 675f0fee462 IGNITE-27103 Don't call failure handler for Handshake
exception in IncomingSnapshotCopier joinFuture (#7015)
add ef3945348e6 IGNITE-27111 Remove IGNITE_ZONE_BASED_REPLICATION param
for TC runs (#7021)
add d7441f2c88e IGNITE-27110 Remove unused method and parameter (#7020)
add c5f2d0fe9eb IGNITE-27099 Remove !colocationEnabled() branches from
some other tests (#7017)
add 210c1888115 IGNITE-27075 Remove code related to non-colocated case
(compute module) (#6993)
add 894e6982322 IGNITE-26521 Sql. Flaky
ItUnstableTopologyTest.ensureLostOfNodeDoesntCausesQueryToFail (#6958)
add a5e82a67ded IGNITE-26621 Optimize client's implicit batch reads
add 578ed5ea474 IGNITE-25290 .NET: Add StringSyntax attribute to SQL APIs
(#7027)
add 5357a90aa9a IGNITE-27113 Fix a race in aipersist's `acquirePage`
(#7023)
add 570ed3f6a99 IGNITE-27070 .NET: Fix TestPutRoutesRequestToPrimaryNode
flakiness (#7026)
add a2b909f6345 IGNITE-25543 Implement retry mechanism for reset (#6053)
add 7d33bd5c281 IGNITE-27014 Fix NPE in write intent resolution (#6960)
add da337a2b8a7 IGNITE-26421 Make node stop time unbounded (#6933)
add a7d6f016dd9 IGNITE-27076 Remove code related to non-colocated case
(cluster management module) (#7024)
add 6ac991e55ad IGNITE-27130 Fix spamming of logs by compactor (#7033)
add 38489d84f29 IGNITE-26705 Sql. Replace sql.engine.exec.row.RowSchema
with StructNativeType (#6968)
add b44abb1812b IGNITE-27102 Sql. After canceling a DDL script, some
queries remain unfinished (#7022)
add ac2de38dbeb IGNITE-27127 NPE in CLI SQL (#7032)
add 48e2f0e03fc IGNITE-27063 Wait for node join in CLI (#6994)
add 5ab1f0cb5ce IGNITE-27057 .NET: Increase TestSchemaUpdateWhileStreaming
timeout (#7029)
add 53bc922c8e6 IGNITE-26963 Reuse improvements in HTTP matchers (#6910)
add 77a23904bea IGNITE-26500 Add basic SQL examples (#6646)
add 84dfe6d6f12 IGNITE-27129 .NET: Improve logging in tests (#7034)
add eeafed07fbe IGNITE-26086 Ability to restrict query execution by type
in thin client SQL API (#6383)
add 380ba4ffd03 IGNITE-26087 Ability to obtain results of a
multi-statement query execution using the internal thin client SQL API. (#6397)
add b4bab09daa3 IGNITE-26276 Sql. Jdbc. Add new implementation for
ResultSetMetadata (#6488)
add b7056885cbf IGNITE-26351 Jdbc. Add additional tests for existing
ResultSet (#6518)
add 13f3f564481 IGNITE-26354 Jdbc. ResultSet backed by thin client without
data accessors (#6530)
add f2edcdf1192 IGNITE-26417 Jdbc. DatabaseMetadata for thin client backed
connection (#6581)
add 77d8ded0bd5 IGNITE-26369 Jdbc. Add accessor methods to thin
client-backed ResultSet (numeric types) (#6555)
add ae4db80daa0 IGNITE-26379 Jdbc. Add accessor methods to thin
client-backed ResultSet (datetime types) (#6565)
add d751a2ba2d7 IGNITE-26140 Sql. Jdbc. Add new implementation for
java.sql.ResultSet (adapter for org.apache.ignite.sql.ResultSet). (#6639)
add e9555b2903c IGNITE-26506: Jdbc. Jdbc connection over thin client API
(#6654)
add a6d067b08cf IGNITE-26427 Jdbc. Statement for thin client backed
connection (#6659)
add 8a597068d8d IGNITE-26428 Jdbc. PreparedStatement for thin client
backed connection (#6677)
add 24b45259b8a IGNITE-26141 Sql. Jdbc. Migrate (Prepared)Statement
methods (executeUpdate, executeQuery, execute) to use thin client SQL API
(#6740)
add 63da02bc59e IGNITE-26617 Jdbc. Thin client jdbc connection does not
observe changes made by other connections of the same driver instance (#6771)
add 0092a9e9b49 IGNITE-26139 Sql. Jdbc. Support non-autocommit mode and
cancellation token for use in thin client API. (#6772)
add 562ea51d9b7 IGNITE-26190 Sql. Jdbc. PreparedStatement.executeBatch
using the thin client SQL API (#6823)
add a02661d5061 IGNITE-26142 Jdbc. Support multi-statement execution in
(Prepared)Statement.execute() using thin client SQL API (#6806)
add d3c9c68e046 IGNITE-26143 Sql. Jdbc. Statement.executeBatch using thin
client SQL API (#6824)
add 5ca87e51f4a IGNITE-25617 Sql. JDBC connection property for changing
partition awareness cache size (#6366)
add 522c58ff866 IGNITE-26146 Sql. Jdbc. Abort the connection to a node
that does not support a feature required by the new JDBC driver (#6566)
add 3315ea09c45 IGNITE-26789 Jdbc. Fix resource leak when client
disconnects (#6879)
add e8a3aedf7cb IGNITE-26148 Jdbc. Multinode connection tests (#6899)
add 70d2832f1eb IGNITE-26790 Cli. SqlExceptionHandler. Correctly translate
SQL exceptions (#6934)
add 34affdff9fa IGNITE-26314 Jdbc. Migrate JdbcDatabaseMetadata to use the
new ResultSet implementation (#6965)
add 70c5e9eecdf IGNITE-26145 Jdbc. Remove previous driver implementation
(#6985)
add 80db9a68cd6 IGNITE-26149 Jdbc. Benchmark added (#6921)
add b01cfdb89b3 IGNITE-26845 Jdbc. Unstable test testBatchException has
been temporarily disabled.
add 5f896bc519d IGNITE-25587 Jdbc. Basic connection failover tests (#7039)
add 6ba472e3068 IGNITE-27140 Add tests for MvPartitionStorage
implementations (#7041)
add 57731a3566f IGNITE-27043 Ignore Calcite dependency in Debendabot
(#7042)
add 403a46fa775 IGNITE-27119 Remove code related to non-colocated case
(indexing module) (#7028)
add 7e74b7b5700 IGNITE-27135 Add distribution zone SQL example (#7035)
add 31266cbd2f8 IGNITE-27114 Remove non-colocation
DistributionZoneRebalanceEngine (#7025)
add 905a12f8731 Bump docfx from 2.78.2 to 2.78.4 (#7046)
add 55d7a4c4888 Bump BenchmarkDotNet from 0.14.0 to 0.15.6 (#7045)
add 01301b6fc22 Bump JetBrains.Annotations from 2024.3.0 to 2025.2.2
(#7047)
add 0b65728d28e IGNITE-27148 Remove code related to non-colocated case
(storage modules) (#7053)
add 66d59c94e46 IGNITE-27144 Call "waitUntilPageIsFullyInitialized"
outside segment lock (#7043)
add efd5a1366ad IGNITE-27160 Move @ErrorCodeGroup into its own module
(#7066)
add 5168177d12b IGNITE-26364 Allow starting node with string configuration
(#6963)
add caf60dbecee IGNITE-26898 Reforward request to the target node in
restartWithCleanup (#7008)
add 87fad3e90a4 IGNITE-27013 ODBC 3.0: Implement heartbeats (#7001)
add f6eaf1254be IGNITE-26849 Fix node recovery after aborting raft
snapshot installation and raft log truncation (#7054)
add d2d9cf20c67 IGNITE-27120 Sql. Await start of transaction usage in test
on cancellation (#7038)
add 83d4deb1b3c IGNITE-26870 Fix flaky
ItIdempotentCommandCacheTest.testIdempotentInvokeAfterLeaderChange (#7036)
add adaa25871c8 IGNITE-26544 Implement new REST POST method for data nodes
recalculation (#6902)
add 5615d65efbf IGNITE-27143 Eliminate non-colocation code from
TableManager. (#7055)
add 1e9c1e27b92 IGNITE-27173 .NET: Distributed cache: fix column names in
README.md (#7070)
add de6546bfaf3 IGNITE-27166 Optimize ascii strings comparison (#7068)
add e4567b622d4 IGNITE-27165 Increase timeouts in ThrottlingTest (#7069)
add 55d6a05b2e2 IGNITE-27164 Remove code related to non-colocated case
(sql module) (#7071)
add 63e6b1b1bb0 IGNITE-27184 Fix Raft snapshot file compatibility (#7084)
add 1f269c38cae IGNITE-27008 Improve index build log (#7064)
add c20203ebe49 IGNITE-27147 Optimise compaction of multiple delta files
(#7067)
add c8851decef1 IGNITE-26150 Jdbc. Description of the new JDBC features
has been added to the documentation (#7040)
add 6f9322ca686 IGNITE-23633 Retry ChangePeersAndLearnersRequest on fail
while pendings handling (#7030)
add 4afa0828138 Bump org.openapi.generator from 7.12.0 to 7.17.0
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 (c099fd361dc)
\
N -- N -- N
refs/heads/dependabot/gradle/org.openapi.generator-7.17.0 (4afa0828138)
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:
.github/dependabot.yml | 4 +
.../All checks [PMD, spotbugs, checkstyle].run.xml | 12 +-
...run.xml => All checkstyle [checkstyle].run.xml} | 2 +-
...ck [spotbugsMain].run.xml => PMD [pmd].run.xml} | 6 +-
...].run.xml => Spotbugs check [spotbugs].run.xml} | 5 +-
.teamcity/build/build_types/ReleaseBuild.kt | 1 +
.teamcity/pom.xml | 28 +-
.teamcity/test/build_types/RunAllTests.kt | 1 -
.teamcity/test/build_types/RunAllTestsCustomJDK.kt | 1 -
.../test/platform_tests/PlatformCppTestsLinux.kt | 6 +-
.teamcity/test/template_types/OtherTestsModule.kt | 3 +-
.teamcity/test/template_types/TestsModule.kt | 3 +-
build.gradle | 21 +-
.../migration-tools-integration-test.gradle | 10 +
docs/_data/toc.yaml | 4 +-
.../storage/distribution-zones.adoc | 245 +
.../developers-guide/clients/jdbc-driver.adoc | 30 +-
docs/_docs/developers-guide/sql/jdbc-driver.adoc | 108 -
examples/sql/ddl_examples.sql | 230 +
examples/sql/distribution-zones.sql | 77 +
examples/sql/world.sql | 5355 ++++++++++++++++++++
gradle/libs.versions.toml | 11 +-
.../containers/Ignite2ClusterWithSamples.java | 7 +-
.../tests/containers/MigrationToolsContainer.java | 9 +-
migration-tools/packaging/cli/build.gradle | 4 +-
.../e2e-tests-framework/ai2-runner/build.gradle | 4 +-
modules/api/build.gradle | 2 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 9 +
.../java/org/apache/ignite/sql/ColumnType.java | 5 +-
.../ignite/table/AbstractImmutableTupleTest.java | 2 +-
.../compaction/ItCatalogCompactionTest.java | 201 +-
.../compaction/CatalogCompactionRunner.java | 32 +-
.../compaction/CatalogManagerCompactionFacade.java | 36 +-
.../CatalogCompactionRunnerSelfTest.java | 14 +-
.../CatalogManagerCompactionFacadeTest.java | 82 +-
.../internal/catalog/CatalogManagerImpl.java | 52 +-
.../ignite/internal/catalog/CatalogService.java | 14 +-
.../internal/catalog/commands/CatalogUtils.java | 137 +-
.../catalog/commands/CreateTableCommand.java | 37 +-
.../catalog/commands/CreateZoneCommand.java | 3 +-
.../catalog/commands/RenameZoneCommand.java | 3 +-
.../internal/catalog/storage/NewSchemaEntry.java | 4 +-
...CatalogManagerDescriptorCausalityTokenTest.java | 7 +-
.../internal/catalog/CatalogManagerSelfTest.java | 26 +-
.../internal/catalog/CatalogSystemViewTest.java | 2 +-
.../ignite/internal/catalog/CatalogTableTest.java | 93 +-
.../ignite/internal/catalog/CatalogZoneTest.java | 9 +
...ractChangeIndexStatusCommandValidationTest.java | 2 +-
.../commands/AbstractCommandValidationTest.java | 25 +-
.../AlterTableDropColumnCommandValidationTest.java | 2 +-
.../commands/AlterZoneCommandValidationTest.java | 9 +-
.../catalog/commands/CatalogUtilsTest.java | 2 +-
.../CreateSchemaCommandValidationTest.java | 2 +-
.../commands/CreateSystemSchemaValidationTest.java | 2 +-
.../commands/CreateTableCommandValidationTest.java | 19 +-
.../commands/DropIndexCommandValidationTest.java | 2 +-
.../commands/DropZoneCommandValidationTest.java | 2 +-
.../commands/RenameIndexCommandValidationTest.java | 4 +-
.../commands/RenameTableCommandValidationTest.java | 4 +-
.../storage/CatalogSerializationChecker.java | 18 +-
.../CatalogSerializationCompatibilityTest.java | 1 -
...atalogSerializationCompatibilityV1BaseTest.java | 3 +
.../internal/catalog/BaseCatalogManagerTest.java | 18 +
.../ignite/internal/cli/CliIntegrationTest.java | 3 +-
.../cluster/init/ItClusterInitOneNodeTest.java | 66 +
.../partitions/states/ItPartitionStatesTest.java | 15 +-
.../cli/commands/sql/ItSqlCommandTest.java | 5 +-
.../cli/commands/sql/ItSqlReplCommandTest.java | 2 +-
.../internal/cli/call/cluster/ClusterInitCall.java | 59 +-
...allFactory.java => ClusterInitCallFactory.java} | 15 +-
.../call/cluster/unit/DeployUnitCallFactory.java | 7 +-
.../cli/call/cluster/unit/DeployUnitReplCall.java | 4 +-
.../commands/cluster/init/ClusterInitCommand.java | 14 +-
.../cluster/init/ClusterInitConstants.java} | 10 +-
.../cluster/init/ClusterInitReplCommand.java | 33 +-
.../cluster/unit/ClusterUnitDeployCommand.java | 5 +-
.../cli/core/call/AsyncCallExecutionPipeline.java | 8 +-
.../call/AsyncCallExecutionPipelineBuilder.java | 33 +-
.../internal/cli/core/call/AsyncCallFactory.java} | 14 +-
.../cli/core/call/CallExecutionPipeline.java | 6 +-
.../internal/cli/core/call/SpinnerRenderer.java} | 39 +-
.../exception/handler/SqlExceptionHandler.java | 150 +-
.../cli/core/repl/ConnectionHeartBeat.java | 14 +-
.../cli/core/style/component/ErrorUiComponent.java | 18 +-
.../internal/cli/commands/CliCommandTestBase.java | 113 +-
.../internal/cli/commands/ProfileMixinTest.java | 116 +-
.../cli/commands/UrlOptionsNegativeTest.java | 34 +-
.../cli/commands/cluster/ClusterInitReplTest.java | 11 +
.../cli/commands/cluster/ClusterInitTest.java | 16 +-
.../partitions/restart/RestartPartitionsTest.java | 29 +-
.../cli/core/call/SpinnerRendererTest.java} | 30 +-
.../ignite/internal/client/proto/ClientOp.java | 5 +
.../client/proto/ProtocolBitmaskFeature.java | 12 +-
.../client/proto/tx/ClientInternalTxOptions.java} | 47 +-
.../ignite/internal/client/sql/QueryModifier.java | 93 +
.../ignite/internal/compute/PojoConverter.java | 1 +
.../internal/compute/SharedComputeUtils.java | 1 +
.../internal/jdbc/proto/IgniteQueryErrorCode.java | 1 +
.../jdbc/proto/JdbcDatabaseMetadataHandler.java | 65 +
.../internal/jdbc/proto/JdbcQueryEventHandler.java | 129 -
.../ignite/internal/jdbc/proto/SqlStateCode.java | 3 +
.../internal/jdbc/proto/event/JdbcColumnMeta.java | 12 +-
.../client/proto/sql/QueryModifierTest.java | 67 +
.../ignite/client/handler/ItClientHandlerTest.java | 2 +
.../ignite/client/handler/ClientHandlerModule.java | 4 +-
.../handler/ClientInboundMessageHandler.java | 15 +-
.../client/handler/ClientResourceRegistry.java | 12 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 115 +-
.../requests/jdbc/ClientJdbcCancelRequest.java | 4 +-
.../jdbc/ClientJdbcColumnMetadataRequest.java | 4 +-
.../requests/jdbc/ClientJdbcConnectRequest.java | 4 +-
.../jdbc/ClientJdbcPrimaryKeyMetadataRequest.java | 4 +-
.../jdbc/ClientJdbcSchemasMetadataRequest.java | 4 +-
.../jdbc/ClientJdbcTableMetadataRequest.java | 4 +-
.../handler/requests/sql/ClientSqlCommon.java | 208 +
.../sql/ClientSqlCursorNextResultRequest.java | 87 +
.../requests/sql/ClientSqlExecuteBatchRequest.java | 2 +-
.../requests/sql/ClientSqlExecuteRequest.java | 146 +-
.../sql/ClientSqlExecuteScriptRequest.java | 2 +-
.../handler/requests/sql/ClientSqlProperties.java | 15 +-
.../handler/requests/table/ClientTableCommon.java | 62 +-
.../table/ClientTupleContainsAllKeysRequest.java | 24 +-
.../table/ClientTupleContainsKeyRequest.java | 5 +-
.../table/ClientTupleDeleteAllExactRequest.java | 5 +-
.../table/ClientTupleDeleteAllRequest.java | 4 +-
.../table/ClientTupleDeleteExactRequest.java | 5 +-
.../requests/table/ClientTupleDeleteRequest.java | 4 +-
.../requests/table/ClientTupleGetAllRequest.java | 36 +-
.../table/ClientTupleGetAndDeleteRequest.java | 4 +-
.../table/ClientTupleGetAndReplaceRequest.java | 5 +-
.../table/ClientTupleGetAndUpsertRequest.java | 5 +-
.../requests/table/ClientTupleGetRequest.java | 5 +-
.../table/ClientTupleInsertAllRequest.java | 5 +-
.../requests/table/ClientTupleInsertRequest.java | 5 +-
.../table/ClientTupleReplaceExactRequest.java | 4 +-
.../requests/table/ClientTupleReplaceRequest.java | 5 +-
.../requests/table/ClientTupleRequestBase.java | 42 +-
.../table/ClientTupleUpsertAllRequest.java | 5 +-
.../requests/table/ClientTupleUpsertRequest.java | 5 +-
.../requests/table/ClientTuplesRequestBase.java | 25 +-
.../client/handler/ClientResourceRegistryTest.java | 6 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 3 +-
.../handler/requests/sql/ClientSqlCommonTest.java | 92 +
.../ignite/client/handler/FakeCatalogService.java | 5 +
.../apache/ignite/client/ClientOperationType.java | 5 +
.../org/apache/ignite/client/RetryReadPolicy.java | 1 +
.../ignite/internal/client/ChannelValidator.java | 50 +
.../ignite/internal/client/ClientFutureUtils.java | 33 +-
.../apache/ignite/internal/client/ClientUtils.java | 3 +
.../ignite/internal/client/ProtocolContext.java | 18 +-
.../ignite/internal/client/ReliableChannel.java | 49 +-
.../ignite/internal/client/TcpClientChannel.java | 34 +-
.../ignite/internal/client/TcpIgniteClient.java | 23 +-
.../ignite/internal/client/WriteContext.java | 4 +-
.../internal/client/sql/ClientAsyncResultSet.java | 267 +-
.../ignite/internal/client/sql/ClientSql.java | 49 +-
.../client/table/ClientKeyValueBinaryView.java | 49 +-
.../internal/client/table/ClientKeyValueView.java | 51 +-
.../client/table/ClientRecordBinaryView.java | 57 +-
.../internal/client/table/ClientRecordView.java | 59 +-
.../ignite/internal/client/table/ClientTable.java | 124 +-
.../internal/client/table/ClientTableMapUtils.java | 163 +
.../ignite/internal/client/table/MapFunction.java} | 22 +-
.../internal/client/tx/ClientLazyTransaction.java | 26 +-
.../ignite/internal/client/tx/DirectTxUtils.java | 28 +-
.../ignite/client/ClientKeyValueViewTest.java | 23 +-
.../org/apache/ignite/client/ClientSqlTest.java | 59 +
.../org/apache/ignite/client/ClientTupleTest.java | 2 +-
.../org/apache/ignite/client/RetryPolicyTest.java | 59 +-
.../ignite/client/TestClientHandlerModule.java | 1 +
.../org/apache/ignite/client/fakes/FakeCursor.java | 8 +
.../apache/ignite/client/fakes/FakeTxManager.java | 2 +-
.../internal/client/ClientFutureUtilsTest.java | 17 -
.../RepeatedFinishClientTransactionTest.java | 5 +-
modules/cluster-management/build.gradle | 2 +
.../cluster/management/ItClusterManagerTest.java | 28 +-
.../management/raft/ItCmgRaftServiceTest.java | 6 +-
.../cluster/management/ClusterInitializer.java | 9 +-
.../management/ClusterManagementGroupManager.java | 23 +-
.../network/messages/CmgInitMessage.java | 2 +
.../cluster/management/raft/CmgRaftService.java | 6 +-
.../cluster/management/ClusterInitializerTest.java | 4 +-
.../network/messages/CmgInitMessageTest.java} | 52 +-
.../management/BaseItClusterManagementTest.java | 26 +
.../internal/cluster/management/MockNode.java | 42 +-
modules/compatibility-tests/build.gradle | 1 +
modules/compatibility-tests/jobs.gradle | 2 +
.../internal/ItCmgRaftLogCompatibilityTest.java | 94 +
.../ItCmgRaftSnapshotCompatibilityTest.java | 37 +-
...ItMetastorageRaftSnapshotCompatibilityTest.java | 3 +-
.../internal/PersistentCompatibilityTest.java | 34 +-
.../WriteIntentStorageCompatibilityTest.java | 69 +
...cOverThinSqlWithOldServerCompatibilityTest.java | 82 +
.../DisableWriteIntentSwitchExecutionJob.java} | 27 +-
.../ignite/internal/CompatibilityTestBase.java | 16 +-
.../org/apache/ignite/internal/IgniteCluster.java | 10 +-
.../ignite/internal/jobs/DeploymentUtils.java | 3 +-
.../src/testFixtures/resources/igniteVersions.json | 3 -
.../internal/compute/ItWorkerShutdownTest.java | 7 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 24 +-
.../compute/NextColocatedWorkerSelector.java | 27 +-
.../compute/PartitionNextWorkerSelector.java | 13 +-
.../compute/PrimaryReplicaNextWorkerSelector.java | 4 +-
.../internal/compute/IgniteComputeImplTest.java | 5 -
.../internal/causality/BaseVersionedValue.java | 25 +-
.../causality/CompletableVersionedValue.java | 15 +-
.../internal/causality/CompletionListener.java | 4 +-
.../causality/IncrementalVersionedValue.java | 24 +-
.../components/SystemPropertiesNodeProperties.java | 1 +
.../ignite/internal/sql/SyncResultSetAdapter.java | 31 +-
.../apache/ignite/internal/thread/ThreadUtils.java | 3 +-
.../internal/tostring/IgniteToStringBuilder.java | 2 +-
.../apache/ignite/internal/type/NativeType.java | 52 +-
.../apache/ignite/internal/type/NativeTypes.java | 80 +-
.../ignite/internal/type/StructNativeType.java | 126 +
.../ignite/internal/util/IgniteBusyLock.java} | 18 +-
.../ignite/internal/util/IgniteSpinBusyLock.java | 4 +-
.../internal/util/IgniteStripedBusyLock.java | 4 +-
.../apache/ignite/internal/util/IgniteUtils.java | 20 +-
.../org/apache/ignite/internal/util/ViewUtils.java | 4 +-
.../causality/IncrementalVersionedValueTest.java | 51 +-
modules/distribution-zones/build.gradle | 3 +
.../apache/ignite/internal/TestRebalanceUtil.java | 195 -
.../distributionzones/ItDataNodesManagerTest.java | 87 +-
...tDistributionZoneMetaStorageCompactionTest.java | 13 +-
.../ItDistributionZonesFiltersTest.java | 39 +-
...niteDistributionZoneManagerNodeRestartTest.java | 46 +-
.../ItRebalanceByPendingAssignmentsQueueTest.java | 146 +-
.../rebalance/ItRebalanceDistributedTest.java | 216 +-
.../ignite/internal/rebalance/ItRebalanceTest.java | 8 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 15 +-
.../ignite/internal/table/ItEstimatedSizeTest.java | 31 +-
.../distributionzones/DataNodesManager.java | 46 +-
.../distributionzones/DistributionZoneManager.java | 75 +-
.../distributionzones/DistributionZonesUtil.java | 40 +
.../DistributionZoneNotFoundException.java | 10 +
.../rebalance/DistributionZoneRebalanceEngine.java | 349 --
.../DistributionZoneRebalanceEngineV2.java | 14 +-
.../rebalance/PartitionMover.java | 119 -
.../RebalanceRaftGroupEventsListener.java | 701 ---
.../distributionzones/rebalance/RebalanceUtil.java | 11 -
.../ZoneRebalanceRaftGroupEventsListener.java | 74 +-
.../rebalance/ZoneRebalanceUtil.java | 50 +-
.../BaseDistributionZoneManagerTest.java | 12 +-
.../distributionzones/DataNodesManagerTest.java | 91 +-
.../DistributionZoneManagerAlterFilterTest.java | 2 +
...ibutionZoneManagerConfigurationChangesTest.java | 2 -
...istributionZoneManagerScaleUpScaleDownTest.java | 37 +-
.../DistributionZoneCausalityDataNodesTest.java | 14 +-
.../DistributionZoneRebalanceEngineTest.java | 69 +-
...balanceMinimumRequiredTimeProviderImplTest.java | 40 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 55 +-
.../distributionzones/DataNodesTestUtil.java | 267 +
.../DistributionZonesTestUtil.java | 122 +-
.../error-code-annotation-processor/build.gradle | 1 +
.../build.gradle} | 10 +-
.../error/code/annotations/ErrorCodeGroup.java | 5 +-
.../ignite/internal/failure/FailureManager.java | 4 +-
.../internal/index/ItBuildIndexOneNodeTest.java | 10 +-
.../ignite/internal/index/ItBuildIndexTest.java | 155 +-
.../ItBuildIndexWriteIntentsHandlingTest.java | 230 +
.../internal/index/WriteIntentSwitchControl.java} | 22 +-
.../internal/index/ChangeIndexStatusTask.java | 11 +-
.../index/ChangeIndexStatusTaskController.java | 63 +-
.../index/ChangeIndexStatusTaskScheduler.java | 7 -
.../index/FinalTransactionStateResolver.java | 4 +-
.../internal/index/IndexBuildController.java | 186 +-
.../ignite/internal/index/IndexBuildTask.java | 117 +-
.../IndexBuildTaskStatisticsLoggingListener.java | 148 +
.../apache/ignite/internal/index/IndexBuilder.java | 30 +-
.../internal/index/IndexBuildingManager.java | 8 +-
.../RetryingFinalTransactionStateResolver.java | 6 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 13 +-
.../internal/index/ChangeIndexStatusTaskTest.java | 25 +-
.../CommittedFinalTransactionStateResolver.java | 4 +-
.../index/IndexAvailabilityControllerTest.java | 6 +-
.../internal/index/IndexBuildControllerTest.java | 26 +-
...ndexBuildTaskStatisticsLoggingListenerTest.java | 84 +
.../ignite/internal/index/IndexBuilderTest.java | 6 +-
.../internal/index/IndexManagementUtilsTest.java | 9 +-
.../internal/index/TestIndexManagementUtils.java | 4 +-
modules/jdbc/build.gradle | 2 +
.../jdbc/ItJdbcClusterPerIntegrationTest.java | 111 +
.../internal/jdbc/ItJdbcMetadataSelfTest.java | 858 +++-
.../jdbc/ItJdbcParameterMetadataSelfTest.java | 149 +
.../jdbc/ItJdbcResultSetMetadataSelfTest.java | 94 +
.../apache/ignite/jdbc/AbstractJdbcSelfTest.java | 17 +-
.../ignite/jdbc/ItJdbcAuthenticationTest.java | 6 +
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 62 +-
.../ignite/jdbc/ItJdbcComplexDmlDdlSelfTest.java | 10 +-
.../ignite/jdbc/ItJdbcComplexQuerySelfTest.java | 12 +-
.../ignite/jdbc/ItJdbcConnectionFailoverTest.java | 164 +
.../ignite/jdbc/ItJdbcConnectionSelfTest.java | 97 +-
.../ignite/jdbc/ItJdbcErrorsAbstractSelfTest.java | 11 +-
.../apache/ignite/jdbc/ItJdbcErrorsSelfTest.java | 1 -
.../apache/ignite/jdbc/ItJdbcJoinsSelfTest.java | 2 +
.../apache/ignite/jdbc/ItJdbcKillCommandTest.java | 15 +-
.../ignite/jdbc/ItJdbcMultiStatementSelfTest.java | 87 +-
.../apache/ignite/jdbc/ItJdbcQueryMetricsTest.java | 27 +-
.../ignite/jdbc/ItJdbcResultSetSelfTest.java | 6 -
.../ignite/jdbc/ItJdbcStatementCancelSelfTest.java | 21 +-
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 30 +-
.../apache/ignite/jdbc/ItJdbcTransactionTest.java | 31 +-
.../ignite/jdbc/ItJdbcWithC3p0PoolTest.java} | 21 +-
.../jdbc/ItJdbcWithConnectionPoolBaseTest.java | 245 +
.../ignite/jdbc/ItJdbcWithHikariPoolTest.java} | 22 +-
.../ignite/internal/jdbc/ClientSyncResultSet.java} | 34 +-
.../internal/jdbc/ClientSyncResultSetImpl.java | 84 +
.../ignite/internal/jdbc/ConnectionProperties.java | 7 +
.../internal/jdbc/ConnectionPropertiesImpl.java | 12 +-
.../jdbc/JdbcClientDatabaseMetadataHandler.java | 96 +
.../jdbc/JdbcClientQueryCursorHandler.java | 81 -
.../internal/jdbc/JdbcClientQueryEventHandler.java | 200 -
.../ignite/internal/jdbc/JdbcConnection.java | 629 +--
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 755 +--
.../internal/jdbc/JdbcExceptionMapperUtil.java | 56 +
.../internal/jdbc/JdbcPreparedStatement.java | 450 +-
.../internal/jdbc/JdbcQueryExecuteResponse.java | 97 -
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 1386 +++--
.../internal/jdbc/JdbcResultSetMetadata.java | 121 +-
.../apache/ignite/internal/jdbc/JdbcStatement.java | 592 +--
.../org/apache/ignite/internal/jdbc/JdbcUtils.java | 333 ++
.../ignite/internal/jdbc/ResultSetWrapper.java | 97 +
.../org/apache/ignite/jdbc/IgniteJdbcDriver.java | 117 +-
.../ignite/internal/jdbc/ColumnDefinition.java | 67 +
.../internal/jdbc/JdbcConnectionSelfTest.java | 474 ++
.../jdbc/JdbcDatabaseMetadataSelfTest.java | 275 +
.../jdbc/JdbcPreparedStatementSelfTest.java | 725 +++
.../internal/jdbc/JdbcResultSetBaseSelfTest.java | 4080 +++++++++++++++
.../jdbc/JdbcResultSetMetadataBaseSelfTest.java | 320 ++
.../jdbc/JdbcResultSetMetadataSelfTest.java | 82 +
.../internal/jdbc/JdbcResultSetSelfTest.java | 281 +
.../ignite/internal/jdbc/JdbcResultSetTest.java | 779 ---
.../internal/jdbc/JdbcStatementSelfTest.java | 456 ++
.../internal/jdbc/PreparedStatementParamsTest.java | 435 --
.../ignite/internal/marshaller/TupleReader.java | 7 +-
.../impl/ItIdempotentCommandCacheTest.java | 56 +-
.../ItMetaStorageCompactionTriggerOneNodeTest.java | 4 +-
.../impl/ItMetaStorageCompactionTriggerTest.java | 4 +-
.../impl/ItMetaStorageManagerImplTest.java | 12 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 17 +-
.../metastorage/impl/ItMetaStorageServiceTest.java | 14 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 9 +-
.../impl/MetaStorageLeaderElectionListener.java | 3 +-
.../impl/MetaStorageLearnerManager.java | 14 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 8 +-
.../raft/MetaStorageSnapshotStorageFactory.java | 2 +
.../metastorage/server/UpdateEntriesEvent.java | 12 +-
.../server/raft/MetaStorageListener.java | 2 +-
.../server/raft/MetaStorageWriteHandler.java | 10 +-
.../impl/StandaloneMetaStorageManager.java | 18 +-
modules/page-memory/build.gradle | 1 +
.../pagememory/persistence/PageHeader.java | 38 +-
.../persistence/PersistentPageMemory.java | 109 +-
.../checkpoint/CheckpointReadWriteLock.java | 7 +
.../checkpoint/CheckpointTimeoutLock.java | 11 +
.../persistence/checkpoint/Checkpointer.java | 12 +
.../ReentrantReadWriteLockWithTracking.java | 14 +
.../compaction/CompactionMetricsTracker.java | 23 +
.../persistence/compaction/Compactor.java | 102 +-
.../persistence/store/FilePageStore.java | 17 +
.../ignite/internal/pagememory/tree/BplusTree.java | 19 +-
.../internal/pagememory/tree/IgniteTree.java | 12 +-
.../persistence/checkpoint/CheckpointerTest.java | 22 +-
.../persistence/compaction/CompactorTest.java | 207 +-
.../persistence/store/FilePageStoreTest.java | 10 +
.../throttling/PageMemoryThrottlingTest.java | 4 +-
.../persistence/throttling/ThrottlingTest.java | 11 +-
modules/partition-replicator/build.gradle | 1 +
.../replicator/ItColocationStatusHandlingTest.java | 115 +-
.../replicator/ItReplicaLifecycleTest.java | 14 +-
.../partition/replicator/ItZoneTxFinishTest.java | 2 +-
.../partition/replicator/fixtures/Node.java | 15 +-
.../ItZonePartitionRaftListenerRecoveryTest.java | 11 +-
.../PartitionReplicaLifecycleManager.java | 213 +-
.../partition/replicator/ZoneResourcesManager.java | 11 +-
.../network/PartitionReplicationMessageGroup.java | 6 +
.../DisasterRecoveryRequestMessage.java} | 23 +-
.../DisasterRecoveryResponseMessage.java} | 20 +-
.../ChangePeersAndLearnersAsyncReplicaRequest.java | 6 +
.../raft/snapshot/LogStorageAccess.java} | 30 +-
.../raft/snapshot/LogStorageAccessImpl.java} | 28 +-
.../replicator/raft/snapshot/PartitionKey.java | 4 +
.../raft/snapshot/PartitionMvStorageAccess.java | 3 +
.../raft/snapshot/PartitionSnapshotStorage.java | 17 +-
.../replicator/raft/snapshot/ZonePartitionKey.java | 7 +
.../snapshot/incoming/IncomingSnapshotCopier.java | 56 +-
.../incoming/ReplicationLogStorageKey.java | 76 +
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 3 +-
.../raft/snapshot/outgoing/SnapshotMetaUtils.java | 2 +
.../PartitionReplicaLifecycleManagerTest.java | 65 +-
.../replicator/ZoneResourcesManagerTest.java | 5 +-
.../raft/ZonePartitionRaftListenerTest.java | 8 +-
.../PartitionSnapshotStorageFactoryTest.java | 3 +-
.../snapshot/PartitionSnapshotStorageTest.java | 3 +-
.../incoming/IncomingSnapshotCopierTest.java | 17 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 4 +-
.../outgoing/OutgoingSnapshotReaderTest.java | 4 +-
.../SnapshotAwarePartitionDataStorageTest.java | 2 +
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 4 +-
.../placementdriver/LeasePlacementDriver.java | 1 +
.../ItPrimaryReplicaChoiceTest.java | 19 +-
.../MultiActorPlacementDriverTest.java | 5 +
.../PlacementDriverManagerTest.java | 5 +
.../PlacementDriverNodesOperabilityTest.java | 8 +-
.../placementdriver/AssignmentsTrackerTest.java | 16 +-
.../placementdriver/PlacementDriverTest.java | 38 +-
modules/platforms/cpp/ignite/client/CMakeLists.txt | 4 +-
.../cpp/ignite/client/detail/node_connection.cpp | 14 +-
.../cpp/ignite/client/detail/node_connection.h | 3 -
.../ignite/client/detail/table/name_utils_test.cpp | 28 +-
.../ignite/client/ignite_client_configuration.h | 10 +-
.../ignite/client/table/qualified_name_test.cpp | 57 +-
.../cpp/ignite/common/detail/duration_min_max.h} | 20 +-
modules/platforms/cpp/ignite/common/error_codes.h | 3 +
modules/platforms/cpp/ignite/odbc/common_types.cpp | 4 +
.../cpp/ignite/odbc/config/config_tools_test.cpp | 52 +-
.../cpp/ignite/odbc/config/configuration.cpp | 35 +-
.../cpp/ignite/odbc/config/configuration.h | 24 +-
modules/platforms/cpp/ignite/odbc/odbc.cpp | 72 +-
.../platforms/cpp/ignite/odbc/sql_connection.cpp | 64 +-
modules/platforms/cpp/ignite/odbc/sql_connection.h | 257 +-
.../platforms/cpp/ignite/odbc/sql_environment.cpp | 24 +-
.../platforms/cpp/ignite/odbc/sql_environment.h | 17 +-
.../platforms/cpp/ignite/protocol/CMakeLists.txt | 1 +
.../cpp/ignite/protocol/heartbeat_timeout.h} | 30 +-
modules/platforms/cpp/ignite/protocol/messages.h | 2 +-
.../platforms/cpp/tests/odbc-test/CMakeLists.txt | 2 +-
.../cpp/tests/odbc-test/connection_test.cpp | 10 +
.../cpp/tests/odbc-test/odbc_connection.h | 94 +-
modules/platforms/cpp/tests/odbc-test/odbc_suite.h | 23 +-
.../platforms/cpp/tests/odbc-test/queries_test.cpp | 3 +-
modules/platforms/cpp/tests/odbc-test/ssl_test.cpp | 6 +-
.../cpp/tests/odbc-test/transaction_test.cpp | 42 +
.../platforms/cpp/tests/test-common/CMakeLists.txt | 1 +
.../platforms/cpp/tests/test-common/hidden_param.h | 68 +
modules/platforms/dotnet/.config/dotnet-tools.json | 2 +-
.../Apache.Extensions.Caching.Ignite/README.md | 4 +-
.../Apache.Ignite.Benchmarks.csproj | 2 +-
.../Apache.Ignite.Tests/Apache.Ignite.Tests.csproj | 10 +
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 4 +-
.../Apache.Ignite.Tests/Compute/DotNetJobs.cs | 18 +
.../Compute/Executor/DeploymentUnitLoaderTests.cs | 23 +
.../Compute/Executor/NewerDotnetJobs/EchoJob.cs | 24 +
.../NewerDotnetJobs/NewerDotnetJobs.csproj | 13 +
.../Executor/NewerDotnetJobs/NewerDotnetJobs.dll | Bin 0 -> 6144 bytes
.../Compute/Executor/NewerDotnetJobs/global.json | 6 +
.../Compute/PlatformComputeTests.cs | 13 +
.../dotnet/Apache.Ignite.Tests/ConsoleLogger.cs | 34 +-
.../dotnet/Apache.Ignite.Tests/IgniteProxy.cs | 2 +
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 22 +-
.../dotnet/Apache.Ignite.Tests/LoggingTests.cs | 2 +-
.../PartitionAwarenessRealClusterTests.cs | 6 +-
.../Table/SchemaSynchronizationTest.cs | 1 +
.../TestHelpers/ManagementApi.cs | 5 +-
.../dotnet/Apache.Ignite.Tests/TestUtils.cs | 6 +-
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 2 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 9 +
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 35 +-
.../Internal/Compute/Executor/JobLoadContext.cs | 44 +
.../dotnet/Apache.Ignite/Internal/LogMessages.cs | 4 +-
.../dotnet/Apache.Ignite/Sql/SqlStatement.cs | 9 +-
.../internal/raft/RaftGroupConfiguration.java | 21 +-
.../raft/RaftGroupConfigurationSerializer.java | 16 +-
.../internal/raft/RaftGroupEventsListener.java | 12 +-
.../rebalance/ChangePeersAndLearnersWithRetry.java | 100 +
.../internal/raft/rebalance/ExceptionUtils.java} | 30 +-
.../internal/raft/rebalance/RaftCommand.java} | 18 +-
.../raft/rebalance/RaftCommandWithRetry.java | 124 +
.../raft/rebalance/RaftStaleUpdateException.java} | 20 +-
.../internal/raft/service/BeforeApplyHandler.java | 4 +-
.../internal/raft/service/RaftGroupService.java | 28 +-
.../raft/RaftGroupConfigurationSerializerTest.java | 25 +
modules/raft/build.gradle | 2 +
.../ignite/internal/raft/ItLearnersTest.java | 15 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 21 +-
.../internal/raft/ItRaftGroupServiceTest.java | 24 +-
.../raft/ItTruncateSuffixAndRestartTest.java | 6 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 102 +-
.../ignite/raft/jraft/core/ItCliServiceTest.java | 17 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 434 +-
.../ignite/raft/jraft/core/MockStateMachine.java | 18 +
.../apache/ignite/raft/jraft/core/TestCluster.java | 78 +-
.../internal/raft/JraftGroupEventsListener.java | 10 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 54 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 42 +-
.../internal/raft/server/impl/JraftServerImpl.java | 24 +-
.../impl/RaftGroupEventsListenerAdapter.java | 26 +-
.../raft/storage/impl/RocksDbSharedLogStorage.java | 6 +-
.../raft/storage/impl/VolatileRaftMetaStorage.java | 5 +
.../org/apache/ignite/raft/jraft/CliService.java | 24 +-
.../java/org/apache/ignite/raft/jraft/Node.java | 31 +-
.../ignite/raft/jraft/conf/Configuration.java | 56 +-
.../ignite/raft/jraft/core/CliServiceImpl.java | 28 +-
.../jraft/core/DefaultJRaftServiceFactory.java | 4 +-
.../ignite/raft/jraft/core/FSMCallerImpl.java | 22 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 225 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 2 +
.../apache/ignite/raft/jraft/entity/LogEntry.java | 30 +
.../ignite/raft/jraft/entity/RaftOutter.java | 11 +-
.../raft/jraft/entity/codec/AutoDetectDecoder.java | 22 +-
.../entity/codec/DefaultLogEntryCodecFactory.java | 10 +-
.../entity/codec/v2/LogEntryV2CodecFactory.java | 80 +
.../raft/jraft/entity/codec/v2/V2Decoder.java | 190 +
.../raft/jraft/entity/codec/v2/V2Encoder.java | 255 +
.../apache/ignite/raft/jraft/error/RaftError.java | 4 +-
.../raft/jraft/option/LogManagerOptions.java | 4 +-
.../apache/ignite/raft/jraft/rpc/CliRequests.java | 18 +
.../jraft/rpc/impl/ActionRequestProcessor.java | 30 +-
.../rpc/impl/cli/AddLearnersRequestProcessor.java | 6 +-
.../rpc/impl/cli/AddPeerRequestProcessor.java | 6 +-
...hangePeersAndLearnersAsyncRequestProcessor.java | 10 +-
.../ChangePeersAndLearnersRequestProcessor.java | 10 +-
.../impl/cli/RemoveLearnersRequestProcessor.java | 6 +-
.../rpc/impl/cli/RemovePeerRequestProcessor.java | 7 +-
.../impl/cli/ResetLearnersRequestProcessor.java | 10 +-
.../rpc/impl/cli/ResetPeerRequestProcessor.java | 7 +-
.../ignite/raft/jraft/storage/RaftMetaStorage.java | 4 +-
.../jraft/storage/impl/LocalRaftMetaStorage.java | 12 +-
.../raft/jraft/storage/impl/LogManagerImpl.java | 10 +-
.../raft/jraft/storage/impl/RocksDBLogStorage.java | 6 +-
.../ignite/raft/jraft/storage/io/MessageFile.java | 17 +-
.../storage/logit/storage/LogitLogStorage.java | 4 +-
.../logit/storage/file/segment/SegmentFile.java | 5 +-
.../raft/jraft/util/CompatibleJDKMarshaller.java | 119 +
.../raft/JraftGroupEventsListenerTest.java | 2 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 6 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 24 +-
.../ChangePeersAndLearnersWithRetryTest.java} | 45 +-
.../ignite/raft/jraft/entity/LogEntryTest.java | 18 +-
.../entity/codec/BackwardCompatibilityTest.java | 224 +
.../raft/jraft/entity/codec/v2/V2EncoderTest.java | 173 +
.../impl/cli/AddLearnersRequestProcessorTest.java | 11 +-
.../rpc/impl/cli/AddPeerRequestProcessorTest.java | 12 +-
...ePeersAndLearnersAsyncRequestProcessorTest.java | 3 +-
...ChangePeersAndLearnersRequestProcessorTest.java | 16 +-
.../cli/RemoveLearnersRequestProcessorTest.java | 11 +-
.../impl/cli/RemovePeerRequestProcessorTest.java | 12 +-
.../cli/ResetLearnersRequestProcessorTest.java | 11 +-
.../impl/cli/ResetPeersRequestProcessorTest.java | 12 +-
.../ignite/internal/raft/TestLozaFactory.java | 15 +-
modules/replicator/build.gradle | 1 +
.../ItPlacementDriverReplicaSideTest.java | 7 +-
.../raft/client/TopologyAwareRaftGroupService.java | 28 +-
.../ignite/internal/replicator/ReplicaImpl.java | 55 +-
.../ignite/internal/replicator/ReplicaManager.java | 89 +-
.../internal/replicator/ReplicaStateManager.java | 7 +-
.../internal/replicator/VersionedAssignments.java} | 36 +-
.../replicator/message/ReplicaMessageUtils.java | 2 +
.../message/TablePartitionIdMessage.java | 3 +-
.../replicator/message/ZonePartitionIdMessage.java | 3 +-
.../replicator/PlacementDriverReplicaSideTest.java | 5 +-
.../internal/replicator/ReplicaManagerTest.java | 2 +-
.../internal/replicator/ReplicaTestUtils.java | 29 +-
modules/rest-api/build.gradle | 2 +-
.../internal/rest/api/zone/DataNodesApi.java | 102 +
modules/rest/build.gradle | 5 +
.../rest/cluster/ItDataNodesControllerTest.java | 271 +
.../ItNodeConfigurationControllerTest.java | 74 +-
.../rest/metrics/ItMetricControllerTest.java | 2 +-
.../ItDisasterRecoveryColocationDisabledTest.java | 125 -
...terRecoveryControllerRestartPartitionsTest.java | 84 +-
...ControllerRestartPartitionsWithCleanupTest.java | 188 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 245 +-
.../rest/cluster/ClusterManagementController.java | 31 +-
.../rest/cluster/ClusterManagementRestFactory.java | 13 +-
.../rest/cluster/DataNodesRestFactory.java | 49 +
.../internal/rest/cluster/JoinFutureProvider.java} | 14 +-
.../internal/rest/zone/DataNodesController.java | 58 +
.../ignite/internal/rest/RestComponentTest.java | 46 +-
.../ConfigurationControllerBaseTest.java | 57 +-
.../SystemDisasterRecoveryControllerTest.java | 31 +-
modules/runner/build.gradle | 1 +
.../internal/benchmark/BulkLoadBenchmark.java | 60 +
.../ignite/internal/benchmark/InsertBenchmark.java | 2 +-
.../ignite/internal/benchmark/SelectBenchmark.java | 2 +-
.../client/ItClientDataConsistencyTest.java} | 29 +-
.../internal/client/ItClientDirectMappingTest.java | 2 +-
.../client/ItClientObservableTimeTest.java | 18 -
.../ItDistributedConfigurationPropertiesTest.java | 21 +-
.../ItDistributedConfigurationStorageTest.java | 13 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 38 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 31 +-
.../app/ItEnabledColocationHomogeneityTest.java | 2 +
.../app/ItIgniteInMemoryNodeRestartTest.java | 35 +-
.../runner/app/ItIgniteNodeRestartTest.java | 47 +-
.../internal/runner/app/ItIgniteServerTest.java | 155 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 9 +-
.../runner/app/ItReplicaStateManagerTest.java | 14 +-
.../client/ItThinClientChannelValidatorTest.java | 275 +
.../client/ItThinClientMultistatementSqlTest.java | 544 ++
.../runner/app/client/ItThinClientSqlTest.java | 91 +
.../app/client/ItThinClientTransactionsTest.java | 158 +
.../internal/table/ItDataConsistencyTest.java | 280 +
.../ignite/internal/table/ItDurabilityTest.java | 165 +
.../ignite/internal/table/ItDurableFinishTest.java | 35 +-
.../internal/table/ItPublicApiColocationTest.java | 6 +-
.../table/ItRebalanceWithPartitionReturnTest.java | 15 +-
.../ignite/internal/table/ItReplicasTest.java | 40 +-
.../ignite/internal/table/ItTableScanTest.java | 27 +-
.../main/java/org/apache/ignite/IgniteServer.java | 57 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 53 +-
.../ignite/internal/app/IgniteServerImpl.java | 48 +-
.../ignite/internal/app/NodePropertiesImpl.java | 19 +-
.../ignite/internal/app/SameValueLongSupplier.java | 49 -
.../ignite/internal/app/ThreadPoolsManager.java | 6 +-
.../internal/app/NodePropertiesImplTest.java | 39 +-
.../internal/app/SameValueLongSupplierTest.java | 59 -
.../configuration/ignite-snapshot.bin | Bin 5524 -> 5611 bytes
.../ignite/internal/AssignmentsTestUtils.java | 6 +-
.../java/org/apache/ignite/internal/Cluster.java | 44 +-
.../internal/ClusterPerClassIntegrationTest.java | 16 +-
.../schema/BinaryTupleComparatorUtils.java | 81 +-
.../internal/schema/PartialBinaryTupleMatcher.java | 2 +-
.../CatalogToSchemaDescriptorConverterTest.java | 2 +-
.../ignite/internal/sql/engine/SqlQueryType.java | 15 +
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 29 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 12 +-
.../sql/api/ItSqlClientSynchronousApiTest.java | 30 +-
.../internal/sql/api/ItSqlCreateZoneTest.java | 50 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 24 +-
.../internal/sql/engine/ItAggregatesTest.java | 2 -
.../internal/sql/engine/ItColocatedDataTest.java | 2 +-
.../sql/engine/ItDynamicParameterTest.java | 2 +-
.../ItPrefixLikeToRangeScanConversionTest.java | 261 +
.../internal/sql/engine/ItSecondaryIndexTest.java | 18 +-
.../sql/engine/ItUnstableTopologyTest.java | 2 -
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 2 +
.../sql/engine/kill/ItSqlKillCommandTest.java | 6 +-
.../sql/engine/statistic/ItStatisticTest.java | 218 +-
.../systemviews/ItSqlQueriesSystemViewTest.java | 10 +-
.../engine/systemviews/ItZonesSystemViewTest.java | 20 +-
.../integrationTest/sql/group1/explain/scan.test | 2 +-
.../internal/sql/api/AsyncResultSetImpl.java | 5 +
...=> CreateTableDefaultsConfigurationSchema.java} | 22 +-
.../SqlDistributedConfigurationSchema.java | 4 +
.../internal/sql/engine/SqlOperationContext.java | 23 +-
.../sql/engine/SqlQueriesViewProvider.java | 1 +
.../internal/sql/engine/SqlQueryProcessor.java | 36 +-
.../engine/exec/ExecutableTableRegistryImpl.java | 9 -
.../internal/sql/engine/exec/ExecutionContext.java | 15 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 119 +-
.../sql/engine/exec/LogicalRelImplementor.java | 44 +-
.../sql/engine/exec/MailboxRegistryImpl.java | 19 +-
.../internal/sql/engine/exec/RowHandler.java | 6 +-
.../sql/engine/exec/ScannableTableImpl.java | 12 +-
.../internal/sql/engine/exec/SqlRowHandler.java | 62 +-
.../internal/sql/engine/exec/TxAttributes.java | 19 +-
.../sql/engine/exec/UpdatableTableImpl.java | 77 +-
.../sql/engine/exec/exp/ExpressionFactory.java | 4 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 6 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 206 +-
.../engine/exec/exp/JoinProjectionImplementor.java | 23 +-
.../sql/engine/exec/exp/ProjectionImplementor.java | 37 +-
.../internal/sql/engine/exec/exp/RexImpTable.java | 5 +
.../engine/exec/exp/RowProviderImplementor.java | 26 +-
.../engine/exec/exp/SearchBoundsImplementor.java | 58 +-
.../sql/engine/exec/exp/ValuesImplementor.java | 6 +-
.../sql/engine/exec/exp/agg/Accumulators.java | 113 +-
.../exec/exp/func/SystemRangeTableFunction.java | 6 +-
.../exec/fsm/CursorInitializationPhaseHandler.java | 18 +-
.../exec/fsm/CursorPublicationPhaseHandler.java | 58 +
.../sql/engine/exec/fsm/DdlBatchGroup.java | 4 +-
.../sql/engine/exec/fsm/ExecutionPhase.java | 2 +
.../sql/engine/exec/fsm/QueryExecutionProgram.java | 11 +-
.../sql/engine/exec/fsm/QueryExecutor.java | 40 +-
.../exec/fsm/ScriptItemExecutionProgram.java | 4 +
.../mapping/ExecutionDistributionProviderImpl.java | 29 +-
.../MappedFragments.java} | 39 +-
.../sql/engine/exec/mapping/MappingService.java | 3 +-
.../engine/exec/mapping/MappingServiceImpl.java | 50 +-
.../mapping/largecluster/LargeClusterFactory.java | 21 +-
.../mapping/smallcluster/SmallClusterFactory.java | 17 +-
.../internal/sql/engine/exec/rel/HashJoinNode.java | 13 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 7 +-
.../sql/engine/exec/rel/MergeJoinNode.java | 13 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 19 +-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 13 +-
.../internal/sql/engine/exec/rel/Outbox.java | 7 +-
.../internal/sql/engine/exec/row/BaseTypeSpec.java | 78 -
.../internal/sql/engine/exec/row/RowSchema.java | 136 -
.../sql/engine/exec/row/RowSchemaTypes.java | 106 -
.../internal/sql/engine/exec/row/RowType.java | 72 -
.../internal/sql/engine/exec/row/TypeSpec.java | 57 -
.../internal/sql/engine/externalize/RelJson.java | 10 +-
.../sql/engine/message/QueryStartRequest.java | 4 +
.../sql/engine/prepare/KeyValueGetPlan.java | 9 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 144 +-
.../sql/engine/prepare/SelectCountPlan.java | 11 +-
.../sql/engine/prepare/bounds/RangeBounds.java | 69 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 16 +-
.../sql/engine/rel/AbstractIgniteJoin.java | 95 +-
.../internal/sql/engine/rel/IgniteProject.java | 12 +-
.../sql/engine/rel/agg/MapReduceAggregates.java | 2 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 11 +-
.../sql/engine/sql/IgniteSqlDropIndex.java | 6 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 83 +-
...Manager.java => PartitionModificationInfo.java} | 22 +-
.../engine/statistic/SqlStatisticManagerImpl.java | 216 +-
.../statistic/SqlStatisticUpdateManager.java | 6 +-
...datesNotifier.java => StatisticAggregator.java} | 8 +-
.../engine/statistic/StatisticAggregatorImpl.java | 247 +
.../StatisticChangedEvent.java} | 15 +-
.../statistic/event/StatisticEventParameters.java} | 18 +-
.../internal/sql/engine/trait/TraitUtils.java | 16 -
.../sql/engine/type/IgniteTypeFactory.java | 28 +-
.../ignite/internal/sql/engine/util/Commons.java | 11 +
.../internal/sql/engine/util/IgniteMethod.java | 6 +
.../ignite/internal/sql/engine/util/RexUtils.java | 132 +-
.../engine/util/SqlExceptionMapperProvider.java | 2 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 132 +-
.../ignite/internal/sql/docs/OperatorListTest.java | 4 +
.../internal/sql/engine/exec/DdlBatchingTest.java | 51 +
.../exec/ExecutableTableRegistrySelfTest.java | 2 -
.../sql/engine/exec/ExecutionServiceImplTest.java | 121 +-
.../exec/IdentityDistributionFunctionSelfTest.java | 8 +-
.../sql/engine/exec/PartitionsResolutionTest.java | 12 +-
.../exec/ProjectedTableRowConverterSelfTest.java | 8 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 3 +-
.../sql/engine/exec/TableRowConverterSelfTest.java | 24 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 3 +-
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 435 ++
.../exec/exp/agg/GroupingAccumulatorTest.java | 8 +-
.../exec/exp/agg/SameBinaryValAccumulatorTest.java | 89 +
.../exec/exp/agg/SameValAccumulatorTest.java | 71 +
.../mapping/ExecutionTargetFactorySelfTest.java | 14 +-
.../exec/mapping/MappingServiceImplTest.java | 92 +-
.../sql/engine/exec/mapping/MappingTestRunner.java | 6 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 3 +-
.../sql/engine/exec/rel/AsyncRootNodeTest.java | 6 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 16 +-
.../rel/CorrelatedNestedLoopJoinExecutionTest.java | 12 +-
.../exec/rel/DataSourceScanNodeExecutionTest.java | 35 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 8 +-
.../exec/rel/HashAggregateExecutionTest.java | 10 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 5 +-
.../exec/rel/IndexScanNodeExecutionTest.java | 12 +-
.../engine/exec/rel/IntersectExecutionTest.java | 22 +-
.../sql/engine/exec/rel/MinusExecutionTest.java | 20 +-
.../engine/exec/rel/ModifyNodeExecutionTest.java | 84 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 13 +-
.../exec/rel/SortAggregateExecutionTest.java | 10 +-
.../exec/rel/TableScanNodeExecutionTest.java | 13 +-
.../sql/engine/exec/row/RowSchemaTest.java | 130 -
.../sql/engine/exec/row/RowSchemaTypesTest.java | 217 -
.../sql/engine/exec/row/SqlRowHandlerTest.java | 100 +-
.../sql/engine/framework/ArrayRowHandler.java | 15 +-
.../sql/engine/framework/NoOpTransaction.java | 13 +-
.../sql/engine/framework/TestBuilders.java | 19 +-
.../internal/sql/engine/framework/TestNode.java | 2 -
.../planner/IdentityDistributionPlannerTest.java | 21 +-
.../engine/planner/JoinColocationPlannerTest.java | 194 +-
.../sql/engine/planner/PlannerTimeoutTest.java | 7 +-
.../planner/TpcdsColocatedQueryPlannerTest.java | 49 -
.../sql/engine/planner/TpcdsQueryPlannerTest.java | 12 +-
.../sql/engine/prepare/PrepareServiceImplTest.java | 31 +-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 48 +-
.../DistributionZoneSqlToCommandConverterTest.java | 9 +-
.../engine/schema/SqlSchemaManagerImplTest.java | 16 +-
.../statistic/SqlStatisticManagerImplTest.java | 246 +-
.../internal/sql/engine/util/CommonsTest.java | 22 +
.../internal/sql/engine/util/QueryCheckerTest.java | 14 +-
.../internal/sql/engine/util/TypeUtilsTest.java | 124 +-
.../sql/metrics/PlanningCacheMetricsTest.java | 7 +-
.../src/test/resources/docs/operator_list.txt | 10 +
.../test/resources/tpcds/plan/q10_colocated.plan | 176 -
.../test/resources/tpcds/plan/q11_colocated.plan | 233 -
.../test/resources/tpcds/plan/q12_colocated.plan | 48 -
.../test/resources/tpcds/plan/q13_colocated.plan | 76 -
.../test/resources/tpcds/plan/q14_colocated.plan | 1433 ------
.../test/resources/tpcds/plan/q15_colocated.plan | 54 -
.../test/resources/tpcds/plan/q16_colocated.plan | 129 -
.../test/resources/tpcds/plan/q18_colocated.plan | 98 -
.../test/resources/tpcds/plan/q19_colocated.plan | 81 -
.../test/resources/tpcds/plan/q1_colocated.plan | 113 -
.../test/resources/tpcds/plan/q20_colocated.plan | 48 -
.../test/resources/tpcds/plan/q21_colocated.plan | 58 -
.../test/resources/tpcds/plan/q22_colocated.plan | 44 -
.../test/resources/tpcds/plan/q23_colocated.plan | 712 ---
.../test/resources/tpcds/plan/q24_colocated.plan | 357 --
.../test/resources/tpcds/plan/q25_colocated.plan | 102 -
.../test/resources/tpcds/plan/q26_colocated.plan | 70 -
.../test/resources/tpcds/plan/q27_colocated.plan | 68 -
.../test/resources/tpcds/plan/q28_colocated.plan | 105 -
.../test/resources/tpcds/plan/q2_colocated.plan | 120 -
.../test/resources/tpcds/plan/q30_colocated.plan | 135 -
.../test/resources/tpcds/plan/q31_colocated.plan | 272 -
.../test/resources/tpcds/plan/q32_colocated.plan | 103 -
.../test/resources/tpcds/plan/q33_colocated.plan | 252 -
.../test/resources/tpcds/plan/q34_colocated.plan | 73 -
.../test/resources/tpcds/plan/q37_colocated.plan | 55 -
.../test/resources/tpcds/plan/q38_colocated.plan | 125 -
.../test/resources/tpcds/plan/q3_colocated.plan | 48 -
.../test/resources/tpcds/plan/q40_colocated.plan | 66 -
.../test/resources/tpcds/plan/q41_colocated.plan | 52 -
.../test/resources/tpcds/plan/q42_colocated.plan | 44 -
.../test/resources/tpcds/plan/q43_colocated.plan | 44 -
.../test/resources/tpcds/plan/q45_colocated.plan | 89 -
.../test/resources/tpcds/plan/q46_colocated.plan | 97 -
.../test/resources/tpcds/plan/q48_colocated.plan | 64 -
.../test/resources/tpcds/plan/q4_colocated.plan | 371 --
.../src/test/resources/tpcds/plan/q5.plan | 9 +-
.../test/resources/tpcds/plan/q50_colocated.plan | 66 -
.../test/resources/tpcds/plan/q51_colocated.plan | 80 -
.../test/resources/tpcds/plan/q52_colocated.plan | 48 -
.../test/resources/tpcds/plan/q53_colocated.plan | 62 -
.../test/resources/tpcds/plan/q54_colocated.plan | 195 -
.../test/resources/tpcds/plan/q55_colocated.plan | 48 -
.../test/resources/tpcds/plan/q56_colocated.plan | 251 -
.../test/resources/tpcds/plan/q58_colocated.plan | 284 --
.../test/resources/tpcds/plan/q59_colocated.plan | 124 -
.../test/resources/tpcds/plan/q5_colocated.plan | 199 -
.../test/resources/tpcds/plan/q60_colocated.plan | 252 -
.../test/resources/tpcds/plan/q61_colocated.plan | 182 -
.../test/resources/tpcds/plan/q62_colocated.plan | 65 -
.../test/resources/tpcds/plan/q63_colocated.plan | 62 -
.../src/test/resources/tpcds/plan/q64.plan | 36 +-
.../test/resources/tpcds/plan/q64_colocated.plan | 478 --
.../test/resources/tpcds/plan/q65_colocated.plan | 100 -
.../test/resources/tpcds/plan/q66_colocated.plan | 152 -
.../test/resources/tpcds/plan/q68_colocated.plan | 97 -
.../test/resources/tpcds/plan/q69_colocated.plan | 185 -
.../test/resources/tpcds/plan/q6_colocated.plan | 134 -
.../test/resources/tpcds/plan/q71_colocated.plan | 110 -
.../test/resources/tpcds/plan/q72_colocated.plan | 144 -
.../test/resources/tpcds/plan/q73_colocated.plan | 73 -
.../test/resources/tpcds/plan/q74_colocated.plan | 233 -
.../test/resources/tpcds/plan/q75_colocated.plan | 309 --
.../test/resources/tpcds/plan/q76_colocated.plan | 119 -
.../test/resources/tpcds/plan/q77_colocated.plan | 255 -
.../test/resources/tpcds/plan/q78_colocated.plan | 152 -
.../test/resources/tpcds/plan/q79_colocated.plan | 75 -
.../test/resources/tpcds/plan/q7_colocated.plan | 70 -
.../test/resources/tpcds/plan/q80_colocated.plan | 251 -
.../test/resources/tpcds/plan/q81_colocated.plan | 135 -
.../test/resources/tpcds/plan/q82_colocated.plan | 55 -
.../test/resources/tpcds/plan/q83_colocated.plan | 297 --
.../test/resources/tpcds/plan/q84_colocated.plan | 78 -
.../test/resources/tpcds/plan/q85_colocated.plan | 109 -
.../test/resources/tpcds/plan/q87_colocated.plan | 122 -
.../test/resources/tpcds/plan/q88_colocated.plan | 416 --
.../test/resources/tpcds/plan/q89_colocated.plan | 70 -
.../test/resources/tpcds/plan/q8_colocated.plan | 120 -
.../test/resources/tpcds/plan/q90_colocated.plan | 116 -
.../test/resources/tpcds/plan/q91_colocated.plan | 99 -
.../test/resources/tpcds/plan/q92_colocated.plan | 104 -
.../test/resources/tpcds/plan/q93_colocated.plan | 43 -
.../test/resources/tpcds/plan/q94_colocated.plan | 129 -
.../test/resources/tpcds/plan/q95_colocated.plan | 151 -
.../test/resources/tpcds/plan/q96_colocated.plan | 56 -
.../test/resources/tpcds/plan/q97_colocated.plan | 71 -
.../test/resources/tpcds/plan/q98_colocated.plan | 47 -
.../test/resources/tpcds/plan/q99_colocated.plan | 65 -
.../test/resources/tpcds/plan/q9_colocated.plan | 489 --
.../src/test/resources/tpch/plan/q1.plan | 2 +-
.../src/test/resources/tpch/plan/q10.plan | 2 +-
.../src/test/resources/tpch/plan/q12.plan | 2 +-
.../src/test/resources/tpch/plan/q13.plan | 46 +-
.../src/test/resources/tpch/plan/q14.plan | 2 +-
.../src/test/resources/tpch/plan/q15.plan | 4 +-
.../src/test/resources/tpch/plan/q3.plan | 4 +-
.../src/test/resources/tpch/plan/q4.plan | 2 +-
.../src/test/resources/tpch/plan/q6.plan | 2 +-
.../src/test/resources/tpch/plan/variant_q12.plan | 2 +-
.../src/test/resources/tpch/plan/variant_q14.plan | 2 +-
.../src/test/resources/tpch/plan/variant_q8.plan | 2 +-
.../internal/sql/BaseSqlIntegrationTest.java | 14 +-
.../internal/sql/engine/util/QueryChecker.java | 3 +-
.../internal/sql/engine/util/QueryCheckerImpl.java | 2 +-
.../internal/sql/engine/util/SqlTestUtils.java | 33 +-
.../internal/storage/MvPartitionStorage.java | 38 +-
.../apache/ignite/internal/storage/ReadResult.java | 31 +-
.../apache/ignite/internal/storage/RowMeta.java | 38 +-
.../storage/ThreadAssertingMvPartitionStorage.java | 16 +-
.../ignite/internal/storage/util/LocalLocker.java | 5 +
.../AbstractMvPartitionStorageConcurrencyTest.java | 12 +-
.../storage/AbstractMvPartitionStorageGcTest.java | 19 +
.../storage/AbstractMvPartitionStorageTest.java | 139 +-
.../storage/AbstractMvTableStorageTest.java | 12 +-
.../storage/BaseMvPartitionStorageTest.java | 5 +-
.../storage/impl/TestMvPartitionStorage.java | 100 +-
modules/storage-page-memory/build.gradle | 1 +
.../pagememory/AbstractPageMemoryTableStorage.java | 33 +-
.../PersistentPageMemoryStorageEngine.java | 5 +-
.../PersistentPageMemoryTableStorage.java | 7 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 7 +-
...emoryStorageEngineLocalConfigurationModule.java | 6 +
.../PageMemoryCheckpointConfigurationSchema.java | 4 -
.../mv/AbstractPageMemoryMvPartitionStorage.java | 51 +-
.../pagememory/mv/AddWriteInvokeClosure.java | 12 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 13 +-
.../storage/pagememory/mv/ScanVersionsCursor.java | 2 +-
.../storage/pagememory/mv/VersionChain.java | 20 +-
.../storage/pagememory/mv/io/VersionChainIo.java | 20 +-
.../pagememory/PersistentPageMemoryNoLoadTest.java | 109 +
...PersistentPageMemoryMvPartitionStorageTest.java | 60 +-
.../storage/rocksdb/PartitionDataHelper.java | 13 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 116 +-
.../internal/systemview/SystemViewManagerTest.java | 2 +-
modules/table/build.gradle | 1 +
.../ItInternalTableReadWriteScanTest.java | 15 +-
.../apache/ignite/distributed/ItLockTableTest.java | 1 +
.../ItTxDistributedCleanupRecoveryTest.java | 1 +
...xDistributedTestSingleNodeNoCleanupMessage.java | 1 +
...ItTxDistributedTestThreeNodesThreeReplicas.java | 5 +-
.../ItTxObservableTimePropagationTest.java | 7 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 5 +
.../ignite/distributed/ReplicaUnavailableTest.java | 2 +-
.../ReplicasSafeTimePropagationTest.java | 8 +-
.../ignite/internal/ItRaftFsyncOptionTest.java | 20 -
.../partition/ItPartitionDestructionTest.java | 147 +-
.../ignite/internal/table/ItColocationTest.java | 21 +-
.../ignite/internal/table/ItCriteriaQueryTest.java | 105 +
.../internal/table/ItOperationRetryTest.java | 10 +-
...titionModificationCounterConfigurationTest.java | 76 +
.../ItPartitionModificationCounterMetricsTest.java | 8 +-
...bstractHighAvailablePartitionsRecoveryTest.java | 97 +-
.../distributed/PartitionModificationCounter.java | 15 +-
.../PartitionModificationCounterFactory.java | 71 +-
.../PartitionReplicatorNodeRecovery.java | 252 -
.../table/distributed/StorageUpdateHandler.java | 10 +-
.../table/distributed/TableAssignmentsService.java | 4 +-
.../internal/table/distributed/TableManager.java | 1377 +----
.../disaster/DisasterRecoveryManager.java | 264 +-
.../DisasterRecoveryRequestForwardException.java | 37 +
.../table/distributed/gc/GcUpdateHandler.java | 16 +-
.../raft/MinimumRequiredTimeCollectorService.java | 1 +
.../snapshot/PartitionMvStorageAccessImpl.java | 5 +
.../raft/snapshot/TablePartitionKey.java | 8 +
.../replicator/PartitionReplicaListener.java | 24 +-
.../distributed/storage/BrokenTxStateStorage.java | 5 -
...GetEstimatedSizeWithLastModifiedTsRequest.java} | 21 +-
...etEstimatedSizeWithLastModifiedTsResponse.java} | 20 +-
.../PartitionModificationInfoMessage.java} | 24 +-
.../internal/table/message/TableMessageGroup.java} | 31 +-
.../ignite/internal/utils/RebalanceUtilEx.java | 198 -
.../PartitionModificationCounterTest.java | 12 +-
.../table/distributed/StorageCleanupTest.java | 9 +-
.../distributed/TableManagerRecoveryTest.java | 161 +-
.../table/distributed/TableManagerTest.java | 284 +-
.../disaster/DisasterRecoveryMsInvokeTest.java | 25 +-
.../gc/AbstractGcUpdateHandlerTest.java | 68 +
.../raft/PartitionCommandListenerTest.java | 39 +-
.../raft/RaftGroupConfigurationConverterTest.java | 2 +
.../PartitionReplicaListenerIndexLockingTest.java | 24 +-
...itionReplicaListenerSortedIndexLockingTest.java | 24 +-
.../replication/PartitionReplicaListenerTest.java | 892 +---
.../ZonePartitionReplicaListenerTest.java | 154 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 18 +-
.../ignite/internal/table/TableTestUtils.java | 9 +-
.../internal/table/TxInfrastructureTest.java | 5 +
.../table/impl/DummyInternalTableImpl.java | 2 +
modules/transactions/build.gradle | 1 +
.../disaster/DisasterRecoveryTestUtil.java | 17 +-
.../disaster/ItDisasterRecoveryManagerTest.java | 431 +-
.../ItDisasterRecoveryReconfigurationTest.java | 226 +-
.../ItDisasterRecoveryResetPartitionsTest.java | 19 +-
.../ignite/internal/tx/ItTxTimeoutOneNodeTest.java | 16 -
.../tx/readonly/ItReadOnlyTxInPastTest.java | 2 +-
.../tx/distributed/ItTxResourcesVacuumTest.java | 15 +-
.../org/apache/ignite/internal/tx/TxManager.java | 4 +-
.../internal/tx/impl/EnlistedPartitionGroup.java | 2 +
.../internal/tx/impl/ReadWriteTransactionImpl.java | 3 +
.../internal/tx/impl/TxCleanupRequestSender.java | 25 +-
.../state/ThreadAssertingTxStateStorage.java | 7 -
.../internal/tx/storage/state/TxStateStorage.java | 8 -
.../state/rocksdb/TxStateRocksDbStorage.java | 11 +-
.../internal/tx/TxManagerColocationTest.java | 32 -
.../apache/ignite/internal/tx/TxManagerTest.java | 26 +-
.../ReadWriteTransactionImplColocationTest.java | 32 -
.../tx/impl/ReadWriteTransactionImplTest.java | 25 +-
.../rocksdb/TxStateRocksDbSharedStorageTest.java | 2 +-
.../storage/state/AbstractTxStateStorageTest.java | 9 +-
.../tx/storage/state/test/TestTxStateStorage.java | 7 +-
.../internal/tx/test/ItTransactionTestUtils.java | 8 +-
settings.gradle | 2 +
976 files changed, 36828 insertions(+), 31371 deletions(-)
rename .run/{All checkstyle [checkstyleMain checkstyleIntegrationTest
checkstyleTest checkstyleTestFixtures].run.xml => All checkstyle
[checkstyle].run.xml} (95%)
rename .run/{Spotbugs check [spotbugsMain].run.xml => PMD [pmd].run.xml} (88%)
rename .run/{PMD [pmdMain pmdTest].run.xml => Spotbugs check
[spotbugs].run.xml} (88%)
create mode 100644
docs/_docs/administrators-guide/storage/distribution-zones.adoc
delete mode 100644 docs/_docs/developers-guide/sql/jdbc-driver.adoc
create mode 100644 examples/sql/ddl_examples.sql
create mode 100644 examples/sql/distribution-zones.sql
create mode 100644 examples/sql/world.sql
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/cluster/init/ItClusterInitOneNodeTest.java
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/cluster/{unit/DeployUnitCallFactory.java
=> ClusterInitCallFactory.java} (66%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionKey.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/cluster/init/ClusterInitConstants.java}
(76%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/statistic/StatisticUpdatesNotifier.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/core/call/AsyncCallFactory.java}
(76%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/NullTypeSpec.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/core/call/SpinnerRenderer.java}
(54%)
copy
modules/cli/src/{main/java/org/apache/ignite/internal/cli/call/cluster/unit/DeployUnitCallFactory.java
=>
test/java/org/apache/ignite/internal/cli/core/call/SpinnerRendererTest.java}
(53%)
copy
modules/{raft/src/main/java/org/apache/ignite/raft/jraft/entity/codec/DefaultLogEntryCodecFactory.java
=>
client-common/src/main/java/org/apache/ignite/internal/client/proto/tx/ClientInternalTxOptions.java}
(51%)
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/internal/client/sql/QueryModifier.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/internal/jdbc/proto/JdbcDatabaseMetadataHandler.java
delete mode 100644
modules/client-common/src/main/java/org/apache/ignite/internal/jdbc/proto/JdbcQueryEventHandler.java
create mode 100644
modules/client-common/src/test/java/org/apache/ignite/internal/client/proto/sql/QueryModifierTest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCursorNextResultRequest.java
create mode 100644
modules/client-handler/src/test/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCommonTest.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/ChannelValidator.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientTableMapUtils.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/MappingService.java
=>
client/src/main/java/org/apache/ignite/internal/client/table/MapFunction.java}
(62%)
copy
modules/cluster-management/src/{main/java/org/apache/ignite/internal/cluster/management/network/messages/CmgInitMessage.java
=>
test/java/org/apache/ignite/internal/cluster/management/network/messages/CmgInitMessageTest.java}
(50%)
create mode 100644
modules/compatibility-tests/src/integrationTest/java/org/apache/ignite/internal/ItCmgRaftLogCompatibilityTest.java
create mode 100644
modules/compatibility-tests/src/integrationTest/java/org/apache/ignite/internal/WriteIntentStorageCompatibilityTest.java
create mode 100644
modules/compatibility-tests/src/integrationTest/java/org/apache/ignite/internal/client/JdbcOverThinSqlWithOldServerCompatibilityTest.java
copy
modules/{client/src/main/java/org/apache/ignite/internal/client/WriteContext.java
=>
compatibility-tests/src/jobs/java/org/apache/ignite/internal/compute/DisableWriteIntentSwitchExecutionJob.java}
(56%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/type/StructNativeType.java
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionKey.java
=> core/src/main/java/org/apache/ignite/internal/util/IgniteBusyLock.java}
(70%)
delete mode 100644
modules/distribution-zones/src/integrationTest/java/org/apache/ignite/internal/TestRebalanceUtil.java
delete mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/DistributionZoneRebalanceEngine.java
delete mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/PartitionMover.java
delete mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/RebalanceRaftGroupEventsListener.java
create mode 100644
modules/distribution-zones/src/testFixtures/java/org/apache/ignite/internal/distributionzones/DataNodesTestUtil.java
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionKey.java
=> error-code-api/build.gradle} (82%)
rename modules/{error-code-annotation-processor =>
error-code-api}/src/main/java/org/apache/ignite/error/code/annotations/ErrorCodeGroup.java
(78%)
create mode 100644
modules/index/src/integrationTest/java/org/apache/ignite/internal/index/ItBuildIndexWriteIntentsHandlingTest.java
copy
modules/{cli/src/test/java/org/apache/ignite/internal/cli/commands/cluster/ClusterInitReplTest.java
=>
index/src/integrationTest/java/org/apache/ignite/internal/index/WriteIntentSwitchControl.java}
(60%)
create mode 100644
modules/index/src/main/java/org/apache/ignite/internal/index/IndexBuildTaskStatisticsLoggingListener.java
create mode 100644
modules/index/src/test/java/org/apache/ignite/internal/index/IndexBuildTaskStatisticsLoggingListenerTest.java
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/internal/jdbc/ItJdbcClusterPerIntegrationTest.java
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/internal/jdbc/ItJdbcParameterMetadataSelfTest.java
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/internal/jdbc/ItJdbcResultSetMetadataSelfTest.java
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/jdbc/ItJdbcConnectionFailoverTest.java
copy
modules/{core/src/main/java/org/apache/ignite/internal/components/SystemPropertiesNodeProperties.java
=>
jdbc/src/integrationTest/java/org/apache/ignite/jdbc/ItJdbcWithC3p0PoolTest.java}
(63%)
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/jdbc/ItJdbcWithConnectionPoolBaseTest.java
copy
modules/{core/src/main/java/org/apache/ignite/internal/components/SystemPropertiesNodeProperties.java
=>
jdbc/src/integrationTest/java/org/apache/ignite/jdbc/ItJdbcWithHikariPoolTest.java}
(62%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/components/SystemPropertiesNodeProperties.java
=>
jdbc/src/main/java/org/apache/ignite/internal/jdbc/ClientSyncResultSet.java}
(58%)
create mode 100644
modules/jdbc/src/main/java/org/apache/ignite/internal/jdbc/ClientSyncResultSetImpl.java
create mode 100644
modules/jdbc/src/main/java/org/apache/ignite/internal/jdbc/JdbcClientDatabaseMetadataHandler.java
delete mode 100644
modules/jdbc/src/main/java/org/apache/ignite/internal/jdbc/JdbcClientQueryCursorHandler.java
delete mode 100644
modules/jdbc/src/main/java/org/apache/ignite/internal/jdbc/JdbcClientQueryEventHandler.java
create mode 100644
modules/jdbc/src/main/java/org/apache/ignite/internal/jdbc/JdbcExceptionMapperUtil.java
delete mode 100644
modules/jdbc/src/main/java/org/apache/ignite/internal/jdbc/JdbcQueryExecuteResponse.java
create mode 100644
modules/jdbc/src/main/java/org/apache/ignite/internal/jdbc/JdbcUtils.java
create mode 100644
modules/jdbc/src/main/java/org/apache/ignite/internal/jdbc/ResultSetWrapper.java
create mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/ColumnDefinition.java
create mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcConnectionSelfTest.java
create mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcDatabaseMetadataSelfTest.java
create mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcPreparedStatementSelfTest.java
create mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcResultSetBaseSelfTest.java
create mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcResultSetMetadataBaseSelfTest.java
create mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcResultSetMetadataSelfTest.java
create mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcResultSetSelfTest.java
delete mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcResultSetTest.java
create mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcStatementSelfTest.java
delete mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/PreparedStatementParamsTest.java
copy
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/{replication/ChangePeersAndLearnersAsyncReplicaRequest.java
=> disaster/DisasterRecoveryRequestMessage.java} (64%)
copy
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/{replication/ChangePeersAndLearnersAsyncReplicaRequest.java
=> disaster/DisasterRecoveryResponseMessage.java} (65%)
copy
modules/{index/src/main/java/org/apache/ignite/internal/index/FinalTransactionStateResolver.java
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/LogStorageAccess.java}
(51%)
rename
modules/{table/src/integrationTest/java/org/apache/ignite/distributed/ItInternalTableReadWriteScanColocationTest.java
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/LogStorageAccessImpl.java}
(50%)
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/incoming/ReplicationLogStorageKey.java
copy
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed/TableManagerWithColocationTest.java
=> platforms/cpp/ignite/common/detail/duration_min_max.h} (65%)
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/call/cluster/unit/DeployUnitCallFactory.java
=> platforms/cpp/ignite/protocol/heartbeat_timeout.h} (57%)
create mode 100644 modules/platforms/cpp/tests/test-common/hidden_param.h
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Compute/Executor/NewerDotnetJobs/EchoJob.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Compute/Executor/NewerDotnetJobs/NewerDotnetJobs.csproj
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Compute/Executor/NewerDotnetJobs/NewerDotnetJobs.dll
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Compute/Executor/NewerDotnetJobs/global.json
create mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/ChangePeersAndLearnersWithRetry.java
copy
modules/{index/src/main/java/org/apache/ignite/internal/index/FinalTransactionStateResolver.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/ExceptionUtils.java}
(53%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/statistic/StatisticUpdatesNotifier.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/RaftCommand.java}
(73%)
create mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/RaftCommandWithRetry.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/DdlBatchGroup.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/RaftStaleUpdateException.java}
(68%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/entity/codec/v2/LogEntryV2CodecFactory.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/entity/codec/v2/V2Decoder.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/entity/codec/v2/V2Encoder.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/util/CompatibleJDKMarshaller.java
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed/PartitionMoverTest.java
=>
raft/src/test/java/org/apache/ignite/internal/raft/rebalance/ChangePeersAndLearnersWithRetryTest.java}
(68%)
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/entity/codec/BackwardCompatibilityTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/raft/jraft/entity/codec/v2/V2EncoderTest.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/MappingService.java
=>
replicator/src/main/java/org/apache/ignite/internal/replicator/VersionedAssignments.java}
(58%)
create mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/zone/DataNodesApi.java
create mode 100644
modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/cluster/ItDataNodesControllerTest.java
delete mode 100644
modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/recovery/ItDisasterRecoveryColocationDisabledTest.java
create mode 100644
modules/rest/src/main/java/org/apache/ignite/internal/rest/cluster/DataNodesRestFactory.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/statistic/StatisticUpdatesNotifier.java
=>
rest/src/main/java/org/apache/ignite/internal/rest/cluster/JoinFutureProvider.java}
(75%)
create mode 100644
modules/rest/src/main/java/org/apache/ignite/internal/rest/zone/DataNodesController.java
copy
modules/{client/src/main/java/org/apache/ignite/internal/client/WriteContext.java
=>
runner/src/integrationTest/java/org/apache/ignite/internal/client/ItClientDataConsistencyTest.java}
(58%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientChannelValidatorTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientMultistatementSqlTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItDataConsistencyTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItDurabilityTest.java
delete mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/app/SameValueLongSupplier.java
delete mode 100644
modules/runner/src/test/java/org/apache/ignite/internal/app/SameValueLongSupplierTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItPrefixLikeToRangeScanConversionTest.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/configuration/distributed/{SqlDistributedConfigurationSchema.java
=> CreateTableDefaultsConfigurationSchema.java} (51%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/CursorPublicationPhaseHandler.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{row/NullTypeSpec.java
=> mapping/MappedFragments.java} (57%)
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/BaseTypeSpec.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/RowSchema.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/RowSchemaTypes.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/RowType.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/TypeSpec.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/statistic/{SqlStatisticUpdateManager.java
=> PartitionModificationInfo.java} (57%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/statistic/{StatisticUpdatesNotifier.java
=> StatisticAggregator.java} (84%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/statistic/StatisticAggregatorImpl.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/statistic/{StatisticUpdatesNotifier.java
=> event/StatisticChangedEvent.java} (74%)
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed/TableManagerWithColocationTest.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/statistic/event/StatisticEventParameters.java}
(66%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/SameBinaryValAccumulatorTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/SameValAccumulatorTest.java
delete mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/row/RowSchemaTest.java
delete mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/row/RowSchemaTypesTest.java
delete mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/TpcdsColocatedQueryPlannerTest.java
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q10_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q11_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q12_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q13_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q14_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q15_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q16_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q18_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q19_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q1_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q20_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q21_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q22_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q23_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q24_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q25_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q26_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q27_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q28_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q2_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q30_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q31_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q32_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q33_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q34_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q37_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q38_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q3_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q40_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q41_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q42_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q43_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q45_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q46_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q48_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q4_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q50_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q51_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q52_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q53_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q54_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q55_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q56_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q58_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q59_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q5_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q60_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q61_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q62_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q63_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q64_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q65_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q66_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q68_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q69_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q6_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q71_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q72_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q73_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q74_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q75_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q76_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q77_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q78_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q79_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q7_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q80_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q81_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q82_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q83_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q84_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q85_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q87_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q88_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q89_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q8_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q90_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q91_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q92_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q93_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q94_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q95_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q96_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q97_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q98_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q99_colocated.plan
delete mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q9_colocated.plan
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItPartitionModificationCounterConfigurationTest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/DisasterRecoveryRequestForwardException.java
copy modules/{error-code-annotation-processor/build.gradle =>
table/src/main/java/org/apache/ignite/internal/table/message/GetEstimatedSizeWithLastModifiedTsRequest.java}
(59%)
copy modules/{error-code-annotation-processor/build.gradle =>
table/src/main/java/org/apache/ignite/internal/table/message/GetEstimatedSizeWithLastModifiedTsResponse.java}
(61%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/{distributed/disaster/exceptions/ZonesNotFoundException.java
=> message/PartitionModificationInfoMessage.java} (57%)
copy
modules/{client/src/main/java/org/apache/ignite/internal/client/WriteContext.java
=>
table/src/main/java/org/apache/ignite/internal/table/message/TableMessageGroup.java}
(51%)
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/utils/RebalanceUtilEx.java
delete mode 100644
modules/transactions/src/test/java/org/apache/ignite/internal/tx/TxManagerColocationTest.java
delete mode 100644
modules/transactions/src/test/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImplColocationTest.java
