This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch ignite-26849
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 031cc6ea744 IGNITE-26849 after review #1.0
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 b1618e08690 Merge branch 'main' into ignite-26849
No new revisions were added by this update.
Summary of changes:
.github/dependabot.yml | 4 +
.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 +-
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 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 3 +
.../java/org/apache/ignite/sql/ColumnType.java | 5 +-
.../ignite/table/AbstractImmutableTupleTest.java | 2 +-
.../cluster/init/ItClusterInitOneNodeTest.java | 66 +
.../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} | 12 +-
.../cluster/init/ClusterInitReplCommand.java | 33 +-
.../cluster/unit/ClusterUnitDeployCommand.java | 5 +-
.../cli/core/call/AsyncCallExecutionPipeline.java | 8 +-
.../call/AsyncCallExecutionPipelineBuilder.java | 31 +-
.../call/{CallInput.java => AsyncCallFactory.java} | 10 +-
.../cli/core/call/CallExecutionPipeline.java | 6 +-
.../{StringCallInput.java => SpinnerRenderer.java} | 40 +-
.../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 +-
.../cli/core/call/SpinnerRendererTest.java} | 24 +-
.../ignite/internal/client/proto/ClientOp.java | 5 +
.../client/proto/ProtocolBitmaskFeature.java | 12 +-
.../client/proto/tx/ClientInternalTxOptions.java} | 50 +-
.../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 | 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 | 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 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 3 +-
.../handler/requests/sql/ClientSqlCommonTest.java | 92 +
.../apache/ignite/client/ClientOperationType.java | 5 +
.../org/apache/ignite/client/RetryReadPolicy.java | 1 +
.../ignite/internal/client/ChannelValidator.java | 50 +
.../apache/ignite/internal/client/ClientUtils.java | 3 +
.../ignite/internal/client/ProtocolContext.java | 18 +-
.../ignite/internal/client/ReliableChannel.java | 17 +-
.../ignite/internal/client/TcpClientChannel.java | 34 +-
.../ignite/internal/client/TcpIgniteClient.java | 23 +-
.../ignite/internal/client/WriteContext.java | 4 +-
.../internal/client/sql/ClientAsyncResultSet.java | 68 +-
.../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} | 20 +-
.../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 +-
.../ignite/client/TestClientHandlerModule.java | 1 +
.../org/apache/ignite/client/fakes/FakeCursor.java | 8 +
.../apache/ignite/client/fakes/FakeTxManager.java | 2 +-
.../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 +
...ItMetastorageRaftSnapshotCompatibilityTest.java | 1 -
...cOverThinSqlWithOldServerCompatibilityTest.java | 82 +
.../ignite/internal/CompatibilityTestBase.java | 12 +-
.../org/apache/ignite/internal/IgniteCluster.java | 5 +
.../ignite/internal/compute/IgniteComputeImpl.java | 24 +-
.../compute/NextColocatedWorkerSelector.java | 27 +-
.../compute/PartitionNextWorkerSelector.java | 13 +-
.../compute/PrimaryReplicaNextWorkerSelector.java | 4 +-
.../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} | 17 +-
.../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 +-
.../ItRebalanceByPendingAssignmentsQueueTest.java | 18 +-
.../rebalance/ItRebalanceDistributedTest.java | 6 +-
.../distributionzones/DistributionZoneManager.java | 19 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 349 --
.../DistributionZoneRebalanceEngineV2.java | 14 +-
.../rebalance/PartitionMover.java | 2 +-
.../distributionzones/rebalance/RebalanceUtil.java | 11 -
.../rebalance/ZoneRebalanceUtil.java | 12 +-
.../DistributionZoneRebalanceEngineTest.java | 66 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 55 +-
.../error-code-annotation-processor/build.gradle | 1 +
.../error-code-api}/build.gradle | 6 +-
.../error/code/annotations/ErrorCodeGroup.java | 5 +-
.../ignite/internal/failure/FailureManager.java | 4 +-
.../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 | 33 +-
.../apache/ignite/internal/index/IndexBuilder.java | 18 -
.../internal/index/IndexBuildingManager.java | 8 +-
.../RetryingFinalTransactionStateResolver.java | 6 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 13 +-
.../internal/index/ChangeIndexStatusTaskTest.java | 25 +-
.../CommittedFinalTransactionStateResolver.java | 4 +-
.../index/IndexAvailabilityControllerTest.java | 2 -
.../internal/index/IndexBuildControllerTest.java | 4 +-
.../ignite/internal/index/IndexBuilderTest.java | 6 +-
.../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/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 | 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} | 17 +-
.../jdbc/ItJdbcWithConnectionPoolBaseTest.java | 245 +
.../ignite/jdbc/ItJdbcWithHikariPoolTest.java} | 18 +-
.../ignite/internal/jdbc/ClientSyncResultSet.java} | 29 +-
.../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 | 111 +-
.../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 --
.../impl/ItIdempotentCommandCacheTest.java | 2 +
.../ItMetaStorageCompactionTriggerOneNodeTest.java | 4 +-
.../impl/ItMetaStorageCompactionTriggerTest.java | 4 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 4 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 4 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 2 +-
.../impl/StandaloneMetaStorageManager.java | 16 +
.../pagememory/persistence/PageHeader.java | 38 +-
.../persistence/PersistentPageMemory.java | 109 +-
.../persistence/compaction/Compactor.java | 2 +-
.../partition/replicator/ItZoneTxFinishTest.java | 2 +-
.../partition/replicator/fixtures/Node.java | 5 +-
.../PartitionReplicaLifecycleManager.java | 87 +-
.../network/PartitionReplicationMessageGroup.java | 6 +
...st.java => DisasterRecoveryRequestMessage.java} | 19 +-
...t.java => DisasterRecoveryResponseMessage.java} | 18 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 6 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 3 +-
.../PartitionReplicaLifecycleManagerTest.java | 3 +-
.../incoming/IncomingSnapshotCopierTest.java | 4 +-
.../placementdriver/PlacementDriverTest.java | 38 +-
modules/platforms/cpp/ignite/common/error_codes.h | 1 +
modules/platforms/cpp/ignite/odbc/common_types.cpp | 1 +
modules/platforms/dotnet/.config/dotnet-tools.json | 2 +-
.../Apache.Ignite.Benchmarks.csproj | 2 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 4 +-
.../dotnet/Apache.Ignite.Tests/ConsoleLogger.cs | 34 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 22 +-
.../dotnet/Apache.Ignite.Tests/LoggingTests.cs | 2 +-
.../PartitionAwarenessRealClusterTests.cs | 6 +-
.../Table/SchemaSynchronizationTest.cs | 1 +
.../dotnet/Apache.Ignite.Tests/TestUtils.cs | 6 +-
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 2 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 3 +
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 35 +-
.../dotnet/Apache.Ignite/Internal/LogMessages.cs | 4 +-
.../dotnet/Apache.Ignite/Sql/SqlStatement.cs | 9 +-
.../internal/raft/rebalance/ExceptionUtils.java} | 24 +-
.../raft/rebalance/RaftStaleUpdateException.java} | 11 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 5 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 6 +
.../internal/raft/server/impl/JraftServerImpl.java | 4 +-
.../ItPlacementDriverReplicaSideTest.java | 2 +-
.../ignite/internal/replicator/ReplicaManager.java | 103 +-
.../internal/replicator/ReplicaStateManager.java | 2 +-
.../internal/replicator/ReplicaManagerTest.java | 2 +-
modules/rest-api/build.gradle | 2 +-
modules/rest/build.gradle | 2 +
.../ItNodeConfigurationControllerTest.java | 74 +-
...terRecoveryControllerRestartPartitionsTest.java | 84 +-
...ControllerRestartPartitionsWithCleanupTest.java | 188 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 243 +-
.../rest/cluster/ClusterManagementController.java | 31 +-
.../rest/cluster/ClusterManagementRestFactory.java | 13 +-
.../internal/rest/cluster/JoinFutureProvider.java} | 12 +-
.../ignite/internal/rest/RestComponentTest.java | 46 +-
.../ConfigurationControllerBaseTest.java | 57 +-
.../SystemDisasterRecoveryControllerTest.java | 31 +-
.../internal/benchmark/BulkLoadBenchmark.java | 60 +
.../ignite/internal/benchmark/InsertBenchmark.java | 2 +-
.../ignite/internal/benchmark/SelectBenchmark.java | 2 +-
.../client/ItClientDataConsistencyTest.java} | 22 +-
.../internal/client/ItClientDirectMappingTest.java | 2 +-
.../ItDistributedConfigurationPropertiesTest.java | 4 +-
.../ItDistributedConfigurationStorageTest.java | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 39 +-
.../internal/runner/app/ItIgniteServerTest.java | 155 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 5 +-
.../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/ItTableScanTest.java | 27 +-
.../main/java/org/apache/ignite/IgniteServer.java | 57 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 32 +-
.../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 +-
.../CatalogToSchemaDescriptorConverterTest.java | 2 +-
.../ignite/internal/sql/engine/SqlQueryType.java | 15 +
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 23 +
.../sql/engine/ItDynamicParameterTest.java | 2 +-
.../sql/engine/kill/ItSqlKillCommandTest.java | 6 +-
.../systemviews/ItSqlQueriesSystemViewTest.java | 10 +-
.../internal/sql/api/AsyncResultSetImpl.java | 5 +
.../CreateTableDefaultsConfigurationSchema.java} | 28 +-
.../SqlDistributedConfigurationSchema.java | 4 +
.../internal/sql/engine/SqlOperationContext.java | 23 +-
.../internal/sql/engine/SqlQueryProcessor.java | 18 +-
.../internal/sql/engine/exec/ExecutionContext.java | 15 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 98 +-
.../sql/engine/exec/LogicalRelImplementor.java | 44 +-
.../sql/engine/exec/MailboxRegistryImpl.java | 19 +-
.../internal/sql/engine/exec/RowHandler.java | 6 +-
.../internal/sql/engine/exec/SqlRowHandler.java | 62 +-
.../sql/engine/exec/UpdatableTableImpl.java | 22 +-
.../sql/engine/exec/exp/ExpressionFactory.java | 4 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 4 +-
.../engine/exec/exp/JoinProjectionImplementor.java | 23 +-
.../sql/engine/exec/exp/ProjectionImplementor.java | 37 +-
.../engine/exec/exp/RowProviderImplementor.java | 26 +-
.../sql/engine/exec/exp/ValuesImplementor.java | 6 +-
.../exec/exp/func/SystemRangeTableFunction.java | 6 +-
.../sql/engine/exec/fsm/QueryExecutor.java | 29 +-
...nMappingException.java => MappedFragments.java} | 29 +-
.../sql/engine/exec/mapping/MappingService.java | 3 +-
.../engine/exec/mapping/MappingServiceImpl.java | 19 +-
.../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/NullTypeSpec.java | 47 -
.../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 -
.../sql/engine/message/QueryStartRequest.java | 4 +
.../sql/engine/prepare/KeyValueGetPlan.java | 9 +-
.../sql/engine/prepare/SelectCountPlan.java | 11 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 16 +-
.../sql/engine/type/IgniteTypeFactory.java | 28 +-
.../engine/util/SqlExceptionMapperProvider.java | 2 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 132 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 109 +-
.../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 +-
.../exec/mapping/MappingServiceImplTest.java | 24 +-
.../sql/engine/exec/mapping/MappingTestRunner.java | 4 +-
.../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 | 11 +-
.../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/TestBuilders.java | 16 +-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 48 +-
.../DistributionZoneSqlToCommandConverterTest.java | 9 +-
.../engine/schema/SqlSchemaManagerImplTest.java | 7 +-
.../internal/sql/engine/util/TypeUtilsTest.java | 124 +-
.../internal/sql/BaseSqlIntegrationTest.java | 2 +-
.../internal/sql/engine/util/SqlTestUtils.java | 15 +-
.../internal/storage/MvPartitionStorage.java | 5 +-
.../apache/ignite/internal/storage/ReadResult.java | 31 +-
.../apache/ignite/internal/storage/RowMeta.java | 16 +-
.../storage/ThreadAssertingMvPartitionStorage.java | 4 +-
.../storage/AbstractMvPartitionStorageGcTest.java | 17 +
.../storage/AbstractMvPartitionStorageTest.java | 75 +-
.../storage/BaseMvPartitionStorageTest.java | 5 +-
.../storage/impl/TestMvPartitionStorage.java | 29 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 22 +-
.../pagememory/mv/AddWriteInvokeClosure.java | 12 +-
.../storage/pagememory/mv/ScanVersionsCursor.java | 2 +-
.../storage/pagememory/mv/VersionChain.java | 20 +-
.../storage/pagememory/mv/io/VersionChainIo.java | 2 +-
.../pagememory/PersistentPageMemoryNoLoadTest.java | 109 +
...PersistentPageMemoryMvPartitionStorageTest.java | 2 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 30 +-
.../internal/systemview/SystemViewManagerTest.java | 2 +-
...ItTxDistributedTestThreeNodesThreeReplicas.java | 5 +-
.../ItTxObservableTimePropagationTest.java | 7 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 2 +-
.../ignite/internal/table/ItColocationTest.java | 21 +-
.../internal/table/ItOperationRetryTest.java | 10 +-
...titionModificationCounterConfigurationTest.java | 76 +
.../ItPartitionModificationCounterMetricsTest.java | 8 +-
.../table/distributed/TableAssignmentsService.java | 4 +-
.../internal/table/distributed/TableManager.java | 21 +-
.../disaster/DisasterRecoveryManager.java | 236 +-
...> DisasterRecoveryRequestForwardException.java} | 29 +-
.../replicator/PartitionReplicaListener.java | 20 +-
.../distributed/TableManagerRecoveryTest.java | 132 +-
.../table/distributed/TableManagerTest.java | 278 +-
.../disaster/DisasterRecoveryMsInvokeTest.java | 25 +-
.../PartitionReplicaListenerIndexLockingTest.java | 24 +-
...itionReplicaListenerSortedIndexLockingTest.java | 24 +-
.../replication/PartitionReplicaListenerTest.java | 892 +---
.../ZonePartitionReplicaListenerTest.java | 154 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 2 +-
modules/transactions/build.gradle | 1 +
.../disaster/DisasterRecoveryTestUtil.java | 7 +-
.../ItDisasterRecoveryReconfigurationTest.java | 117 +-
.../ItDisasterRecoveryResetPartitionsTest.java | 15 +-
.../tx/distributed/ItTxResourcesVacuumTest.java | 9 +-
.../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 +-
.../internal/tx/test/ItTransactionTestUtils.java | 8 +-
settings.gradle | 2 +
441 files changed, 24472 insertions(+), 9720 deletions(-)
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/{api/src/main/java/org/apache/ignite/table/DataStreamerOperationType.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/cluster/init/ClusterInitConstants.java}
(76%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/call/{CallInput.java
=> AsyncCallFactory.java} (79%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/call/{StringCallInput.java
=> SpinnerRenderer.java} (57%)
copy
modules/{cluster-management/src/test/java/org/apache/ignite/internal/cluster/management/ClusterIdHolderTest.java
=>
cli/src/test/java/org/apache/ignite/internal/cli/core/call/SpinnerRendererTest.java}
(63%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/subscription/ListAccumulator.java
=>
client-common/src/main/java/org/apache/ignite/internal/client/proto/tx/ClientInternalTxOptions.java}
(53%)
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/prepare/ddl/StorageProfileValidator.java
=>
client/src/main/java/org/apache/ignite/internal/client/table/MapFunction.java}
(64%)
create mode 100644
modules/compatibility-tests/src/integrationTest/java/org/apache/ignite/internal/client/JdbcOverThinSqlWithOldServerCompatibilityTest.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/type/StructNativeType.java
copy
modules/{marshaller-common/src/main/java/org/apache/ignite/internal/util/Factory.java
=> core/src/main/java/org/apache/ignite/internal/util/IgniteBusyLock.java}
(75%)
delete mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/DistributionZoneRebalanceEngine.java
copy {dev-utilities => modules/error-code-api}/build.gradle (90%)
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/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/jdbc/src/{main/java/org/apache/ignite/jdbc/package-info.java =>
integrationTest/java/org/apache/ignite/jdbc/ItJdbcWithC3p0PoolTest.java} (65%)
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/jdbc/ItJdbcWithConnectionPoolBaseTest.java
copy modules/jdbc/src/{main/java/org/apache/ignite/jdbc/package-info.java =>
integrationTest/java/org/apache/ignite/jdbc/ItJdbcWithHikariPoolTest.java} (62%)
copy modules/{api/src/main/java/org/apache/ignite/lang/Cursor.java =>
jdbc/src/main/java/org/apache/ignite/internal/jdbc/ClientSyncResultSet.java}
(62%)
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/disaster/{LocalPartitionStatesRequest.java
=> DisasterRecoveryRequestMessage.java} (72%)
copy
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/{LocalPartitionStatesRequest.java
=> DisasterRecoveryResponseMessage.java} (76%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxCleanupExceptionUtils.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/ExceptionUtils.java}
(60%)
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/serialization/marshal/MarshalException.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/rebalance/RaftStaleUpdateException.java}
(75%)
copy
modules/{raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/FutureImpl.java
=>
rest/src/main/java/org/apache/ignite/internal/rest/cluster/JoinFutureProvider.java}
(78%)
copy
modules/{sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItNotNullConstraintClientTest.java
=>
runner/src/integrationTest/java/org/apache/ignite/internal/client/ItClientDataConsistencyTest.java}
(65%)
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
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/configuration/GcConfigurationSchema.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/configuration/distributed/CreateTableDefaultsConfigurationSchema.java}
(58%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{ColocationMappingException.java
=> MappedFragments.java} (60%)
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/NullTypeSpec.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
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItPartitionModificationCounterConfigurationTest.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/{IllegalPartitionIdException.java
=> DisasterRecoveryRequestForwardException.java} (52%)
