This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/io.freefair.aggregate-javadoc-9.1.0
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 87ffb034775 Bump io.freefair.aggregate-javadoc from 6.6.3 to 9.1.0
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 8bac9638589 IGNITE-27136 C++ 3.0: Fix memory leak in the
ignite-odbc-test (#7096)
add f7b3d7827c3 IGNITE-27204 Log stale node handshake failure on debug
(#7110)
add 372b1ba8428 IGNITE-27202 Fix an issue a wrong commit partition ID for
directly mapped transactions. (#7105)
add 4fc0a3a3723 IGNITE-27176 .NET: Document
IgniteServiceCollectionExtensions (#7082)
add e86c12a33f5 IGNITE-27009 Introduce secondary indexes build metrics
(#7086)
add 9050a172731 IGNITE-27015 Sql. Introduced virtual column __PARTITION_ID
(#7111)
add 3fa0c97f524 IGNITE-27208 Prepare RowVersion read/write code to
addition of new versions (#7112)
add 219b0f5ee53 IGNITE-27134 Jdbc. Added backgroundReconnectInterval
property to connection configuration (#7093)
add 3ac90222b76 IGNITE-27215 Fix Critical system error caused by
HandshakeException on cluster stop (#7117)
add 3d7d56ae8c3 IGNITE-27096 Fix illegal reflective access in CLI (#7097)
add c22fae1e682 IGNITE-27211 CLI highlighting doesn't work on Alpine Linux
(#7113)
add 61bd024a505 IGNITE-27219 .NET: Improve observableTs logging (#7121)
add f88dc85fa55 IGNITE-26834 Fix ignite.version.full set in case of local
build (#6974)
add 94e1adec5f5 IGNITE-26811 Do not throw HandshakeException when node is
stopping (#7116)
add cce2ace2b19 IGNITE-27220 Store first and last log indices in memory
(#7123)
add de56335f7be IGNITE-27228 Refactor TcpIgniteClient (#7129)
add 02bec3d4507 IGNITE-27189 Remove non-colocated code from
PartitionReplicaListener (#7106)
add 216159e0b38 IGNITE-27117 Sql. Don't abort execution of previous
statements when an error occurs in a multi-statement query (#7099)
add 2699a72bcbe IGNITE-27089 Fix handling for delayed ack failures
add 955e835503e IGNITE-27198 Optimize hash index lookup (#7092)
add 7ef48f0fa87 IGNITE-27192 Optimize catalog access in CatalogManager
(#7089)
add 33cbfd6e203 IGNITE-26951 .NET: Fix flaky
CurrentClientWithOldServerCompatibilityTest (#7131)
add 2c829425297 IGNITE-27227 Ensure all entries in AttributeList are
Attributes (#7130)
add 0449ef85000 IGNITE-27199 Support patch versions for deployments (#7104)
add c32f509ec6e IGNITE-26983 Enrich possible deadlock log message with
extra information (#7107)
add 20bf34da4fe IGNITE-26998 Warmup gc entries before `runConsistently`
(#7109)
add da06a26b5fa IGNITE-27231 Improve marshaller error messages (#7135)
add b210c57e6c7 IGNITE-27230 .NET: Improve server-side exception
representation (#7132)
add ebc3de2a4ea IGNITE-27079 Use "stop" hint in
StorageUpdateHandler#handleUpdateAll (#7095)
add 3d7949b6a3d [IGNITE-26459] Add ability to explicitly trigger dataNodes
recalculation via CLI command (#7120)
add 7f981bd304c IGNITE-27217 Reduce log severity for primary replica
change in ClientInboundMessageHandler (#7142)
add 3d59b7138bc IGNITE-27244 Fix examples/java/README.md (#7144)
add b6b188f4109 IGNITE-18922 Thin 3.0: Avoid BinaryTuple conversion in
client SQL handler (#7143)
add 0e49fb951ef IGNITE-27087 Update placement driver metrics list (#7000)
add 8ff5992ea52 IGNITE-27241 Add data staleness check to the statistic
manager (#7141)
add f21c525ef15 IGNITE-27249 Use shared ScheduledThreadPoolExecutor for
ReplicaManager in ItTxTestCluster (#7147)
add c0917543680 IGNITE-27248 Rename recalculate -> reset (#7146)
add ce064598700 IGNITE-27002 Add labels to transactions (#7088)
add 933ff524e96 IGNITE-27237 Mute Critical system error on Unable to start
rebalance (#7138)
add 1b6b83da5fe IGNITE-27252 Update timeouts in
TestScaleCubeClusterServiceFactory (#7149)
add 5f71a2938de IGNITE-27205 ODBC: Fix heap-use-after-free in tests (#7114)
add a38f7d124e6 IGNITE-26481 TeamCity: Fix ODBC driver load error (#7004)
add 25297f112e6 Bump Microsoft.CodeAnalysis.CSharp from 4.13.0 to 5.0.0
(#7127)
add a083f463048 Bump BenchmarkDotNet from 0.15.6 to 0.15.8 (#7124)
add 6e5a99bcfa3 Bump io.freefair.aggregate-javadoc from 6.6.3 to 9.1.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 (87ffb034775)
\
N -- N -- N
refs/heads/dependabot/gradle/io.freefair.aggregate-javadoc-9.1.0 (6e5a99bcfa3)
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 +
.teamcity/build/distributions/OdbcDeb.kt | 36 +-
.teamcity/build/distributions/OdbcRpm.kt | 44 +-
.teamcity/build/distributions/OdbcZip.kt | 48 +-
.teamcity/test/build_types/RunAllTests.kt | 1 -
.teamcity/test/build_types/RunAllTestsCustomJDK.kt | 1 -
.teamcity/test/template_types/OtherTestsModule.kt | 3 +-
.teamcity/test/template_types/TestsModule.kt | 3 +-
buildscripts/generate-version-file.gradle | 23 +-
docs/_data/toc.yaml | 2 -
.../config/cluster-config.adoc | 6 +
.../administrators-guide/metrics/metrics-list.adoc | 25 +-
docs/_docs/developers-guide/clients/dotnet.adoc | 25 +-
.../developers-guide/clients/jdbc-driver.adoc | 31 +-
docs/_docs/developers-guide/sql/jdbc-driver.adoc | 108 -
docs/_docs/developers-guide/sql/sql-api.adoc | 6 +-
docs/_docs/sql-tuning/sql-tuning.adoc | 26 +
examples/java/README.md | 93 +-
examples/sql/ddl_examples.sql | 230 +
examples/sql/distribution-zones.sql | 77 +
examples/sql/world.sql | 5355 ++++++++++++++++++++
gradle/libs.versions.toml | 9 +-
modules/api/build.gradle | 2 +-
.../ignite/deployment/version/UnitVersion.java | 150 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 6 +
.../java/org/apache/ignite/sql/ColumnType.java | 5 +-
.../ignite/deployment/version/VersionTest.java | 52 +-
.../ignite/table/AbstractImmutableTupleTest.java | 2 +-
.../compaction/CatalogCompactionRunner.java | 27 +-
.../compaction/CatalogManagerCompactionFacade.java | 36 +-
.../CatalogCompactionRunnerSelfTest.java | 14 +-
.../CatalogManagerCompactionFacadeTest.java | 82 +-
.../ignite/internal/catalog/CatalogByIndexMap.java | 158 +
.../internal/catalog/CatalogManagerImpl.java | 68 +-
.../ignite/internal/catalog/CatalogService.java | 14 +-
.../internal/catalog/CatalogByIndexMapTest.java | 109 +
.../ignite/internal/cli/CliIntegrationTest.java | 3 +-
.../cli/call/metric/ItEnabledMetricCallsTest.java | 3 +-
.../cluster/init/ItClusterInitOneNodeTest.java | 66 +
.../partitions/states/ItPartitionStatesTest.java | 15 +-
.../cli/commands/sql/ItSqlCommandTest.java | 5 +-
.../cli/commands/sql/ItSqlReplCommandTest.java | 2 +-
.../commands/unit/ItDeploymentUnitReplTest.java} | 17 +-
.../cli/commands/unit/ItDeploymentUnitTest.java | 25 +-
.../datanodes/ItResetDataNodesCommandTest.java} | 13 +-
.../ItResetDataNodesReplCommandTest.java} | 13 +-
.../zone/datanodes/ItResetDataNodesTest.java | 87 +
.../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 +-
.../zone/ResetDataNodesCall.java} | 43 +-
.../management/zone/ResetDataNodesCallInput.java | 56 +
.../ignite/internal/cli/commands/FormatMixin.java | 4 +-
.../ignite/internal/cli/commands/Options.java | 5 +
.../internal/cli/commands/TopLevelCliCommand.java | 2 +
.../cli/commands/TopLevelCliReplCommand.java | 2 +
.../commands/cluster/init/ClusterInitCommand.java | 14 +-
.../cluster/init/ClusterInitConstants.java} | 10 +-
.../cluster/init/ClusterInitReplCommand.java | 33 +-
.../cluster/unit/ClusterUnitDeployCommand.java | 5 +-
.../cli/commands/sql/SqlExecReplCommand.java | 4 +-
.../cli/commands/treesitter/parser/Parser.java | 18 +
.../internal/cli/commands/zone/ZoneCommand.java} | 18 +-
.../cli/commands/zone/ZoneReplCommand.java} | 18 +-
.../commands/zone/datanodes/DataNodesCommand.java} | 17 +-
.../zone/datanodes/DataNodesReplCommand.java} | 17 +-
.../datanodes/ResetDataNodesCommand.java} | 24 +-
.../zone/datanodes/ResetDataNodesMixin.java} | 30 +-
.../datanodes/ResetDataNodesReplCommand.java} | 40 +-
.../cli/core/call/AsyncCallExecutionPipeline.java | 8 +-
.../call/AsyncCallExecutionPipelineBuilder.java | 31 +-
.../internal/cli/core/call/AsyncCallFactory.java} | 12 +-
.../cli/core/call/CallExecutionPipeline.java | 6 +-
.../internal/cli/core/call/SpinnerRenderer.java} | 36 +-
.../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 +-
.../client/proto/ClientBinaryTupleUtils.java | 5 +-
.../ignite/internal/client/proto/ClientOp.java | 5 +
.../internal/client/proto/ErrorExtensions.java | 2 +
.../client/proto/ProtocolBitmaskFeature.java | 12 +-
.../client/proto/tx/ClientInternalTxOptions.java} | 38 +-
.../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 | 25 +-
.../client/handler/ClientResourceRegistry.java | 6 +
.../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 | 221 +-
.../sql/ClientSqlCursorNextResultRequest.java | 87 +
.../requests/sql/ClientSqlExecuteBatchRequest.java | 16 +-
.../requests/sql/ClientSqlExecuteRequest.java | 163 +-
.../sql/ClientSqlExecuteScriptRequest.java | 2 +-
.../handler/requests/sql/ClientSqlProperties.java | 15 +-
.../sql/ClientSqlQueryMetadataRequest.java | 8 +-
.../handler/requests/table/ClientTableCommon.java | 187 +-
.../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 | 56 +-
.../table/ClientTupleUpsertAllRequest.java | 5 +-
.../requests/table/ClientTupleUpsertRequest.java | 5 +-
.../requests/table/ClientTuplesRequestBase.java | 29 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 3 +-
.../handler/requests/sql/ClientSqlCommonTest.java | 92 +
.../requests/table/ClientHandlerTupleTests.java | 6 +-
.../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 +
.../internal/client/ClientDelayedAckException.java | 58 +
.../apache/ignite/internal/client/ClientUtils.java | 3 +
.../ignite/internal/client/ProtocolContext.java | 18 +-
.../ignite/internal/client/ReliableChannel.java | 17 +-
.../ignite/internal/client/TcpClientChannel.java | 63 +-
.../ignite/internal/client/TcpIgniteClient.java | 25 +-
.../ignite/internal/client/WriteContext.java | 4 +-
.../internal/client/compute/ClientCompute.java | 3 +-
.../internal/client/sql/ClientAsyncResultSet.java | 68 +-
.../ignite/internal/client/sql/ClientSql.java | 49 +-
.../client/table/ClientKeyValueBinaryView.java | 53 +-
.../internal/client/table/ClientKeyValueView.java | 51 +-
.../client/table/ClientRecordBinaryView.java | 59 +-
.../internal/client/table/ClientRecordView.java | 59 +-
.../ignite/internal/client/table/ClientTable.java | 124 +-
.../internal/client/table/ClientTableMapUtils.java | 170 +
.../client/table/ClientTupleSerializer.java | 23 +-
.../ignite/internal/client/table/MapFunction.java} | 22 +-
.../internal/client/tx/ClientLazyTransaction.java | 26 +-
.../internal/client/tx/ClientTransaction.java | 25 +-
.../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 +-
.../ignite/client/TestClientHandlerModule.java | 1 +
.../org/apache/ignite/client/fakes/FakeCursor.java | 8 +
.../apache/ignite/client/fakes/FakeTxManager.java | 18 +-
.../RepeatedFinishClientTransactionTest.java | 5 +-
.../cluster/management/ItClusterManagerTest.java | 28 +-
.../cluster/management/ClusterInitializer.java | 9 +-
.../management/ClusterManagementGroupManager.java | 19 +-
.../cluster/management/ClusterInitializerTest.java | 4 +-
.../management/BaseItClusterManagementTest.java | 20 +
.../internal/cluster/management/MockNode.java | 38 +-
modules/compatibility-tests/build.gradle | 1 +
modules/compatibility-tests/jobs.gradle | 2 +
.../ItCmgRaftSnapshotCompatibilityTest.java | 37 +-
...ItMetastorageRaftSnapshotCompatibilityTest.java | 3 +-
.../internal/PersistentCompatibilityTest.java | 34 +-
.../WriteIntentStorageCompatibilityTest.java | 69 +
...cOverThinSqlWithOldServerCompatibilityTest.java | 82 +
.../DisableWriteIntentSwitchExecutionJob.java} | 27 +-
.../ignite/internal/CompatibilityTestBase.java | 20 +-
.../org/apache/ignite/internal/IgniteCluster.java | 10 +-
.../ignite/internal/jobs/DeploymentUtils.java | 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 -
.../compute/loader/JobClassLoaderFactoryTest.java | 2 +-
.../internal/causality/BaseVersionedValue.java | 25 +-
.../causality/CompletableVersionedValue.java | 15 +-
.../internal/causality/CompletionListener.java | 4 +-
.../causality/IncrementalVersionedValue.java | 6 +-
.../components/SystemPropertiesNodeProperties.java | 1 +
.../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 | 43 +-
.../properties/IgniteProductVersionTest.java | 101 +-
.../ignite/internal/util/ExceptionUtilsTest.java | 19 +
.../matchers/CompletableFutureMatcher.java | 2 +-
modules/distribution-zones/build.gradle | 3 +
.../apache/ignite/internal/TestRebalanceUtil.java | 195 -
.../distributionzones/ItDataNodesManagerTest.java | 87 +-
...tDistributionZoneMetaStorageCompactionTest.java | 13 +-
.../ItDistributionZonesFiltersTest.java | 39 +-
.../ItRebalanceByPendingAssignmentsQueueTest.java | 146 +-
.../rebalance/ItRebalanceDistributedTest.java | 157 +-
.../ignite/internal/rebalance/ItRebalanceTest.java | 10 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 15 +-
.../ignite/internal/table/ItEstimatedSizeTest.java | 31 +-
.../distributionzones/DataNodesManager.java | 46 +-
.../distributionzones/DistributionZoneManager.java | 69 +-
.../distributionzones/DistributionZonesUtil.java | 40 +
.../DistributionZoneNotFoundException.java | 10 +
.../rebalance/DistributionZoneRebalanceEngine.java | 179 +-
.../DistributionZoneRebalanceEngineV2.java | 301 --
.../rebalance/PartitionMover.java | 120 -
.../RebalanceRaftGroupEventsListener.java | 702 ---
.../distributionzones/rebalance/RebalanceUtil.java | 11 -
.../ZoneRebalanceRaftGroupEventsListener.java | 61 +-
.../rebalance/ZoneRebalanceUtil.java | 50 +-
.../distributionzones/DataNodesManagerTest.java | 87 +-
.../DistributionZoneRebalanceEngineTest.java | 60 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 55 +-
.../distributionzones/DataNodesTestUtil.java | 267 +
.../DistributionZonesTestUtil.java | 52 +-
.../error-code-annotation-processor/build.gradle | 1 +
.../build.gradle} | 10 +-
.../error/code/annotations/ErrorCodeGroup.java | 5 +-
.../ignite/internal/failure/FailureManager.java | 4 +-
modules/index/build.gradle | 1 +
.../ignite/internal/index/ItBuildIndexTest.java | 14 +-
.../ItBuildIndexWriteIntentsHandlingTest.java | 2 -
.../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 | 106 +-
.../IndexBuildTaskStatisticsLoggingListener.java | 148 +
.../apache/ignite/internal/index/IndexBuilder.java | 46 +-
.../internal/index/IndexBuilderMetricSource.java | 124 +
.../internal/index/IndexBuildingManager.java | 15 +-
.../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 +
.../internal/index/IndexBuilderMetricsTest.java | 145 +
.../ignite/internal/index/IndexBuilderTest.java | 12 +-
.../internal/index/IndexManagementUtilsTest.java | 9 +-
.../internal/index/TestIndexManagementUtils.java | 4 +-
modules/jdbc/build.gradle | 3 +
.../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 | 262 +
.../ignite/jdbc/ItJdbcConnectionSelfTest.java | 147 +-
.../ignite/jdbc/ItJdbcErrorsAbstractSelfTest.java | 11 +-
.../apache/ignite/jdbc/ItJdbcErrorsSelfTest.java | 1 -
.../apache/ignite/jdbc/ItJdbcJoinsSelfTest.java | 7 +-
.../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} | 33 +-
.../internal/jdbc/ClientSyncResultSetImpl.java | 84 +
.../ignite/internal/jdbc/ConnectionProperties.java | 16 +
.../internal/jdbc/ConnectionPropertiesImpl.java | 25 +-
.../jdbc/JdbcClientDatabaseMetadataHandler.java | 96 +
.../jdbc/JdbcClientQueryCursorHandler.java | 81 -
.../internal/jdbc/JdbcClientQueryEventHandler.java | 200 -
.../ignite/internal/jdbc/JdbcConnection.java | 630 +--
.../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 | 123 +-
.../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 --
.../internal/marshaller/ValidationUtils.java | 3 +-
.../internal/marshaller/FieldAccessorTest.java | 4 +-
.../impl/ItIdempotentCommandCacheTest.java | 25 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 4 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 4 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 2 +-
.../impl/StandaloneMetaStorageManager.java | 16 +
.../metrics/exporters/jmx/MetricSetMbean.java | 7 +-
.../network/scalecube/ItNodeRestartsTest.java | 85 +-
.../internal/network/DefaultMessagingService.java | 32 +-
.../RecoveryInitiatorHandshakeManager.java | 7 +-
.../TestScaleCubeClusterServiceFactory.java | 5 +-
.../pagememory/datapage/PageMemoryTraversal.java | 3 +-
.../datapage/ReadPageMemoryRowValue.java | 27 +-
.../internal/pagememory/freelist/FreeListImpl.java | 3 +-
.../ignite/internal/pagememory/io/DataPageIo.java | 3 +-
.../pagememory/persistence/PageHeader.java | 38 +-
.../persistence/PersistentPageMemory.java | 109 +-
.../compaction/CompactionMetricsTracker.java | 23 +
.../persistence/compaction/Compactor.java | 44 +-
.../persistence/store/FilePageStore.java | 17 +
.../persistence/compaction/CompactorTest.java | 108 +-
.../persistence/store/FilePageStoreTest.java | 10 +
.../persistence/throttling/ThrottlingTest.java | 11 +-
.../replicator/ItReplicaLifecycleTest.java | 12 -
.../partition/replicator/ItZoneTxFinishTest.java | 2 +-
.../partition/replicator/fixtures/Node.java | 12 +-
.../ItZonePartitionRaftListenerRecoveryTest.java | 8 +-
.../PartitionReplicaLifecycleManager.java | 227 +-
.../replicator/ReplicaTxFinishMarker.java | 16 +-
.../TableAwareReplicaRequestPreProcessor.java | 62 +-
.../replicator/ZonePartitionReplicaListener.java | 5 +-
.../partition/replicator/ZoneResourcesManager.java | 11 +-
.../exception/OperationLockException.java | 43 +
.../network/PartitionReplicationMessageGroup.java | 6 +
.../disaster/DisasterRecoveryRequestMessage.java} | 32 +-
.../disaster/DisasterRecoveryResponseMessage.java} | 29 +-
.../replication/ReadWriteReplicaRequest.java | 11 +-
.../network/replication/RequestType.java | 14 +
.../replicator/raft/RaftTxFinishMarker.java | 15 +-
.../raft/snapshot/LogStorageAccess.java} | 30 +-
.../raft/snapshot/LogStorageAccessImpl.java} | 31 +-
.../raft/snapshot/PartitionDataStorage.java | 7 +-
.../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 | 49 +-
.../incoming/ReplicationLogStorageKey.java | 76 +
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 3 +-
.../PartitionReplicaLifecycleManagerTest.java | 60 +-
.../replicator/ZoneResourcesManagerTest.java | 5 +-
.../PartitionSnapshotStorageFactoryTest.java | 3 +-
.../snapshot/PartitionSnapshotStorageTest.java | 3 +-
.../incoming/IncomingSnapshotCopierTest.java | 20 +-
.../outgoing/OutgoingSnapshotReaderTest.java | 4 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 13 +-
.../placementdriver/LeasePlacementDriver.java | 1 +
.../ItPrimaryReplicaChoiceTest.java | 19 +-
.../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/ignite_client_configuration.h | 10 +-
.../cpp/ignite/common/detail/duration_min_max.h} | 20 +-
modules/platforms/cpp/ignite/common/error_codes.h | 2 +
.../detail/linux/linux_async_client_pool.cpp | 4 +-
.../network/detail/linux/linux_async_client_pool.h | 5 +-
.../detail/linux/linux_async_worker_thread.cpp | 12 +-
.../ignite/network/ssl/secure_socket_client.cpp | 78 +-
.../cpp/ignite/network/ssl/secure_socket_client.h | 4 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 2 +
.../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} | 26 +-
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 | 44 +-
modules/platforms/dotnet/.config/dotnet-tools.json | 2 +-
.../Apache.Extensions.Caching.Ignite/README.md | 4 +-
.../Apache.Ignite.Benchmarks.csproj | 2 +-
.../ExceptionsGenerator.cs | 4 +-
.../Apache.Ignite.Tests/Apache.Ignite.Tests.csproj | 2 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 14 +-
.../dotnet/Apache.Ignite.Tests/ConsoleLogger.cs | 34 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 22 +-
.../dotnet/Apache.Ignite.Tests/JavaServer.cs | 38 +-
.../dotnet/Apache.Ignite.Tests/LoggingTests.cs | 2 +-
.../PartitionAwarenessRealClusterTests.cs | 6 +-
.../Table/SchemaSynchronizationTest.cs | 1 +
.../Table/SchemaValidationTest.cs | 14 +-
.../dotnet/Apache.Ignite.Tests/TestUtils.cs | 6 +-
.../Transactions/TransactionsTests.cs | 14 +-
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 2 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 6 +
.../dotnet/Apache.Ignite/IgniteServerException.cs | 58 +
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 1 +
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 46 +-
.../dotnet/Apache.Ignite/Internal/LogMessages.cs | 13 +-
.../dotnet/Apache.Ignite/Sql/SqlStatement.cs | 9 +-
.../internal/raft/RaftGroupEventsListener.java | 3 +-
.../rebalance/ChangePeersAndLearnersWithRetry.java | 100 +
.../internal/raft/rebalance/ExceptionUtils.java} | 27 +-
.../internal/raft/rebalance/RaftCommand.java} | 16 +-
.../raft/rebalance/RaftCommandWithRetry.java | 124 +
.../raft/rebalance/RaftStaleUpdateException.java} | 15 +-
.../internal/raft/ItRaftGroupServiceTest.java | 12 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 102 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 73 +-
.../ignite/raft/jraft/core/MockStateMachine.java | 18 +
.../apache/ignite/raft/jraft/core/TestCluster.java | 78 +-
.../internal/raft/JraftGroupEventsListener.java | 3 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 23 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 6 +
.../internal/raft/server/impl/JraftServerImpl.java | 20 +-
.../impl/RaftGroupEventsListenerAdapter.java | 10 +-
.../raft/storage/impl/VolatileRaftMetaStorage.java | 5 +
.../raft/storage/segstore/IndexFileManager.java | 23 +-
.../raft/storage/segstore/RaftLogCheckpointer.java | 37 -
.../raft/storage/segstore/SegmentFileManager.java | 75 +-
.../raft/storage/segstore/SegstoreLogStorage.java | 45 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 54 +-
.../ignite/raft/jraft/storage/RaftMetaStorage.java | 4 +-
.../jraft/storage/impl/LocalRaftMetaStorage.java | 12 +-
.../ignite/raft/jraft/storage/io/MessageFile.java | 17 +-
.../raft/jraft/util/CompatibleJDKMarshaller.java | 119 +
.../ChangePeersAndLearnersWithRetryTest.java} | 35 +-
.../storage/segstore/IndexFileManagerTest.java | 11 +-
.../storage/segstore/SegmentFileManagerTest.java | 63 +-
.../SegstoreLogStorageConcurrencyTest.java | 136 +
.../storage/segstore/SegstoreLogStorageTest.java | 44 +-
.../ItPlacementDriverReplicaSideTest.java | 2 +-
.../ignite/internal/replicator/ReplicaImpl.java | 44 +-
.../ignite/internal/replicator/ReplicaManager.java | 96 +-
.../internal/replicator/ReplicaStateManager.java | 2 +-
.../replicator/message/ReplicaMessageUtils.java | 15 +-
.../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 | 3 +-
...terRecoveryControllerRestartPartitionsTest.java | 84 +-
...ControllerRestartPartitionsWithCleanupTest.java | 188 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 243 +-
.../rest/cluster/ClusterManagementController.java | 31 +-
.../rest/cluster/ClusterManagementRestFactory.java | 13 +-
.../rest/cluster/DataNodesRestFactory.java | 49 +
.../internal/rest/cluster/JoinFutureProvider.java} | 12 +-
.../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 | 19 +-
.../ItDistributedConfigurationPropertiesTest.java | 4 +-
.../ItDistributedConfigurationStorageTest.java | 4 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 38 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 11 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 35 +-
.../runner/app/ItIgniteNodeRestartTest.java | 42 +-
.../internal/runner/app/ItIgniteServerTest.java | 155 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 11 +-
.../runner/app/ItReplicaStateManagerTest.java | 14 +-
.../runner/app/PlatformTestNodeRunner.java | 4 +-
.../app/client/ItAbstractThinClientTest.java | 14 +-
.../client/ItThinClientChannelValidatorTest.java | 276 +
.../app/client/ItThinClientMarshallingTest.java | 136 +-
.../client/ItThinClientMultistatementSqlTest.java | 544 ++
.../ItThinClientSchemaSynchronizationTest.java | 28 +-
.../runner/app/client/ItThinClientSqlTest.java | 91 +
.../app/client/ItThinClientTransactionsTest.java | 194 +-
...ClientTransactionsWithBrokenReplicatorTest.java | 389 ++
.../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 | 68 +-
.../internal/table/ItThinClientColocationTest.java | 2 +-
.../main/java/org/apache/ignite/IgniteServer.java | 57 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 44 +-
.../ignite/internal/app/IgniteServerImpl.java | 48 +-
.../ignite/internal/app/ThreadPoolsManager.java | 6 +-
.../configuration/ignite-snapshot.bin | Bin 5541 -> 5611 bytes
.../ignite/internal/AssignmentsTestUtils.java | 6 +-
.../java/org/apache/ignite/internal/Cluster.java | 44 +-
.../internal/ClusterPerClassIntegrationTest.java | 19 +-
.../schema/BinaryTupleComparatorUtils.java | 81 +-
.../internal/schema/PartialBinaryTupleMatcher.java | 2 +-
.../internal/schema/SchemaMismatchException.java | 10 +
.../CatalogToSchemaDescriptorConverterTest.java | 2 +-
.../schema/marshaller/KvMarshallerTest.java | 2 +-
.../schema/marshaller/RecordMarshallerTest.java | 2 +-
.../ignite/internal/sql/engine/SqlQueryType.java | 15 +
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 29 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 12 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 10 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 22 +
.../ignite/internal/sql/engine/ItDmlTest.java | 2 +
.../sql/engine/ItDynamicParameterTest.java | 2 +-
.../ItPrefixLikeToRangeScanConversionTest.java | 261 +
.../internal/sql/engine/ItSecondaryIndexTest.java | 18 +-
.../sql/engine/ItSqlMultiStatementTest.java | 36 +
.../sql/engine/ItUnstableTopologyTest.java | 2 -
.../sql/engine/kill/ItSqlKillCommandTest.java | 6 +-
.../systemviews/ItSqlQueriesSystemViewTest.java | 10 +-
.../basic_queries/rename_columns_in_from.test | 14 +-
.../integrationTest/sql/group1/explain/scan.test | 2 +-
.../sql/group1/syscolumns/system_columns.test | 45 +-
.../internal/sql/api/AsyncResultSetImpl.java | 14 +-
...=> CreateTableDefaultsConfigurationSchema.java} | 22 +-
.../SqlDistributedConfigurationSchema.java | 4 +
.../internal/sql/engine/SqlOperationContext.java | 23 +-
.../sql/engine/SqlQueriesViewProvider.java | 1 +
.../internal/sql/engine/SqlQueryProcessor.java | 30 +-
.../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 +-
.../engine/exec/TableRowConverterFactoryImpl.java | 15 +-
.../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 | 16 +-
.../exec/exp/func/SystemRangeTableFunction.java | 6 +-
.../exec/fsm/CursorInitializationPhaseHandler.java | 18 +-
.../exec/fsm/CursorPublicationPhaseHandler.java | 58 +
.../sql/engine/exec/fsm/ExecutionPhase.java | 2 +
.../sql/engine/exec/fsm/MultiStatementHandler.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/IgniteSqlValidator.java | 3 +-
.../sql/engine/prepare/KeyValueGetPlan.java | 9 +-
.../sql/engine/prepare/SelectCountPlan.java | 11 +-
.../sql/engine/prepare/bounds/RangeBounds.java | 69 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 16 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 21 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 25 +
.../engine/statistic/StatisticAggregatorImpl.java | 69 +-
.../sql/engine/tx/QueryTransactionContextImpl.java | 2 +-
.../engine/tx/ScriptTransactionWrapperImpl.java | 15 +
.../sql/engine/type/IgniteTypeFactory.java | 28 +-
.../ignite/internal/sql/engine/util/Commons.java | 8 +-
.../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 | 3 +
.../internal/sql/engine/exec/DdlBatchingTest.java | 2 +
.../exec/ExecutableTableRegistrySelfTest.java | 2 -
.../sql/engine/exec/ExecutionServiceImplTest.java | 113 +-
.../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 +-
.../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 | 35 +-
.../internal/sql/engine/framework/TestNode.java | 2 -
.../sql/engine/planner/TpcdsQueryPlannerTest.java | 4 +-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 48 +-
.../DistributionZoneSqlToCommandConverterTest.java | 9 +-
.../engine/schema/SqlSchemaManagerImplTest.java | 9 +-
.../internal/sql/engine/util/QueryCheckerTest.java | 16 +-
.../internal/sql/engine/util/TypeUtilsTest.java | 124 +-
.../src/test/resources/docs/operator_list.txt | 6 +
.../src/test/resources/mapping/correlated.test | 8 +-
.../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/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 | 14 +-
.../apache/ignite/internal/storage/ReadResult.java | 31 +-
.../apache/ignite/internal/storage/RowMeta.java | 16 +-
.../storage/ThreadAssertingMvPartitionStorage.java | 8 +-
.../storage/AbstractMvPartitionStorageGcTest.java | 17 +
.../storage/AbstractMvPartitionStorageTest.java | 167 +-
.../storage/BaseMvPartitionStorageTest.java | 14 +-
.../storage/impl/TestMvPartitionStorage.java | 53 +-
.../storage/index/AbstractIndexStorageTest.java | 54 -
.../storage/pagememory/StorageMemoryIoModule.java | 2 +-
.../pagememory/StoragePartitionMetaFactory.java | 2 +-
.../storage/pagememory/StoragePartitionMetaIo.java | 11 +-
.../StoragePartitionMetaIoVersions.java} | 15 +-
.../index/AbstractPageMemoryIndexStorage.java | 43 +
.../index/freelist/ReadIndexColumnsValue.java | 16 +-
.../pagememory/index/hash/HashIndexRowKey.java | 10 +
.../index/hash/PageMemoryHashIndexStorage.java | 27 +-
.../pagememory/index/hash/io/HashIndexTreeIo.java | 18 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 40 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 106 +-
.../pagememory/mv/AddWriteInvokeClosure.java | 76 +-
.../storage/pagememory/mv/FindRowVersion.java | 46 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 32 +
.../pagememory/mv/PlainRowVersionReader.java | 69 +
...Value.java => PlainRowVersionValueOffsets.java} | 22 +-
.../mv/PreloadingForGcInvokeClosure.java | 99 +
.../storage/pagememory/mv/ReadRowVersion.java | 45 +-
.../storage/pagememory/mv/ReadRowVersionValue.java | 15 +-
.../internal/storage/pagememory/mv/RowVersion.java | 111 +-
.../storage/pagememory/mv/RowVersionReader.java | 67 +
...rsionValue.java => RowVersionValueOffsets.java} | 30 +-
.../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 | 8 +-
.../internal/storage/rocksdb/GarbageCollector.java | 47 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 41 +-
.../internal/systemview/SystemViewManagerTest.java | 2 +-
modules/table/build.gradle | 2 +
...xDistributedTestSingleNodeNoCleanupMessage.java | 6 +-
...ItTxDistributedTestThreeNodesThreeReplicas.java | 5 +-
.../ItTxObservableTimePropagationTest.java | 7 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 13 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 13 +-
.../ignite/internal/table/ItColocationTest.java | 23 +-
.../table/ItKeyValueBinaryViewApiTest.java | 15 +-
.../internal/table/ItOperationRetryTest.java | 10 +-
...titionModificationCounterConfigurationTest.java | 76 +
.../ItPartitionModificationCounterMetricsTest.java | 8 +-
.../internal/table/ItRecordBinaryViewApiTest.java | 4 +-
...bstractHighAvailablePartitionsRecoveryTest.java | 99 +-
.../schema/marshaller/TupleMarshallerImpl.java | 36 +-
.../internal/table/KeyValueBinaryViewImpl.java | 2 +-
.../internal/table/RecordBinaryViewImpl.java | 2 +-
.../apache/ignite/internal/table/TableImpl.java | 2 +-
.../internal/table/TupleMarshallerCache.java | 7 +-
.../PartitionReplicatorNodeRecovery.java | 252 -
.../table/distributed/StorageUpdateHandler.java | 2 +-
.../internal/table/distributed/TableManager.java | 1387 +----
.../disaster/DisasterRecoveryManager.java | 264 +-
.../DisasterRecoveryRequestForwardException.java | 37 +
.../table/distributed/gc/GcUpdateHandler.java | 90 +-
.../ignite/internal/table/distributed/gc/MvGc.java | 4 +-
.../raft/MinimumRequiredTimeCollectorService.java | 1 +
.../table/distributed/raft/PartitionListener.java | 13 +-
.../snapshot/PartitionMvStorageAccessImpl.java | 5 +
.../SnapshotAwarePartitionDataStorage.java | 4 +-
.../raft/snapshot/TablePartitionKey.java | 8 +
.../replicator/PartitionReplicaListener.java | 469 +-
.../distributed/storage/InternalTableImpl.java | 3 +-
.../table/partition/HashPartitionManagerImpl.java | 2 +-
.../ignite/internal/utils/RebalanceUtilEx.java | 198 -
.../TupleMarshallerFixlenOnlyBenchmark.java | 4 +-
.../TupleMarshallerVarlenOnlyBenchmark.java | 4 +-
.../marshaller/TupleMarshallerStatisticsTest.java | 3 +-
.../table/ColocationHashCalculationTest.java | 5 +-
.../internal/table/MutableRowTupleAdapterTest.java | 33 +-
.../table/TableKvOperationsMockedTest.java | 6 +-
.../internal/table/distributed/IndexGcTest.java | 22 +-
.../distributed/StorageUpdateHandlerTest.java | 66 +-
.../distributed/TableManagerRecoveryTest.java | 156 +-
.../table/distributed/TableManagerTest.java | 284 +-
.../disaster/DisasterRecoveryMsInvokeTest.java | 25 +-
.../gc/AbstractGcUpdateHandlerTest.java | 38 +-
.../internal/table/distributed/gc/MvGcTest.java | 12 +-
.../PartitionReplicaListenerIndexLockingTest.java | 26 +-
...itionReplicaListenerSortedIndexLockingTest.java | 26 +-
.../replication/PartitionReplicaListenerTest.java | 1045 +---
.../ZonePartitionReplicaListenerTest.java | 170 +-
.../replicator/TransactionStateResolverTest.java | 8 +-
.../storage/InternalTableEstimatedSizeTest.java | 4 +-
.../table/type/NumericTypesSerializerTest.java | 29 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 28 +-
.../distributed/TestPartitionDataStorage.java | 5 +-
.../ignite/internal/table/KeyValueTestUtils.java | 9 +
.../ignite/internal/table/TxAbstractTest.java | 34 +-
.../table/impl/DummyInternalTableImpl.java | 4 +-
modules/transactions/build.gradle | 1 +
.../disaster/DisasterRecoveryTestUtil.java | 17 +-
.../disaster/ItDisasterRecoveryManagerTest.java | 5 +-
.../ItDisasterRecoveryReconfigurationTest.java | 226 +-
.../ItDisasterRecoveryResetPartitionsTest.java | 17 +-
.../tx/readonly/ItReadOnlyTxInPastTest.java | 2 +-
.../tx/distributed/ItTxResourcesVacuumTest.java | 9 +-
...LockException.java => DelayedAckException.java} | 34 +-
.../ignite/internal/tx/InternalTxOptions.java | 21 +-
.../apache/ignite/internal/tx/LockException.java | 18 +
.../tx/PossibleDeadlockOnLockAcquireException.java | 52 +
.../tx/TransactionExceptionMapperProvider.java | 2 +
.../org/apache/ignite/internal/tx/TxManager.java | 15 +-
.../org/apache/ignite/internal/tx/TxStateMeta.java | 216 +-
.../ignite/internal/tx/TxStateMetaAbandoned.java | 31 +-
.../ignite/internal/tx/TxStateMetaFinishing.java | 50 +-
.../internal/tx/impl/EnlistedPartitionGroup.java | 2 +
.../ignite/internal/tx/impl/HeapLockManager.java | 89 +-
.../internal/tx/impl/IgniteTransactionsImpl.java | 2 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 3 +
.../tx/impl/RemoteReadWriteTransaction.java | 8 +-
.../internal/tx/impl/TransactionInflights.java | 64 +-
.../internal/tx/impl/TxCleanupRequestSender.java | 37 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 114 +-
.../tx/impl/VolatileTxStateMetaStorage.java | 12 +-
.../tx/message/TransactionMetaMessage.java | 2 +-
.../tx/message/TxStateMetaAbandonedMessage.java | 3 +-
.../tx/message/TxStateMetaFinishingMessage.java | 10 +-
.../internal/tx/message/TxStateMetaMessage.java | 5 +-
.../apache/ignite/internal/tx/TxCleanupTest.java | 56 +-
.../apache/ignite/internal/tx/TxStateMetaTest.java | 126 +
.../internal/tx/impl/OrphanDetectorTest.java | 15 +-
.../internal/tx/test/ItTransactionTestUtils.java | 8 +-
.../internal/tx/test/TxStateMetaTestUtils.java | 53 +
packaging/cli/build.gradle | 1 +
packaging/cli/start.sh | 1 +
settings.gradle | 2 +
911 files changed, 35308 insertions(+), 30712 deletions(-)
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/catalog/src/main/java/org/apache/ignite/internal/catalog/CatalogByIndexMap.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogByIndexMapTest.java
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/cluster/init/ItClusterInitOneNodeTest.java
copy
modules/cli/src/{test/java/org/apache/ignite/internal/cli/commands/cluster/ClusterInitReplTest.java
=>
integrationTest/java/org/apache/ignite/internal/cli/commands/unit/ItDeploymentUnitReplTest.java}
(71%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionKey.java
=>
cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/zone/datanodes/ItResetDataNodesCommandTest.java}
(73%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionKey.java
=>
cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/zone/datanodes/ItResetDataNodesReplCommandTest.java}
(72%)
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/zone/datanodes/ItResetDataNodesTest.java
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/cluster/{unit/DeployUnitCallFactory.java
=> ClusterInitCallFactory.java} (66%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/{cluster/ClusterInitCall.java
=> management/zone/ResetDataNodesCall.java} (54%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/management/zone/ResetDataNodesCallInput.java
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/{client-common/src/main/java/org/apache/ignite/internal/client/proto/ErrorExtensions.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/zone/ZoneCommand.java}
(64%)
copy
modules/{client-common/src/main/java/org/apache/ignite/internal/client/proto/ErrorExtensions.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/zone/ZoneReplCommand.java}
(63%)
copy
modules/{client-common/src/main/java/org/apache/ignite/internal/client/proto/ErrorExtensions.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/zone/datanodes/DataNodesCommand.java}
(65%)
copy
modules/{client-common/src/main/java/org/apache/ignite/internal/client/proto/ErrorExtensions.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/zone/datanodes/DataNodesReplCommand.java}
(65%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/{cluster/unit/ClusterUnitDeployCommand.java
=> zone/datanodes/ResetDataNodesCommand.java} (63%)
copy
modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/StorageMemoryIoModule.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/zone/datanodes/ResetDataNodesMixin.java}
(53%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/{cluster/unit/ClusterUnitDeployCommand.java
=> zone/datanodes/ResetDataNodesReplCommand.java} (50%)
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/core/call/AsyncCallFactory.java}
(75%)
copy
modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/ReadRowVersionValue.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/{transactions/src/main/java/org/apache/ignite/internal/tx/LockException.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/ClientDelayedAckException.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%)
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/DistributionZoneRebalanceEngineV2.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/main/java/org/apache/ignite/internal/index/IndexBuildTaskStatisticsLoggingListener.java
create mode 100644
modules/index/src/main/java/org/apache/ignite/internal/index/IndexBuilderMetricSource.java
create mode 100644
modules/index/src/test/java/org/apache/ignite/internal/index/IndexBuildTaskStatisticsLoggingListenerTest.java
create mode 100644
modules/index/src/test/java/org/apache/ignite/internal/index/IndexBuilderMetricsTest.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/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/StorageMemoryIoModule.java
=>
jdbc/src/main/java/org/apache/ignite/internal/jdbc/ClientSyncResultSet.java}
(60%)
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
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/exception/OperationLockException.java
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TransactionMetaMessage.java
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/DisasterRecoveryRequestMessage.java}
(55%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TransactionMetaMessage.java
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/DisasterRecoveryResponseMessage.java}
(59%)
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%)
copy
modules/{replicator/src/main/java/org/apache/ignite/internal/replicator/message/TablePartitionIdMessage.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%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/ZonesNotFoundException.java
=> platforms/cpp/ignite/protocol/heartbeat_timeout.h} (56%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/IgniteServerException.cs
create mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/ChangePeersAndLearnersWithRetry.java
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/LockException.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/ExceptionUtils.java}
(53%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionKey.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/RaftCommand.java}
(72%)
create mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/RaftCommandWithRetry.java
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed/TableManagerWithColocationTest.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/RaftStaleUpdateException.java}
(67%)
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}
(75%)
create mode 100644
modules/raft/src/test/java/org/apache/ignite/internal/raft/storage/segstore/SegstoreLogStorageConcurrencyTest.java
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
create mode 100644
modules/rest/src/main/java/org/apache/ignite/internal/rest/cluster/DataNodesRestFactory.java
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionKey.java
=>
rest/src/main/java/org/apache/ignite/internal/rest/cluster/JoinFutureProvider.java}
(73%)
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/runner/app/client/ItThinClientTransactionsWithBrokenReplicatorTest.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
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
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/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
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionKey.java
=>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/StoragePartitionMetaIoVersions.java}
(68%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/PlainRowVersionReader.java
copy
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/{ReadRowVersionValue.java
=> PlainRowVersionValueOffsets.java} (70%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/PreloadingForGcInvokeClosure.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/RowVersionReader.java
copy
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/{ReadRowVersionValue.java
=> RowVersionValueOffsets.java} (61%)
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
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/utils/RebalanceUtilEx.java
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/{LockException.java
=> DelayedAckException.java} (50%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/PossibleDeadlockOnLockAcquireException.java
create mode 100644
modules/transactions/src/test/java/org/apache/ignite/internal/tx/TxStateMetaTest.java
create mode 100644
modules/transactions/src/testFixtures/java/org/apache/ignite/internal/tx/test/TxStateMetaTestUtils.java
