This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/org.threeten-threetenbp-1.6.9
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard f4322047ac Bump org.threeten:threetenbp from 1.6.8 to 1.6.9
add 1ac8094b4c IGNITE-21846 Exclude noinspection from
CommentStartWithSpace rule (#3489)
add bbdb28a993 IGNITE-21760 Remove destroyed RocksDB tables on recovery
(#3488)
add 6f53312518 IGNITE-21413 .NET: Add tags to metrics (#3490)
add b1fdda2508 IGNITE-21527 C++: Clean up IEP-54 leftovers (#3486)
add 37a37de4d9 IGNITE-21851 Remove RocksDB cache type support (#3497)
add 02a45ba8ae IGNITE-21848 Move thread hijack protection to wrappers
(#3491)
add d80a17dfbb IGNITE-21797: Fix column's type mismatch during marshalling
of pojo (embedded API) (#3466)
add 53f1f5cedd IGNITE-20649 Sql. Added casting to the required type for
EXCEPT/INTERSECT operations (#3479)
add 997f53db50 IGNITE-20126 Handle 'index storage is under destruction' on
read/write (#3447)
add 38af0512c3 IGNITE-21855 Fix ItIndexAndIndexStorageDestructionTest
(#3503)
add ded415d544 IGNITE-21529 Implement log sink for EventLog (#3485)
add 9b467f1791 IGNITE-21566 Fix failed to get the primary replica
exception. (#3492)
add ae643bd31f IGNITE-21849 Prevent thread hijacking via IgniteTables
(#3498)
add b8e9c98465 IGNITE-21330 Sql. Support index scan for OR operator with
dynamic parameters (#3407)
add 37a80743d0 IGNITE-21673 Do not allow duplicate column names in unique
column list of a primary key constraint. (#3501)
add a5161669ed IGNITE-21820: Sql. Test framework. Activate indices created
via TestNode::initSchema script. (#3458)
add 1c45e005b2 IGNITE-21870 Make SharedRocksDbInstance#sortedIndexes
thread-safe
add a4dac8ef73 IGNITE-21864 Provide cluster name in thin client (#3507)
add c662f45bbe IGNITE-21768 Java thin: Fix column serialization order in
ClientKeyValueView (#3509)
add bcde60c53d IGNITE-21853 Prevent thread hijacking via
IgniteTransactions (#3506)
add 8a848cb24e IGNITE-21722 Sql. Fix NPE in correlated nested loop join
(#3504)
add b08fbb6087 IGNITE-21852: RecordView. RecordView does not support
arbitrary key column order (#3502)
add cad7303f30 IGNITE-21776 Sql. Concurrent "create table" call with same
name need to wait already processed result (#3448)
add 166ade294e IGNITE-21878 Allow compute threads to execute storage
operations (#3517)
add 9f9e0a6166 IGNITE-21827: Sql. Union returns incorrect result for
DECIMAL and INT columns (#3474)
add 7e6ca8f927 IGNITE-21287 Sql. LogicalOrToUnionRule may hang (#3505)
add 3733fa400b IGNITE-21256 Add internal API for getting partition states
from all nodes in the cluster. (#3379)
add 83224d76e3 IGNITE-21862 Rename PK index when renaming a table (#3518)
add e04ca11c99 IGNITE-21867 Add new ability to configure
ReplicaService#RPC_TIMEOUT and TxMessageSender#RPC_TIMEOUT and increase the
default values (#3510)
add 71c320f0af IGNITE-21745 Optimize BigDecimal representation in
BinaryTuple (#3493)
add a927dd3db4 IGNITE-21288 C++: Implement job execution interface (#3516)
add dee0f1b0f4 IGNITE-21818 Support broadcasting null-returning jobs
(#3520)
add 82576ea5cd IGNITE-21885 Fix AssertionError in
RocksDbSortedIndexStorage#scan (#3523)
add 387c559fd5 IGNITE-21875 SQL API cleanup - remove properties and
reactive methods (#3514)
add 35ef7213b0 IGNITE-21877 Fix column deserialization order in
ClientKeyValueView (#3526)
add f139cbbfe8 IGNITE-21335 C++ 3.0: Implement job_execution_options
(#3524)
add d80f40ad73 IGNITE-21876 Prevent thread hijacking via IgniteCompute
(#3529)
add a5c0973bf4 IGNITE-21891: fixing an issue for tuples when key columns
are after value ones
add 655cf0fbb5 IGNITE-21869 Prevent thread hijacking via IgniteSql (#3512)
add 292546402c IGNITE-21665 Implement Event log (#3522)
add 78e446b9a7 IGNITE-21898 Remove reactive methods from
AntiHijackingIgniteSql (#3534)
add 0d4dbce79c IGNITE-21896 Close RocksDB flush listener on stop (#3533)
add e896751ac6 IGNITE-21890 Fix BinaryTupleComparator for decimal values
(#3527)
add 167f8dce56 IGNITE-21808 CREATE ZONE syntax must work with any the case
of zone name (#3508)
add dd75ada680 IGNITE-21765 Fix streamer partition awareness (#3538)
add c41a26f2d8 IGNITE-21761 Within commitPartition mark txnState with
cleanup finished timestamp (#3496)
add e394902598 IGNITE-21572 Fix one phase transaction protocol
inconsistency in case of primary replica expirations (#3467)
add bac613c518 IGNITE-17591 Refactor toString generation for network
messages (#3519)
add d9480d7e38 IGNITE-21567 Sql. Fixed precision when converting from
TIME/TIMESTAMP to VARCHAR (#3513)
add 87ee3037d4 IGNITE-21794: Sql. Rename ItKeyValuePutTest and
ItKeyValueGetTest (#3515)
add d28153dce8 IGNITE-21879 Sql. Jdbc
IdbcStatementSelfTest.testOpenCursorsPureQuery is flaky (#3543)
add 10d97f81d1 IGNITE-21887 Sql. Reuse caller thread if query already
prepared (#3525)
add 4de0999022 IGNITE-21094 Sql. Combine single/script query execution
methods into a single one (#3536)
add d3ff291c4c IGNITE-21931 .NET: Refactor DataStreamer to use
StreamerBatchSend (#3546)
add 7c8ebb82bb IGNITE-21897 Sql. Invalid collation passthrough for sorted
aggregates (#3537)
add 952c97b2d5 IGNITE-21909 Fix race on getting and destroying an index in
SharedRocksDbInstance (#3544)
add 64117d5a75 IGNITE-18944 Remove obsolete TODO (#3545)
add 0fdb5e4f90 IGNITE-21828 Fix config update commands without parameters
(#3550)
add 58f43c8f05 IGNITE-21907 Change thread count for RAFT disruptors to
improve perfo… (#3542)
add 5180c53f7d IGNITE-21301 Sync raft log before flush in all storage
engines (#3535)
add 1539873b49 IGNITE-21757 Fix redeploy (#3528)
add d62471e0d1 IGNITE-21989 Get topology in the JDBC URL completer
directly (#3555)
add 3dd95601f1 IGNITE-21895 Assertion rarely raised on
LimitExecutionTest.testLimit (#3531)
add 303cfa02a9 IGNITE-21773 Don't notify low watermark update listeners at
node start (#3549)
add 0757083143 IGNITE-21905 Add integration test for EventLog (#3554)
add 9a24cc6145 IGNITE-21490 .NET: Add DataStreamer data removal (#3560)
add 3cb914dd7a IGNITE-21580 Sql. Optimise query plans when using two phase
aggregates (#3552)
add 4ebefb3f6f IGNITE-21307 Add using a failure handler during watch
processing (#3553)
add 5075e7d48c IGNITE-21924 Improve user threads handling (#3547)
add e067aeae9d IGNITE-21494 Data Streamer: use one executor per node for
flushTimer (#3562)
add b03ea24f6e IGNITE-22002 Substitute assertion with explicit check for
PrimaryReplicaChangeCommand (#3573)
add 6fda2047ac IGNITE-22008 Fix double-checked locking in
ReadWriteTransactionImpl (#3576)
add 266fdc6fa6 IGNITE-20606 Sql. Add syntax to support setting the default
distribution zone (#3567)
add 6f29716426 IGNITE-21382 Fixed flaky
ItPrimaryReplicaChoiceTest.testPrimaryChangeLongHandling (#3495)
add e78b369bb5 IGNITE-21920 Cover SQL E051-04 (Basic query specification,
GROUP BY can contain columns not in <select list>) feature by tests (#3572)
add 7a479e147c IGNITE-21480 Check local node before broadcasting (#3568)
add 0c7076c0b6 IGNITE-21594 Storage profiles (#3266)
add 77bbc39bff IGNITE-21995 Do not disable thread assertions in tests
(#3565)
add a4ceab5d43 IGNITE-21892 Await replica services creation in
ItPlacementDriverReplicaSideTest (#3574)
add 010111eaa2 IGNITE-22018 Fix flaky ItConnectionHeartbeatTest (#3582)
add a0bbb71e64 IGNITE-21721 Sql. Adjust cost estimation for index scan
(#3579)
add c47c746b69 IGNITE-19274 Sql. Jdbc client time zone propagation (#3558)
add 4ed64a8b46 IGNITE-21922: Cover SQL E141-01(Basic integrity
constraints, NOT NULL constraints) feature by tests (#3578)
add 1b8046c97d IGNITE-21762 Run cleanup on primary reelection for all
finished txns. (#3540)
add 90b4e2418d IGNITE-21917: Cover SQL T434 (GROUP BY DISTINCT) feature by
tests (#3580)
add a71af6247a Bump org.threeten:threetenbp from 1.6.8 to 1.6.9
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 (f4322047ac)
\
N -- N -- N
refs/heads/dependabot/gradle/org.threeten-threetenbp-1.6.9 (a71af6247a)
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:
check-rules/checkstyle-rules.xml | 2 +-
check-rules/spotbugs-excludes.xml | 10 +
docs/_docs/config/data-region.adoc | 5 +-
docs/_docs/storage/rocksdb.adoc | 6 +-
examples/build.gradle | 1 +
examples/config/ignite-config.conf | 7 +
.../storage/ItPageMemoryStorageExampleTest.java | 21 --
.../storage/ItRocksdbStorageExampleTest.java | 11 -
.../PersistentPageMemoryStorageExample.java | 2 +-
.../example/storage/RocksDbStorageExample.java | 2 +-
.../example/storage/StorageEngineExample.java | 15 +-
.../storage/VolatilePageMemoryStorageExample.java | 2 +-
gradle/libs.versions.toml | 2 +
.../org/apache/ignite/catalog/IgniteCatalog.java | 6 +-
.../apache/ignite/catalog/annotations/Zone.java | 14 +-
.../ignite/catalog/definitions/ZoneDefinition.java | 64 +---
.../org/apache/ignite/compute/IgniteCompute.java | 27 +-
.../main/java/org/apache/ignite/sql/IgniteSql.java | 46 ---
.../main/java/org/apache/ignite/sql/Statement.java | 28 --
.../ignite/sql/reactive/ReactiveResultSet.java | 72 ----
.../java/org/apache/ignite/table/RecordView.java | 2 +-
.../internal/ConfigurationModuleArchTest.java | 92 -----
.../internal/binarytuple/BinaryTupleBuilder.java | 24 +-
.../internal/binarytuple/BinaryTupleParser.java | 2 +-
.../internal/binarytuple/BinaryTupleReader.java | 14 +-
.../internal/binarytuple/BinaryTupleTest.java | 47 ++-
.../ignite/internal/catalog/ItCatalogDslTest.java | 16 +-
.../catalog/sql/CreateFromAnnotationsImpl.java | 7 +-
.../catalog/sql/CreateFromDefinitionImpl.java | 7 +-
.../internal/catalog/sql/CreateZoneImpl.java | 18 +-
.../ignite/internal/catalog/sql/WithOption.java | 4 +
.../catalog/sql/CreateFromAnnotationsTest.java | 37 +-
.../catalog/sql/CreateFromDefinitionTest.java | 13 +-
.../internal/catalog/sql/CreateZoneTest.java | 13 +-
.../catalog/sql/InvalidDefinitionTest.java | 3 -
.../internal/catalog/CatalogManagerImpl.java | 52 ++-
.../catalog/CatalogParamsValidationUtils.java | 44 +++
.../ignite/internal/catalog/CatalogService.java | 3 +
.../CatalogVersionAwareValidationException.java} | 33 +-
.../catalog/commands/AlterZoneCommand.java | 25 +-
.../catalog/commands/AlterZoneCommandBuilder.java | 7 +-
.../AlterZoneSetDefaultCatalogCommand.java | 76 ++++
.../internal/catalog/commands/CatalogUtils.java | 67 ++--
.../catalog/commands/CreateTableCommand.java | 50 ++-
.../commands/CreateTableCommandBuilder.java | 5 +-
.../catalog/commands/CreateZoneCommand.java | 28 +-
.../catalog/commands/CreateZoneCommandBuilder.java | 7 +-
.../catalog/commands/RenameTableCommand.java | 15 +-
.../catalog/commands/RenameZoneCommand.java | 2 +-
...torageParams.java => StorageProfileParams.java} | 55 +--
.../internal/catalog/commands/TablePrimaryKey.java | 27 +-
.../catalog/commands/TableSortedPrimaryKey.java | 7 +-
.../descriptors/CatalogDataStorageDescriptor.java | 88 -----
.../CatalogStorageProfileDescriptor.java | 73 ++++
.../CatalogStorageProfilesDescriptor.java | 90 +++++
.../descriptors/CatalogTableDescriptor.java | 25 +-
.../catalog/descriptors/CatalogZoneDescriptor.java | 28 +-
.../internal/catalog/storage/AlterColumnEntry.java | 3 +-
.../internal/catalog/storage/DropColumnsEntry.java | 3 +-
.../internal/catalog/storage/NewColumnsEntry.java | 3 +-
.../internal/catalog/storage/RenameIndexEntry.java | 139 +++++++
.../internal/catalog/storage/RenameTableEntry.java | 3 +-
.../CatalogEntrySerializerProvider.java | 4 +-
.../serialization/MarshallableEntryType.java | 3 +-
...CatalogManagerDescriptorCausalityTokenTest.java | 19 +-
.../internal/catalog/CatalogManagerSelfTest.java | 114 +++++-
.../commands/AbstractCommandValidationTest.java | 21 +-
.../catalog/commands/CatalogUtilsTest.java | 3 +-
.../commands/CreateTableCommandValidationTest.java | 110 ++++++
.../commands/CreateZoneCommandValidationTest.java | 22 ++
.../commands/RenameTableCommandValidationTest.java | 22 ++
.../catalog/commands/TablePrimaryKeyTest.java | 22 +-
.../CatalogDataStorageDescriptorTest.java | 37 --
.../descriptors/CatalogTableDescriptorTest.java | 4 +-
.../descriptors/CatalogZoneDescriptorTest.java | 8 +-
.../storage/CatalogEntrySerializationTest.java | 41 ++-
.../ignite/internal/catalog/CatalogTestUtils.java | 12 +-
.../ignite/internal/cli/CliIntegrationTest.java | 6 +
.../internal/cli/commands/ItConfigCommandTest.java | 191 ----------
.../cli/commands/ItConnectionHeartbeatTest.java | 109 +-----
.../configuration/ItConfigCommandTest.java | 37 +-
.../repl/executor/ItIgnitePicocliCommandsTest.java | 10 +-
.../cli/commands/SpacedParameterMixin.java | 2 +-
.../repl/registry/impl/JdbcUrlRegistryImpl.java | 25 +-
.../repl/registry/impl/NodeNameRegistryImpl.java | 2 +-
.../internal/cli/commands/CliCommandTestBase.java | 48 ++-
.../internal/cli/commands/ProfileMixinTest.java | 45 +--
.../cluster/config/ConfigUpdateCommandTest.java | 131 +++++++
.../client/proto/ClientMessageDecoder.java | 2 +-
.../table/MutableTupleBinaryTupleAdapter.java | 4 +-
.../internal/jdbc/proto/JdbcQueryEventHandler.java | 5 +-
modules/client-handler/build.gradle | 5 +-
.../apache/ignite/client/handler/TestServer.java | 2 +-
.../ignite/client/handler/ClientHandlerModule.java | 4 +-
.../handler/ClientInboundMessageHandler.java | 13 +-
.../handler/ClientPrimaryReplicaTracker.java | 34 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 53 ++-
.../ClientComputeExecuteColocatedRequest.java | 2 +-
.../compute/ClientComputeExecuteRequest.java | 2 +-
.../requests/jdbc/ClientJdbcConnectRequest.java | 5 +-
.../requests/sql/ClientSqlExecuteRequest.java | 2 +-
.../handler/requests/table/ClientHandlerTuple.java | 10 +-
...entTablePartitionPrimaryReplicasGetRequest.java | 19 +-
.../handler/ClientPrimaryReplicaTrackerTest.java | 2 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 9 +-
.../ignite/client/handler/FakeCatalogService.java | 6 +-
.../ignite/client/handler/FakePlacementDriver.java | 2 +-
modules/client/build.gradle | 1 +
.../client/IgniteClientConfigurationImpl.java | 2 +-
.../ignite/internal/client/ProtocolContext.java | 19 +-
.../ignite/internal/client/ReliableChannel.java | 44 ++-
.../ignite/internal/client/TcpClientChannel.java | 6 +-
.../ignite/internal/client/TcpIgniteClient.java | 22 +-
.../client/io/netty/NettyClientConnection.java | 2 +-
.../internal/client/sql/ClientAsyncResultSet.java | 3 +-
.../internal/client/sql/ClientColumnOrigin.java | 4 +-
.../ignite/internal/client/sql/ClientSql.java | 40 +--
.../internal/client/sql/ClientStatement.java | 32 +-
.../client/sql/ClientStatementBuilder.java | 23 +-
.../internal/client/table/ClientDataStreamer.java | 7 +-
.../internal/client/table/ClientKeyValueView.java | 35 +-
.../client/table/ClientRecordSerializer.java | 12 +-
.../ignite/internal/client/table/ClientSchema.java | 2 +-
.../ignite/internal/client/table/ClientTable.java | 55 +--
.../client/table/ClientTupleSerializer.java | 4 +-
.../marshaller/ClientMarshallerReader.java | 19 +-
.../apache/ignite/client/AbstractClientTest.java | 4 +-
.../org/apache/ignite/client/ClientSqlTest.java | 8 -
.../org/apache/ignite/client/ClientTablesTest.java | 36 --
.../org/apache/ignite/client/ClientTupleTest.java | 4 +-
.../client/ObservableTimestampPropagationTest.java | 1 -
.../org/apache/ignite/client/SchemaUpdateTest.java | 2 +-
.../apache/ignite/client/ServerMetricsTest.java | 1 -
.../ignite/client/TestClientHandlerModule.java | 2 +-
.../java/org/apache/ignite/client/TestServer.java | 3 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 34 +-
.../ignite/client/fakes/FakeInternalTable.java | 6 +
.../apache/ignite/client/fakes/FakeTxManager.java | 16 +-
.../internal/client/ClientFutureUtilsTest.java | 2 +-
modules/cluster-management/build.gradle | 3 +
.../management/topology/ItLogicalTopologyTest.java | 15 +-
.../cluster/management/NodeAttributes.java | 5 +-
.../management/NodeAttributesCollector.java | 15 +-
.../ClusterManagementConfigurationModule.java | 2 +-
.../management/raft/CmgRaftGroupListener.java | 2 +-
.../raft/commands/ClusterNodeMessage.java | 3 +-
.../management/topology/api/LogicalNode.java | 25 +-
.../management/BaseItClusterManagementTest.java | 8 +-
.../internal/cluster/management/MockNode.java | 4 +-
modules/code-deployment/build.gradle | 1 +
.../ignite/internal/deployunit/UnitStatus.java | 26 +-
.../metastore/ClusterEventCallbackImpl.java | 19 +-
.../metastore/DeploymentUnitFailover.java | 14 +-
.../deployunit/metastore/DeploymentUnitStore.java | 9 +-
.../metastore/DeploymentUnitStoreImpl.java | 33 +-
.../metastore/status/SerializeUtils.java | 34 +-
.../metastore/status/UnitClusterStatus.java | 24 +-
.../metastore/status/UnitNodeStatus.java | 35 +-
.../deployment/UnitStatusesSerializerTest.java | 21 +-
.../metastore/DeploymentUnitStoreImplTest.java | 75 +++-
.../deployunit/DeploymentManagerImplTest.java | 15 +-
modules/compute/build.gradle | 1 +
.../ignite/internal/compute/ItComputeBaseTest.java | 14 +-
.../internal/compute/ItComputeTestEmbedded.java | 99 +++++
.../internal/compute/ItExecutionsCleanerTest.java | 13 +-
.../internal/compute/ItWorkerShutdownTest.java | 9 +-
.../threading/ItComputeApiThreadingTest.java | 235 ++++++++++++
.../internal/compute/AntiHijackIgniteCompute.java | 145 ++++++++
.../internal/compute/AntiHijackJobExecution.java | 65 ++++
.../apache/ignite/internal/compute/Cleaner.java | 2 +-
.../internal/compute/ComputeComponentImpl.java | 22 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 6 +-
.../compute/executor/ComputeExecutorImpl.java | 7 +-
.../compute/messaging/ComputeMessaging.java | 2 +
.../internal/compute/ComputeComponentImplTest.java | 288 +++++----------
.../ignite/configuration/ConfigurationModule.java | 5 +-
.../configuration/ConfigurationTreeGenerator.java | 6 +-
.../configuration/ConfigurationTestUtils.java | 0
.../ignite/internal/components/LogSyncer.java} | 17 +-
.../internal/lang/IgniteSystemProperties.java | 3 +
.../apache/ignite/internal/lang/InternalTuple.java | 3 +-
.../internal/replicator/ReplicatorConstants.java} | 14 +-
.../internal/streamer/StreamerSubscriber.java | 43 +--
.../ignite/internal/thread/PublicApiThreading.java | 147 +++++---
.../ignite/internal/thread/ThreadOperation.java | 4 +-
.../internal/tostring/IgniteToStringExclude.java | 6 +-
.../internal/tostring/IgniteToStringInclude.java | 6 +-
.../apache/ignite/internal/util/GridUnsafe.java | 4 +-
.../apache/ignite/internal/util/IgniteUtils.java | 6 +-
.../util/subscription/OrderedMergePublisher.java | 58 ++-
.../apache/ignite/internal/wrapper/Wrapper.java} | 16 +-
.../apache/ignite/internal/wrapper/Wrappers.java | 57 +++
.../causality/IncrementalVersionedValueTest.java | 2 +-
.../internal/streamer/StreamerSubscriberTest.java | 22 ++
.../criteria/CriteriaExceptionMapperUtilTest.java | 2 +-
.../internal/thread/PublicApiThreadingTest.java | 70 ----
.../tostring/IgniteToStringBuilderSelfTest.java | 2 +-
.../internal/testframework/IgniteTestUtils.java | 36 +-
.../testframework/TestIgnitionManager.java | 9 +-
.../src/testFixtures/resources/log4j2-test.xml | 17 +-
...st.java => ItDistributionZonesFiltersTest.java} | 70 ++--
...niteDistributionZoneManagerNodeRestartTest.java | 40 ++-
.../distributionzones/DistributionZoneManager.java | 33 +-
.../distributionzones/DistributionZonesUtil.java | 61 +++-
.../distributionzones/NodeWithAttributes.java | 46 ++-
.../CausalityDataNodesEngine.java | 6 +-
.../disaster/DisasterRecoveryManager.java | 172 ---------
.../rebalance/DistributionZoneRebalanceEngine.java | 2 +-
.../RebalanceRaftGroupEventsListener.java | 13 +-
.../distributionzones/rebalance/RebalanceUtil.java | 14 +-
.../BaseDistributionZoneManagerTest.java | 17 +
...a => DistributionZoneAttributeFiltersTest.java} | 44 +--
.../DistributionZoneManagerAlterFilterTest.java | 24 +-
...ibutionZoneManagerConfigurationChangesTest.java | 8 +-
.../DistributionZoneManagerFilterTest.java | 24 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 145 ++++----
...utionZoneManagerStorageProfilesFilterTest.java} | 51 +--
.../DistributionZoneStorageProfilesFilterTest.java | 71 ++++
.../DistributionZoneCausalityDataNodesTest.java | 31 +-
.../DistributionZoneRebalanceEngineTest.java | 13 +
.../RebalanceUtilUpdateAssignmentsTest.java | 4 +-
.../DistributionZonesTestUtil.java | 124 ++++---
modules/eventlog/README.MD | 43 +++
modules/eventlog/build.gradle | 24 ++
.../ItEventLogConfigurationValidationTest.java | 55 +++
.../ItLogSinkConfigurationValidationTest.java | 89 +++++
.../eventlog/impl/InMemoryCollectionSink.java} | 25 +-
...InMemoryCollectionSinkConfigurationSchema.java} | 18 +-
.../eventlog/impl/ItEventLogConfigurationTest.java | 225 ++++++++++++
.../internal/eventlog/impl/TestEventTypes.java} | 20 +-
.../internal/eventlog/impl/TestSinkFactory.java} | 28 +-
.../apache/ignite/internal/eventlog/api/Event.java | 10 +-
.../api/{EventLog.java => EventChannel.java} | 19 +-
.../ignite/internal/eventlog/api/EventFactory.java | 11 +-
.../ignite/internal/eventlog/api/EventLog.java | 26 +-
.../IgniteEventType.java} | 19 +-
.../eventlog/{event => api}/IgniteEvents.java | 20 +-
.../eventlog/api/{EventFactory.java => Sink.java} | 24 +-
.../config/EventLogConfigurationModule.java} | 30 +-
.../config/schema/ChannelConfigurationSchema.java} | 20 +-
.../schema/EventLogConfigurationSchema.java} | 19 +-
.../config/schema/EventTypeValidatorImpl.java | 49 +++
.../config/schema/LogSinkConfigurationSchema.java} | 37 +-
.../config/schema/SinkConfigurationSchema.java} | 30 +-
.../eventlog/config/schema/ValidEventType.java} | 8 +-
.../ignite/internal/eventlog/event/EventImpl.java | 7 +-
.../internal/eventlog/event/EventTypeRegistry.java | 7 +-
.../event/exception/MissingEventTypeException.java | 2 +-
.../internal/eventlog/impl/ChannelFactory.java} | 25 +-
.../internal/eventlog/impl/ChannelRegistry.java} | 30 +-
.../impl/ConfigurationBasedChannelRegistry.java | 115 ++++++
.../impl/ConfigurationBasedSinkRegistry.java | 95 +++++
.../internal/eventlog/impl/EventChannelImpl.java} | 36 +-
.../internal/eventlog/impl/EventLogImpl.java | 61 ++++
.../ignite/internal/eventlog/impl/LogSink.java | 45 +++
.../SinkFactory.java} | 31 +-
.../internal/eventlog/impl/SinkRegistry.java} | 14 +-
.../internal/eventlog/ser/EventSerializer.java} | 12 +-
.../internal/eventlog/ser/JsonEventSerializer.java | 110 ++++++
.../internal/eventlog/event/EventBuilderTest.java | 1 -
.../internal/eventlog/event/IgniteEventsTest.java | 1 +
.../ConfigurationBasedChannelRegistryTest.java | 155 ++++++++
.../impl/ConfigurationBasedSinkRegistryTest.java | 111 ++++++
.../internal/eventlog/impl/EventLogTest.java | 143 ++++++++
.../ignite/internal/eventlog/impl/LogSinkTest.java | 104 ++++++
.../eventlog/ser/JsonEventSerializerTest.java | 92 +++++
modules/failure-handler/build.gradle | 3 +
.../internal/failure/NoOpFailureProcessor.java} | 26 +-
modules/index/build.gradle | 5 +
.../internal/index/ItBuildIndexOneNodeTest.java | 3 +-
.../ignite/internal/index/ItBuildIndexTest.java | 8 +-
.../ItIndexAndIndexStorageDestructionTest.java | 165 +++++++++
.../ignite/internal/index/ItIndexManagerTest.java | 3 +-
...IndexNodeFinishedRwTransactionsCheckerTest.java | 30 +-
.../index/ItRwTransactionAndIndexesTest.java | 7 +-
.../apache/ignite/internal/index/IndexManager.java | 2 +-
.../ignite/internal/index/IndexManagerTest.java | 9 +-
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 7 +-
.../ignite/jdbc/ItJdbcClientTimeZoneTest.java | 228 ++++++++++++
.../apache/ignite/jdbc/ItJdbcErrorsSelfTest.java | 2 -
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 10 +-
.../ignite/internal/jdbc/ConnectionProperties.java | 15 +
.../internal/jdbc/ConnectionPropertiesImpl.java | 67 +++-
.../internal/jdbc/JdbcClientQueryEventHandler.java | 7 +-
.../ignite/internal/jdbc/JdbcConnection.java | 62 ++--
.../internal/jdbc/PreparedStatementParamsTest.java | 10 +-
modules/low-watermark/README.md | 5 +
modules/{workers => low-watermark}/build.gradle | 29 +-
.../internal/lowwatermark}/LowWatermark.java | 19 +-
.../lowwatermark}/LowWatermarkCandidate.java | 2 +-
.../lowwatermark}/LowWatermarkChangedListener.java | 2 +-
.../internal/lowwatermark}/LowWatermarkImpl.java | 91 ++---
.../message/GetLowWatermarkRequest.java | 7 +-
.../message/GetLowWatermarkResponse.java | 7 +-
.../message/LowWatermarkMessageGroup.java} | 22 +-
.../lowwatermark}/LowWatermarkImplTest.java | 95 +++--
.../internal/lowwatermark}/TestLowWatermark.java | 4 +-
.../ignite/internal/marshaller/Marshaller.java | 57 ++-
.../internal/marshaller/MarshallerColumn.java | 23 +-
.../marshaller/ReflectionMarshallersProvider.java | 11 +-
.../ReflectionMarshallersProviderSelfTest.java | 74 +++-
modules/metastorage/build.gradle | 7 +
.../impl/ItMetaStorageManagerImplTest.java | 6 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 6 +-
.../ItMetaStorageMultipleNodesRocksDbTest.java | 3 +-
...tMetaStorageSafeTimePropagationRocksDbTest.java | 3 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 3 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 9 +-
.../metastorage/server/WatchProcessor.java | 32 +-
.../server/persistence/RocksDbKeyValueStorage.java | 5 +-
.../impl/MetaStorageRocksDbRangeTest.java | 3 +-
.../RocksDbCompactionKeyValueStorageTest.java | 3 +-
.../server/RocksDbKeyValueStorageTest.java | 3 +-
.../metastorage/server/WatchProcessorTest.java | 6 +-
.../server/SimpleInMemoryKeyValueStorage.java | 3 +-
.../server/TestRocksDbKeyValueStorage.java | 3 +-
.../processor/messages/MessageImplGenerator.java | 15 +-
.../stream/DirectByteBufferStreamImplV1.java | 24 +-
.../internal/network/netty/ConnectionManager.java | 2 +-
.../serialization/ClassDescriptorFactory.java | 4 +-
.../serialization/marshal/BuiltInMarshalling.java | 2 +-
.../marshal/DefaultUserObjectMarshaller.java | 4 +-
.../internal/network/AllTypesMessageTest.java | 17 +
...ltUserObjectMarshallerWithSchemaChangeTest.java | 6 +-
.../internal/network/messages/AllTypesMessage.java | 10 +
modules/page-memory/build.gradle | 1 +
.../tree/ItBplusTreeReplaceRemoveRaceTest.java | 18 +-
...ItBplusTreeReuseListVolatilePageMemoryTest.java | 24 +-
.../ItBplusTreeVolatilePageMemoryTest.java | 24 +-
.../ItBplusTreePersistentPageMemoryTest.java | 22 +-
...BplusTreeReuseListPersistentPageMemoryTest.java | 20 +-
.../PageMemoryLocalConfigurationModule.java | 7 +-
...stentPageMemoryProfileConfigurationSchema.java} | 15 +-
...atilePageMemoryProfileConfigurationSchema.java} | 16 +-
.../pagememory/inmemory/VolatilePageMemory.java | 32 +-
.../persistence/PersistentPageMemory.java | 40 +--
.../persistence/checkpoint/CheckpointManager.java | 5 +-
.../persistence/checkpoint/Checkpointer.java | 16 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 2 +-
.../pagememory/freelist/AbstractFreeListTest.java | 18 +-
.../inmemory/VolatilePageMemoryNoLoadSelfTest.java | 25 +-
.../PersistentPageMemoryNoLoadTest.java | 21 +-
.../checkpoint/CheckpointManagerTest.java | 3 +
.../persistence/checkpoint/CheckpointerTest.java | 28 +-
.../ItPrimaryReplicaChoiceTest.java | 144 +++++---
.../MultiActorPlacementDriverTest.java | 10 +-
...apache.ignite.configuration.ConfigurationModule | 1 -
.../internal/placementdriver/LeaseUpdater.java | 46 ++-
.../internal/placementdriver/leases/Lease.java | 34 +-
.../negotiation/LeaseAgreement.java | 9 +
.../placementdriver/PlacementDriverTest.java | 8 +-
.../leases/LeaseSerializationTest.java | 24 +-
modules/platforms/cpp/ignite/client/CMakeLists.txt | 31 +-
.../cpp/ignite/client/compute/compute.cpp | 26 +-
.../platforms/cpp/ignite/client/compute/compute.h | 78 ++--
.../cpp/ignite/client/compute/job_execution.cpp | 44 +++
.../cpp/ignite/client/compute/job_execution.h | 154 ++++++++
.../ignite/client/compute/job_execution_options.h | 70 ++++
.../cpp/ignite/client/compute/job_state.h} | 35 +-
.../cpp/ignite/client/compute/job_status.h} | 38 +-
.../cpp/ignite/client/detail/cluster_connection.h | 20 --
.../ignite/client/detail/compute/compute_impl.cpp | 262 +++++++++++---
.../ignite/client/detail/compute/compute_impl.h | 55 ++-
.../client/detail/compute/job_execution_impl.cpp | 124 +++++++
.../client/detail/compute/job_execution_impl.h | 135 +++++++
.../cpp/ignite/client/detail/response_handler.h | 76 ----
.../cpp/ignite/client/detail/table/schema.h | 102 ++++--
.../cpp/ignite/client/detail/table/table_impl.cpp | 106 ------
.../platforms/cpp/ignite/client/detail/utils.cpp | 70 +++-
modules/platforms/cpp/ignite/client/detail/utils.h | 39 ++
.../cpp/ignite/client/detail/utils_test.cpp | 92 +++++
.../platforms/cpp/ignite/common/big_decimal.cpp | 5 +-
modules/platforms/cpp/ignite/common/big_decimal.h | 19 +-
.../platforms/cpp/ignite/common/big_integer.cpp | 17 +-
modules/platforms/cpp/ignite/common/big_integer.h | 14 +-
modules/platforms/cpp/ignite/odbc/common_types.h | 2 +-
.../cpp/ignite/protocol/client_operation.h | 9 +
modules/platforms/cpp/ignite/protocol/reader.h | 23 ++
.../cpp/ignite/tuple/binary_tuple_builder.cpp | 7 +-
.../cpp/ignite/tuple/binary_tuple_builder.h | 2 +-
.../cpp/ignite/tuple/binary_tuple_parser.cpp | 23 +-
.../cpp/ignite/tuple/binary_tuple_parser.h | 10 +-
modules/platforms/cpp/ignite/tuple/tuple_test.cpp | 198 +++++++++-
.../platforms/cpp/tests/client-test/CMakeLists.txt | 1 +
.../cpp/tests/client-test/column_order_test.cpp | 136 +++++++
.../cpp/tests/client-test/compute_test.cpp | 152 +++++---
.../cpp/tests/client-test/ignite_runner_suite.h | 1 +
.../client-test/schema_synchronization_test.cpp | 2 +-
.../platforms/cpp/tests/client-test/sql_test.cpp | 2 +-
.../cpp/tests/test-common/basic_auth_test_suite.h | 2 +-
.../Apache.Ignite.Tests/ClientSocketTests.cs | 2 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 23 ++
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 15 +-
.../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 203 +++++++----
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 10 +-
.../Apache.Ignite.Tests/ProjectFilesTests.cs | 5 +-
.../Proto/BinaryTuple/BinaryTupleTests.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 9 +
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 105 +++++-
.../dotnet/Apache.Ignite.Tests/Table/Poco.cs | 2 +
.../Table/SchemaSynchronizationTest.cs | 29 +-
.../dotnet/Apache.Ignite/ClientOperationType.cs | 7 +-
.../Internal/Buffers/PooledArrayBuffer.cs | 34 +-
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 34 +-
.../Internal/ClientSocket.Metrics.cs} | 29 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 73 ++--
.../Apache.Ignite/Internal/ConnectionContext.cs | 3 +-
.../Apache.Ignite/Internal/IgniteClientInternal.cs | 6 +-
.../dotnet/Apache.Ignite/Internal/Metrics.cs | 10 +-
.../Apache.Ignite/Internal/MetricsContext.cs} | 18 +-
.../Apache.Ignite/Internal/Network/ClusterNode.cs | 53 ++-
.../Proto/BinaryTuple/BinaryTupleBuilder.cs | 9 +-
.../Proto/BinaryTuple/BinaryTupleCommon.cs | 22 +-
.../Proto/BinaryTuple/BinaryTupleReader.cs | 12 +
.../Apache.Ignite/Internal/Proto/ClientOp.cs | 5 +-
.../Internal/Proto/ClientOpExtensions.cs | 1 +
.../Apache.Ignite/Internal/SocketEndpoint.cs | 24 +-
.../Apache.Ignite/Internal/Table/DataStreamer.cs | 274 ++++++++++----
.../Apache.Ignite/Internal/Table/KeyValueView.cs | 7 +-
.../Apache.Ignite/Internal/Table/RecordView.cs | 15 +-
.../Table/Serialization/RecordSerializer.cs | 22 --
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 41 ++-
.../Table/Poco.cs => Apache.Ignite/MetricTags.cs} | 29 +-
.../dotnet/Apache.Ignite/RetryReadPolicy.cs | 1 +
.../dotnet/Apache.Ignite/Table/DataStreamerItem.cs | 53 +++
.../DataStreamerOperationType.cs} | 17 +-
.../Apache.Ignite/Table/IDataStreamerTarget.cs | 31 +-
.../apache/ignite/internal/raft/RaftManager.java | 4 +
.../raft/ItTruncateSuffixAndRestartTest.java | 4 +
.../java/org/apache/ignite/internal/raft/Loza.java | 17 +
.../internal/raft/server/impl/JraftServerImpl.java | 17 +
.../internal/raft/storage/LogStorageFactory.java | 3 +-
.../storage/impl/DefaultLogStorageFactory.java | 6 +
.../raft/storage/impl/LocalLogStorageFactory.java | 5 +
.../storage/impl/VolatileLogStorageFactory.java | 5 +
.../raft/storage/logit/LogitLogStorageFactory.java | 6 +
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 6 +-
.../java/org/apache/ignite/raft/jraft/Node.java | 10 +
.../apache/ignite/raft/jraft/core/NodeImpl.java | 28 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 6 +-
.../org/apache/ignite/raft/jraft/entity/LogId.java | 2 +-
.../ignite/raft/jraft/option/NodeOptions.java | 9 +-
.../snapshot/local/LocalSnapshotCopier.java | 2 +-
.../snapshot/local/LocalSnapshotStorage.java | 4 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 2 +-
.../ItPlacementDriverReplicaSideTest.java | 67 +++-
.../apache/ignite/internal/replicator/Replica.java | 31 +-
.../ignite/internal/replicator/ReplicaManager.java | 64 ++--
.../ignite/internal/replicator/ReplicaService.java | 42 ++-
.../ReplicationConfigurationSchema.java | 5 +
.../exception/PrimaryReplicaMissException.java | 14 +
.../message/PrimaryReplicaChangeCommand.java} | 19 +-
.../replicator/message/ReplicaMessageGroup.java | 3 +
.../replicator/PlacementDriverReplicaSideTest.java | 2 +
.../rocksdb/flush/RocksDbFlushListener.java | 19 +-
.../internal/rocksdb/flush/RocksDbFlusher.java | 14 +-
modules/runner/build.gradle | 5 +
.../configuration/generator/DefaultsGenerator.java | 3 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 8 +-
.../ignite/internal/benchmark/InsertBenchmark.java | 4 +-
.../ignite/internal/benchmark/SelectBenchmark.java | 17 +-
.../internal/benchmark/SqlIndexScanBenchmark.java | 240 +++++++++++++
.../benchmark/SqlMultiStatementBenchmark.java | 15 +-
.../ignite/internal/benchmark/TpchBenchmark.java | 16 +-
.../ItDistributedConfigurationPropertiesTest.java | 6 +-
.../ItNodeBootstrapConfigurationTest.java | 2 +-
.../configuration/ItNodeConfigurationFileTest.java | 2 +-
.../ItDistributedConfigurationStorageTest.java | 6 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 29 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 13 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 31 +-
.../runner/app/ItIgniteNodeRestartTest.java | 112 +++---
.../internal/runner/app/ItTablesApiTest.java | 15 +-
.../runner/app/PlatformTestNodeRunner.java | 9 +-
.../app/client/ItAbstractThinClientTest.java | 4 +-
.../client/ItCustomKeyColumnOrderClientTest.java | 398 +++++++++++++++++++++
.../ItCustomKeyColumnOrderEmbeddedTest.java} | 15 +-
.../runner/app/client/ItThinClientComputeTest.java | 17 +
.../app/client/ItThinClientConnectionTest.java | 7 +
.../client/ItThinClientPartitionAwarenessTest.java | 2 +-
.../ItSchemaForwardCompatibilityTest.java | 4 +-
.../schemasync/ItSchemaSyncAndReplicationTest.java | 10 +-
.../schemasync/ItSchemaSyncMultiNodeTest.java | 2 +-
.../schemasync/ItSchemaSyncSingleNodeTest.java | 6 +-
.../streamer/ItAbstractDataStreamerTest.java | 23 +-
.../streamer/ItServerDataStreamerTest.java | 3 -
.../ignite/internal/table/ItDurableFinishTest.java | 114 ++++--
.../ignite/internal/table/ItInternalTableTest.java | 53 ++-
.../internal/table/ItPublicApiColocationTest.java | 31 +-
.../internal/table/ItReadOnlyTransactionTest.java | 54 +--
.../ignite/internal/table/ItTableScanTest.java | 27 +-
.../internal/table/ItThinClientColocationTest.java | 5 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 108 ++++--
.../ignite/internal/app/ThreadPoolsManager.java | 3 +-
.../storage/LocalFileConfigurationStorage.java | 47 ++-
.../storage/LocalFileConfigurationStorageTest.java | 4 +-
.../ignite/internal/BaseIgniteRestartTest.java | 4 +
.../internal/ClusterPerClassIntegrationTest.java | 44 ++-
.../internal/ClusterPerTestIntegrationTest.java | 11 +
.../ignite/internal/PublicApiThreadingTests.java | 81 +++++
.../ignite/internal/TestDefaultProfilesNames.java} | 17 +-
.../org/apache/ignite/internal/TestWrappers.java | 102 ++++++
.../apache/ignite/internal/table/NodeUtils.java | 147 +++-----
modules/schema/build.gradle | 2 +-
.../ignite/internal/schema/BinaryRowConverter.java | 17 +-
.../ignite/internal/schema/BinaryTupleSchema.java | 34 +-
.../ignite/internal/schema/SchemaManager.java | 2 +-
.../LowWatermarkConfigurationSchema.java | 6 +-
.../internal/schema/marshaller/KvMarshaller.java | 9 +
.../internal/schema/marshaller/MarshallerUtil.java | 1 +
.../marshaller/asm/AsmMarshallerGenerator.java | 2 +-
.../marshaller/reflection/KvMarshallerImpl.java | 35 +-
.../reflection/RecordMarshallerImpl.java | 8 +-
.../schema/marshaller/reflection/RowReader.java | 98 +++--
.../org/apache/ignite/internal/schema/row/Row.java | 9 +
.../internal/schema/BinaryRowConverterTest.java | 132 +++++++
.../internal/schema/BinaryTupleSchemaTest.java | 100 +++++-
.../ignite/internal/schema/SchemaManagerTest.java | 9 +-
.../CatalogToSchemaDescriptorConverterTest.java | 4 +-
.../schema/marshaller/KvMarshallerTest.java | 173 ++++++++-
.../AuthenticationProviderConfigurationSchema.java | 1 -
.../authentication/AuthenticationManagerImpl.java | 2 +-
modules/sql-engine/build.gradle | 2 +
.../sql/api/ItKvKeyColumnPositionTest.java | 382 ++++++++++++++++++++
.../sql/api/ItRecordViewKeyPositionsTest.java | 248 +++++++++++++
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 42 +--
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 2 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 3 +-
.../sql/engine/BaseSqlMultiStatementTest.java | 9 +-
.../internal/sql/engine/ItAggregatesTest.java | 5 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 134 ++++++-
.../internal/sql/engine/ItDataTypesTest.java | 4 +-
.../internal/sql/engine/ItIndexSpoolTest.java | 8 +-
.../internal/sql/engine/ItOrToUnionRuleTest.java | 2 -
.../sql/engine/ItPkOnlyTableCrossApiTest.java | 13 +-
.../engine/ItSecondaryIndexMultiRangeScanTest.java | 369 +++++++++++++++++++
.../internal/sql/engine/ItSecondaryIndexTest.java | 10 +-
.../ignite/internal/sql/engine/ItSetOpTest.java | 59 ++-
...eGetTest.java => ItSqlUsesKeyValueGetTest.java} | 2 +-
...ePutTest.java => ItSqlUsesKeyValuePutTest.java} | 2 +-
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 14 +-
.../internal/sql/engine/ItZonesSystemViewTest.java | 6 +-
.../sql/engine/datatypes/uuid/ItUuidIndexTest.java | 7 -
.../sql/threading/ItSqlApiThreadingTest.java | 237 ++++++++++++
.../aggregate/group/test_group_by_distinct.test | 98 +++++
.../group/test_group_by_not_in_select.test | 64 ++++
.../sql/contstraint/test_not_null_contraint.test | 235 ++++++++++++
.../sql/types/date/date_parsing.test | 56 +++
.../sql/types/date/date_parsing.test_ignore | 1 +
.../integrationTest/sql/types/date/test_date.test | 38 ++
.../sql/types/date/test_date.test_ignore | 2 +
.../time/{test_time.test_ignore => test_time.test} | 21 +-
.../sql/types/time/time_parsing.test | 29 ++
.../sql/types/time/time_parsing.test_ignore | 2 +-
.../sql/types/timestamp/bc_timestamp.test_ignore | 3 +-
.../sql/types/timestamp/test_timestamp.test | 25 ++
modules/sql-engine/src/main/codegen/config.fmpp | 1 +
.../src/main/codegen/includes/parserImpls.ftl | 25 +-
.../internal/sql/api/AntiHijackAsyncResultSet.java | 74 ++++
.../ignite/internal/sql/api/IgniteSqlImpl.java | 44 +--
.../sql/api/PublicApiThreadingIgniteSql.java | 177 +++++++++
.../internal/sql/api/StatementBuilderImpl.java | 20 --
.../ignite/internal/sql/api/StatementImpl.java | 7 -
.../ignite/internal/sql/engine/QueryProcessor.java | 32 +-
.../internal/sql/engine/SqlQueryProcessor.java | 111 +++---
.../sql/engine/exec/DestinationFactory.java | 4 +-
.../engine/exec/RehashingPartitionExtractor.java | 4 +
.../sql/engine/exec/ddl/DdlCommandHandler.java | 9 +
.../exec/ddl/DdlToCatalogCommandConverter.java | 20 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 196 ++++++++--
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 70 ++++
.../sql/engine/exec/exp/RexToLixTranslator.java | 24 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 16 +-
.../engine/metadata/IgniteMdDistinctRowCount.java | 30 +-
.../sql/engine/metadata/IgniteMdSelectivity.java | 38 --
.../sql/engine/metadata/cost/IgniteCost.java | 9 +
.../internal/sql/engine/prepare/IgnitePlanner.java | 2 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 4 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 13 +-
.../prepare/ddl/AlterZoneSetDefaultCommand.java} | 20 +-
.../sql/engine/prepare/ddl/CreateTableCommand.java | 17 +
.../sql/engine/prepare/ddl/CreateZoneCommand.java | 43 +--
.../prepare/ddl/DdlSqlToCommandConverter.java | 274 ++++++--------
.../sql/engine/prepare/ddl/TableOptionEnum.java} | 12 +-
.../sql/engine/prepare/ddl/ZoneOptionEnum.java | 4 +-
.../internal/sql/engine/rel/AbstractIndexScan.java | 9 +-
.../internal/sql/engine/rel/IgniteAggregate.java | 22 +-
.../internal/sql/engine/rel/IgniteProject.java | 10 +-
.../engine/rel/agg/IgniteSortAggregateBase.java | 56 ++-
.../engine/rule/HashAggregateConverterRule.java | 4 +-
.../sql/engine/rule/SetOpConverterRule.java | 5 +
.../sql/engine/rule/UnionConverterRule.java | 8 +-
.../engine/rule/logical/LogicalOrToUnionRule.java | 7 +-
.../engine/sql/IgniteSqlAlterZoneSetDefault.java | 67 ++++
.../sql/engine/sql/IgniteSqlCreateZone.java | 25 +-
.../internal/sql/engine/sql/ParserServiceImpl.java | 27 --
.../sql/engine/trait/DistributionFunction.java | 2 +-
.../internal/sql/engine/trait/TraitUtils.java | 8 +-
.../sql/engine/type/IgniteTypeFactory.java | 2 +-
.../ignite/internal/sql/engine/util/Commons.java | 77 ++++
.../internal/sql/engine/util/IgniteMethod.java | 12 +
.../ignite/internal/sql/engine/util/RexUtils.java | 258 +++++++++++--
.../ignite/internal/sql/api/IgniteSqlImplTest.java | 20 +-
.../engine/QueryTransactionWrapperSelfTest.java | 6 +-
.../engine/benchmarks/TpchPrepareBenchmark.java | 3 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 2 +-
.../sql/engine/exec/TransactionEnlistTest.java | 13 +-
.../DdlCommandHandlerExceptionHandlingTest.java | 2 +
.../ddl/DistributionZoneDdlCommandHandlerTest.java | 2 +
.../engine/exec/exp/ExpressionFactoryImplTest.java | 259 +++++++++++++-
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 17 +
.../sql/engine/exec/rel/AbstractExecutionTest.java | 10 +-
.../sql/engine/exec/rel/ExecutionTest.java | 5 +-
.../exec/rel/TableScanNodeExecutionTest.java | 13 +-
.../sql/engine/framework/TestBuilders.java | 89 +++--
.../sql/engine/framework/TestClusterTest.java | 14 +
.../planner/AbstractAggregatePlannerTest.java | 58 ++-
.../sql/engine/planner/AbstractPlannerTest.java | 62 +++-
.../sql/engine/planner/AggregatePlannerTest.java | 323 +++++++++++------
.../planner/ColocatedHashAggregatePlannerTest.java | 91 ++++-
.../planner/ColocatedSortAggregatePlannerTest.java | 80 +++++
.../planner/CorrelatedSubqueryPlannerTest.java | 2 +-
.../sql/engine/planner/DmlPlannerTest.java | 2 +-
.../planner/IndexSearchBoundsPlannerTest.java | 35 +-
.../planner/MapReduceHashAggregatePlannerTest.java | 177 +++++++--
.../planner/MapReduceSortAggregatePlannerTest.java | 127 +++++--
.../internal/sql/engine/planner/PlannerTest.java | 58 +++
.../sql/engine/planner/PlannerTimeoutTest.java | 3 +-
.../sql/engine/planner/SetOpPlannerTest.java | 71 ++++
.../sql/engine/planner/TpchQueryPlannerTest.java | 121 +++++++
.../sql/engine/planner/UnionPlannerTest.java | 70 ++++
.../sql/engine/prepare/PrepareServiceImplTest.java | 3 +-
.../ddl/AbstractDdlSqlToCommandConverterTest.java | 3 +-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 97 +++--
.../DistributionZoneSqlToCommandConverterTest.java | 67 +++-
.../engine/schema/SqlSchemaManagerImplTest.java | 12 +-
.../sql/engine/sql/ParserServiceImplTest.java | 143 +-------
.../internal/sql/engine/sql/SqlDdlParserTest.java | 37 +-
.../internal/sql/engine/util/CommonsTest.java | 68 +++-
.../internal/sql/engine/util/QueryCheckerTest.java | 13 +-
.../sql/metrics/PlanningCacheMetricsTest.java | 3 +-
...apache.ignite.configuration.ConfigurationModule | 1 -
.../src/test/resources/mapping/correlated.test | 15 +-
.../resources/mapping/test_partition_pruning.test | 10 +-
.../src/test/resources/mapping/union.test | 50 +--
.../src/test/resources/tpch/plan/q1.plan | 7 +
.../internal/sql/engine/util/QueryCheckerImpl.java | 5 +-
.../internal/sql/engine/util/tpch/TpchTables.java | 168 ++++++++-
.../resources/tpch/ddl/lineitem_ddl.sql | 2 -
.../resources/tpch/ddl/partsupp_ddl.sql | 1 -
modules/storage-api/README.md | 2 +-
modules/storage-api/build.gradle | 3 -
.../internal/storage/DataStorageManager.java | 89 ++---
.../ignite/internal/storage/DataStorageModule.java | 9 +-
.../internal/storage/DataStorageModules.java | 95 +----
.../storage/StorageDestroyedException.java | 8 +
.../storage/ThreadAssertingMvPartitionStorage.java | 8 +-
.../StorageConfigurationModule.java} | 10 +-
.../StorageConfigurationSchema.java} | 24 +-
.../StorageEngineConfigurationSchema.java} | 10 +-
.../StorageProfileConfigurationSchema.java} | 19 +-
.../storage/engine/StorageTableDescriptor.java | 14 +-
.../storage/index/BinaryTupleComparator.java | 6 +-
.../storage/index/ThreadAssertingIndexStorage.java | 8 +-
.../ignite/internal/storage/util/StorageUtils.java | 34 +-
.../internal/storage/DataStorageManagerTest.java | 157 --------
.../internal/storage/DataStorageModulesTest.java | 106 +-----
.../storage/index/BinaryTupleComparatorTest.java | 4 +-
.../storage/index/TestHashIndexStorageTest.java | 4 +-
.../storage/index/TestSortedIndexStorageTest.java | 4 +-
...apache.ignite.configuration.ConfigurationModule | 1 -
.../storage/AbstractMvPartitionStorageTest.java | 2 +-
.../storage/AbstractMvTableStorageTest.java | 4 +-
.../storage/engine/AbstractStorageEngineTest.java | 33 +-
.../storage/impl/TestDataStorageModule.java | 4 +-
.../impl/TestStorageLocalConfigurationModule.java | 4 +-
...ma.java => TestProfileConfigurationSchema.java} | 11 +-
.../storage/index/AbstractIndexStorageTest.java | 6 +-
.../index/AbstractSortedIndexStorageTest.java | 39 +-
.../index/impl/AbstractTestIndexStorage.java | 24 +-
.../storage/index/impl/TestHashIndexStorage.java | 4 +-
.../internal/storage/index/impl/TestIndexRow.java | 59 ++-
.../storage/index/impl/TestSortedIndexStorage.java | 10 +-
.../pagememory/PersistentPageMemoryDataRegion.java | 26 +-
.../PersistentPageMemoryDataStorageModule.java | 18 +-
.../PersistentPageMemoryStorageEngine.java | 45 +--
.../pagememory/VolatilePageMemoryDataRegion.java | 6 +-
.../VolatilePageMemoryDataStorageModule.java | 15 +-
.../VolatilePageMemoryStorageEngine.java | 40 +--
.../configuration/PageMemoryDataRegionName.java | 34 --
.../PageMemoryDataRegionValidatorImpl.java | 93 -----
...emoryStorageEngineLocalConfigurationModule.java | 38 +-
...PageMemoryStorageEngineConfigurationSchema.java | 41 ---
...ntPageMemoryDataStorageConfigurationSchema.java | 38 --
...PageMemoryStorageEngineConfigurationSchema.java | 33 +-
...StorageEngineExtensionConfigurationSchema.java} | 19 +-
...lePageMemoryDataStorageConfigurationSchema.java | 38 --
...PageMemoryStorageEngineConfigurationSchema.java | 35 +-
...StorageEngineExtensionConfigurationSchema.java} | 19 +-
.../index/AbstractPageMemoryIndexStorage.java | 55 ++-
.../index/hash/PageMemoryHashIndexStorage.java | 6 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 8 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 2 -
.../PersistentPageMemoryDataRegionTest.java | 46 ++-
.../PersistentPageMemoryMvTableStorageTest.java | 21 +-
.../VolatilePageMemoryMvTableStorageTest.java | 11 +-
.../PageMemoryDataRegionValidatorImplTest.java | 178 ---------
...yStorageEngineLocalConfigurationModuleTest.java | 74 ++++
.../PersistentPageMemoryStorageEngineTest.java | 10 +-
.../AbstractPageMemoryHashIndexStorageTest.java | 11 +-
.../AbstractPageMemorySortedIndexStorageTest.java | 9 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 23 +-
...PersistentPageMemorySortedIndexStorageTest.java | 17 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 14 +-
.../VolatilePageMemorySortedIndexStorageTest.java | 14 +-
.../storage/pagememory/mv/BlobStorageTest.java | 13 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 21 +-
...rsistentPageMemoryMvPartitionStorageGcTest.java | 21 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 20 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 11 +-
...VolatilePageMemoryMvPartitionStorageGcTest.java | 12 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 11 +-
.../ignite/internal/storage/rocksdb/HashIndex.java | 13 +-
.../ignite/internal/storage/rocksdb/Index.java | 24 +-
.../storage/rocksdb/RocksDbDataRegion.java | 39 +-
.../storage/rocksdb/RocksDbDataStorageModule.java | 14 +-
.../internal/storage/rocksdb/RocksDbIndexes.java | 53 +--
.../storage/rocksdb/RocksDbMetaStorage.java | 22 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 4 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 123 ++++---
.../storage/rocksdb/RocksDbTableStorage.java | 29 +-
.../internal/storage/rocksdb/SortedIndex.java | 19 +-
.../RocksDbDataRegionValidatorImpl.java | 56 ---
...cksDbStorageEngineLocalConfigurationModule.java | 24 +-
...java => RocksDbProfileConfigurationSchema.java} | 24 +-
.../RocksDbStorageEngineConfigurationSchema.java | 23 +-
...StorageEngineExtensionConfigurationSchema.java} | 18 +-
.../rocksdb/index/AbstractRocksDbIndexStorage.java | 48 ++-
.../rocksdb/index/RocksDbHashIndexStorage.java | 8 +-
.../rocksdb/index/RocksDbSortedIndexStorage.java | 16 +-
.../rocksdb/instance/IndexColumnFamily.java} | 32 +-
.../rocksdb/instance/SharedRocksDbInstance.java | 146 ++++++--
.../instance/SharedRocksDbInstanceCreator.java | 1 +
.../RocksDbMvPartitionStorageConcurrencyTest.java | 13 +-
.../rocksdb/RocksDbMvPartitionStorageGcTest.java | 13 +-
.../rocksdb/RocksDbMvPartitionStorageTest.java | 13 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 14 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 45 +--
.../RocksDbDataRegionValidatorImplTest.java | 107 ------
.../rocksdb/engine/RocksDbStorageEngineTest.java | 15 +-
.../rocksdb/index/RocksDbHashIndexStorageTest.java | 13 +-
.../index/RocksDbSortedIndexStorageTest.java | 13 +-
.../instance/SharedRocksDbInstanceTest.java | 136 ++++++-
...apache.ignite.configuration.ConfigurationModule | 1 -
.../internal/systemview/SystemViewManagerTest.java | 6 +-
modules/table/build.gradle | 7 +
.../apache/ignite/distributed/ItLockTableTest.java | 16 +-
.../ItTxDistributedCleanupRecoveryTest.java | 3 +-
...xDistributedTestSingleNodeNoCleanupMessage.java | 12 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 7 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 17 +-
.../ItDisasterRecoveryReconfigurationTest.java | 67 +++-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 21 +-
.../rebalance/ItRebalanceDistributedTest.java | 84 +++--
.../rebalance/ItRebalanceRecoveryTest.java | 10 +-
.../ignite/internal/rebalance/ItRebalanceTest.java | 4 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 16 +-
.../ignite/internal/table/ItColocationTest.java | 13 +-
.../internal/table/ItOperationRetryTest.java | 6 +-
.../table/ItTransactionPrimaryChangeTest.java | 221 ++++++++++++
.../internal/table/ItTransactionRecoveryTest.java | 57 +--
.../threading/ItKvRecordApiThreadingTest.java | 162 ++++-----
.../threading/ItTablesApiThreadingTest.java | 95 +++++
...apache.ignite.configuration.ConfigurationModule | 1 -
.../internal/table/AbstractRowTupleAdapter.java | 66 ++--
.../ignite/internal/table/AbstractTableView.java | 56 +--
.../apache/ignite/internal/table/DataStreamer.java | 11 +-
.../ignite/internal/table/InternalTable.java | 8 +
.../internal/table/KeyValueBinaryViewImpl.java | 45 ++-
.../ignite/internal/table/KeyValueViewImpl.java | 55 ++-
.../table/PublicApiThreadingKeyValueView.java | 244 +++++++++++++
.../table/PublicApiThreadingRecordView.java | 218 +++++++++++
.../internal/table/PublicApiThreadingViewBase.java | 91 +++++
.../internal/table/RecordBinaryViewImpl.java | 49 ++-
.../ignite/internal/table/RecordViewImpl.java | 74 ++--
.../apache/ignite/internal/table/TableImpl.java | 20 +-
.../CatalogStorageIndexDescriptorSupplier.java | 1 +
.../internal/table/distributed/IndexLocker.java | 5 +-
.../PartitionReplicatorNodeRecovery.java | 2 +-
.../PublicApiThreadingIgniteTables.java | 94 +++++
.../table/distributed/PublicApiThreadingTable.java | 80 +++++
.../table/distributed/SortedIndexLocker.java | 9 +-
.../internal/table/distributed/TableManager.java | 93 +++--
.../table/distributed/TableMessageGroup.java | 26 +-
.../table/distributed/command/FinishTxCommand.java | 6 +
.../distributed/command/UpdateAllCommand.java | 5 +
.../table/distributed/command/UpdateCommand.java | 3 +
.../disaster/DisasterRecoveryManager.java | 392 ++++++++++++++++++++
.../disaster/DisasterRecoveryRequest.java | 7 +-
.../disaster/LocalPartitionStateEnum.java} | 36 +-
.../disaster/ManualGroupUpdateRequest.java | 10 +-
.../messages/LocalPartitionState.java} | 24 +-
.../messages/LocalPartitionStatesRequest.java} | 15 +-
.../messages/LocalPartitionStatesResponse.java} | 14 +-
.../ignite/internal/table/distributed/gc/MvGc.java | 2 +-
.../table/distributed/raft/PartitionListener.java | 64 +++-
.../snapshot/FullStateTransferIndexChooser.java | 2 +-
.../raft/snapshot/PartitionAccessImpl.java | 2 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 15 +-
.../raft/snapshot/outgoing/SnapshotMetaUtils.java | 2 +-
.../request/SingleRowReplicaRequest.java | 2 +
.../replicator/PartitionReplicaListener.java | 314 +++++++++++-----
.../replicator/TransactionStateResolver.java | 5 +-
.../distributed/storage/InternalTableImpl.java | 37 +-
.../table/KeyValueBinaryViewOperationsTest.java | 4 +-
.../internal/table/KeyValueViewOperationsTest.java | 2 -
.../table/RecordBinaryViewOperationsTest.java | 4 +-
.../internal/table/RecordViewOperationsTest.java | 2 -
.../CatalogStorageIndexDescriptorSupplierTest.java | 41 +--
.../table/distributed/SortedIndexLockerTest.java | 68 ++++
.../distributed/TableManagerRecoveryTest.java | 42 ++-
.../table/distributed/TableManagerTest.java | 51 ++-
.../PartitionRaftCommandsSerializationTest.java | 2 +
.../PersistentPageMemoryGcUpdateHandlerTest.java | 14 +-
.../distributed/gc/RocksDbGcUpdateHandlerTest.java | 12 +-
.../gc/VolatilePageMemoryGcUpdateHandlerTest.java | 12 +-
.../raft/PartitionCommandListenerTest.java | 36 +-
.../FullStateTransferIndexChooserTest.java | 2 +-
.../raft/snapshot/PartitionAccessImplTest.java | 2 +-
.../incoming/IncomingSnapshotCopierTest.java | 13 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 8 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 7 +-
.../PartitionReplicaListenerIndexLockingTest.java | 4 +-
.../replication/PartitionReplicaListenerTest.java | 38 +-
.../SchemaCompatibilityValidatorTest.java | 2 +-
.../schema/CatalogValidationSchemasSourceTest.java | 6 +-
.../PartitionCommandsMarshallerImplTest.java | 2 +
.../distributed/storage/InternalTableImplTest.java | 6 +-
.../table/type/NumericTypesSerializerTest.java | 38 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 48 ++-
.../ignite/internal/table/TxAbstractTest.java | 7 +-
.../table/impl/DummyInternalTableImpl.java | 15 +-
modules/transactions/build.gradle | 2 +
.../tx/ItTransactionsApiThreadingTest.java | 169 +++++++++
.../org/apache/ignite/internal/tx/TxManager.java | 35 +-
.../java/org/apache/ignite/internal/tx/TxMeta.java | 17 +-
.../org/apache/ignite/internal/tx/TxStateMeta.java | 49 ++-
.../ignite/internal/tx/UpdateCommandResult.java | 100 ++++++
.../TransactionConfigurationSchema.java | 5 +
.../ignite/internal/tx/impl/OrphanDetector.java | 3 +-
.../internal/tx/impl/PlacementDriverHelper.java | 45 ++-
.../impl/PublicApiThreadingIgniteTransactions.java | 67 ++++
.../tx/impl/PublicApiThreadingTransaction.java | 133 +++++++
.../internal/tx/impl/ReadWriteTransactionImpl.java | 2 +-
.../internal/tx/impl/TransactionInflights.java | 4 +-
.../internal/tx/impl/TxCleanupRequestHandler.java | 106 +++++-
.../internal/tx/impl/TxCleanupRequestSender.java | 114 +++++-
.../ignite/internal/tx/impl/TxManagerImpl.java | 136 ++++---
.../ignite/internal/tx/impl/TxMessageSender.java | 44 ++-
.../tx/impl/VolatileTxStateMetaStorage.java | 2 +-
.../tx/impl/WriteIntentSwitchProcessor.java | 9 +-
...ageResponse.java => CleanupReplicatedInfo.java} | 30 +-
.../tx/message/TxCleanupMessageResponse.java | 6 +
...Response.java => TxCleanupRecoveryRequest.java} | 9 +-
.../ignite/internal/tx/message/TxMessageGroup.java | 5 +
.../message/WriteIntentSwitchReplicatedInfo.java} | 40 ++-
.../state/ThreadAssertingTxStateStorage.java | 18 +-
.../internal/tx/storage/state/TxStateStorage.java | 16 +
.../state/rocksdb/TxStateRocksDbSharedStorage.java | 9 +
.../state/rocksdb/TxStateRocksDbStorage.java | 107 ++++--
.../apache/ignite/internal/tx/TxCleanupTest.java | 35 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 22 +-
.../state/rocksdb/RocksDbTxStateStorageTest.java | 4 +-
...apache.ignite.configuration.ConfigurationModule | 1 -
.../storage/state/AbstractTxStateStorageTest.java | 82 +++--
.../tx/storage/state/test/TestTxStateStorage.java | 22 ++
modules/workers/build.gradle | 1 +
.../ignite/internal/worker/ThreadAssertions.java | 41 +--
.../internal/worker/ThreadAssertionsTest.java | 95 +++++
settings.gradle | 2 +
880 files changed, 22579 insertions(+), 8530 deletions(-)
delete mode 100644
modules/api/src/main/java/org/apache/ignite/sql/reactive/ReactiveResultSet.java
delete mode 100644
modules/arch-test/src/test/java/org/apache/ignite/internal/ConfigurationModuleArchTest.java
copy modules/{platforms/dotnet/Apache.Ignite.Tests/Table/Poco.cs =>
catalog/src/main/java/org/apache/ignite/internal/catalog/CatalogVersionAwareValidationException.java}
(57%)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/AlterZoneSetDefaultCatalogCommand.java
rename
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/{DataStorageParams.java
=> StorageProfileParams.java} (50%)
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogDataStorageDescriptor.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogStorageProfileDescriptor.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogStorageProfilesDescriptor.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/RenameIndexEntry.java
delete mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/descriptors/CatalogDataStorageDescriptorTest.java
delete mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/ItConfigCommandTest.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/cluster/config/ConfigUpdateCommandTest.java
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/threading/ItComputeApiThreadingTest.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/AntiHijackIgniteCompute.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/AntiHijackJobExecution.java
rename modules/configuration/src/{test =>
testFixtures}/java/org/apache/ignite/internal/configuration/ConfigurationTestUtils.java
(100%)
copy modules/{platforms/dotnet/Apache.Ignite/Internal/Network/ClusterNode.cs
=> core/src/main/java/org/apache/ignite/internal/components/LogSyncer.java}
(71%)
copy
modules/{eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/EventLog.java
=>
core/src/main/java/org/apache/ignite/internal/replicator/ReplicatorConstants.java}
(72%)
copy
modules/{eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/IgniteEventTypes.java
=> core/src/main/java/org/apache/ignite/internal/wrapper/Wrapper.java} (65%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/wrapper/Wrappers.java
rename
modules/distribution-zones/src/integrationTest/java/org/apache/ignite/internal/distributionzones/{ItDistributionZonesFilterTest.java
=> ItDistributionZonesFiltersTest.java} (86%)
delete mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/disaster/DisasterRecoveryManager.java
rename
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/{DistributionZoneFiltersTest.java
=> DistributionZoneAttributeFiltersTest.java} (79%)
copy
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/{DistributionZoneManagerFilterTest.java
=> DistributionZoneManagerStorageProfilesFilterTest.java} (71%)
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/DistributionZoneStorageProfilesFilterTest.java
create mode 100644 modules/eventlog/README.MD
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/ItEventLogConfigurationValidationTest.java
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/ItLogSinkConfigurationValidationTest.java
copy
modules/{metastorage/src/test/java/org/apache/ignite/internal/metastorage/impl/MetaStorageRocksDbRangeTest.java
=>
eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/impl/InMemoryCollectionSink.java}
(60%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage/DataStorageConfigurationSchema.java
=>
eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/impl/InMemoryCollectionSinkConfigurationSchema.java}
(68%)
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/impl/ItEventLogConfigurationTest.java
copy
modules/eventlog/src/{main/java/org/apache/ignite/internal/eventlog/api/EventLog.java
=>
integrationTest/java/org/apache/ignite/internal/eventlog/impl/TestEventTypes.java}
(69%)
copy
modules/{runner/src/integrationTest/java/org/apache/ignite/internal/streamer/ItServerDataStreamerTest.java
=>
eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/impl/TestSinkFactory.java}
(56%)
copy
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/{EventLog.java
=> EventChannel.java} (64%)
copy
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/{event/IgniteEventTypes.java
=> api/IgniteEventType.java} (58%)
rename
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/{event =>
api}/IgniteEvents.java (80%)
copy
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/{EventFactory.java
=> Sink.java} (53%)
rename
modules/{storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestPersistStorageConfigurationModule.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/EventLogConfigurationModule.java}
(61%)
rename
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/StorageProfileConfigurationSchema.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/ChannelConfigurationSchema.java}
(66%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/StorageProfilesConfigurationSchema.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/EventLogConfigurationSchema.java}
(70%)
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/EventTypeValidatorImpl.java
rename
modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/RocksDbDataStorageConfigurationSchema.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/LogSinkConfigurationSchema.java}
(52%)
rename
modules/{storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestPersistStorageConfigurationSchema.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/SinkConfigurationSchema.java}
(58%)
rename
modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/RocksDbDataRegionName.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/ValidEventType.java}
(75%)
copy modules/{platforms/dotnet/Apache.Ignite.Tests/Table/Poco.cs =>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/ChannelFactory.java}
(65%)
copy
modules/{storage-api/src/main/java/org/apache/ignite/internal/storage/StorageDestroyedException.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/ChannelRegistry.java}
(53%)
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/ConfigurationBasedChannelRegistry.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/ConfigurationBasedSinkRegistry.java
copy
modules/{raft/src/main/java/org/apache/ignite/internal/raft/storage/impl/LocalLogStorageFactory.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/EventChannelImpl.java}
(52%)
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/EventLogImpl.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/LogSink.java
copy
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/{event/exception/MissingEventTypeException.java
=> impl/SinkFactory.java} (52%)
copy modules/{api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java =>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/SinkRegistry.java}
(77%)
rename
modules/{api/src/main/java/org/apache/ignite/sql/reactive/package-info.java =>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/ser/EventSerializer.java}
(78%)
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/ser/JsonEventSerializer.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/impl/ConfigurationBasedChannelRegistryTest.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/impl/ConfigurationBasedSinkRegistryTest.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/impl/EventLogTest.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/impl/LogSinkTest.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/ser/JsonEventSerializerTest.java
copy
modules/{storage-api/src/main/java/org/apache/ignite/internal/storage/StorageDestroyedException.java
=>
failure-handler/src/testFixtures/java/org/apache/ignite/internal/failure/NoOpFailureProcessor.java}
(57%)
mode change 100644 => 100755
create mode 100644
modules/index/src/integrationTest/java/org/apache/ignite/internal/index/ItIndexAndIndexStorageDestructionTest.java
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/jdbc/ItJdbcClientTimeZoneTest.java
create mode 100644 modules/low-watermark/README.md
copy modules/{workers => low-watermark}/build.gradle (66%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark}/LowWatermark.java
(67%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark}/LowWatermarkCandidate.java
(96%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark}/LowWatermarkChangedListener.java
(95%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark}/LowWatermarkImpl.java
(75%)
copy modules/{table/src/main/java/org/apache/ignite/internal/table/distributed
=>
low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark}/message/GetLowWatermarkRequest.java
(82%)
copy modules/{table/src/main/java/org/apache/ignite/internal/table/distributed
=>
low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark}/message/GetLowWatermarkResponse.java
(85%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage/DataStorageConfigurationSchema.java
=>
low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/message/LowWatermarkMessageGroup.java}
(62%)
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed =>
low-watermark/src/test/java/org/apache/ignite/internal/lowwatermark}/LowWatermarkImplTest.java
(79%)
rename modules/{table/src/testFixtures/java/org/apache/ignite/internal/table
=>
low-watermark/src/testFixtures/java/org/apache/ignite/internal/lowwatermark}/TestLowWatermark.java
(96%)
rename
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/{PersistentPageMemoryDataRegionConfigurationSchema.java
=> PersistentPageMemoryProfileConfigurationSchema.java} (77%)
rename
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/{VolatilePageMemoryDataRegionConfigurationSchema.java
=> VolatilePageMemoryProfileConfigurationSchema.java} (81%)
delete mode 100644
modules/placement-driver/src/integrationTest/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
create mode 100644
modules/platforms/cpp/ignite/client/compute/job_execution.cpp
create mode 100644 modules/platforms/cpp/ignite/client/compute/job_execution.h
create mode 100644
modules/platforms/cpp/ignite/client/compute/job_execution_options.h
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage/DataStorageConfigurationSchema.java
=> platforms/cpp/ignite/client/compute/job_state.h} (59%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage/DataStorageConfigurationSchema.java
=> platforms/cpp/ignite/client/compute/job_status.h} (57%)
create mode 100644
modules/platforms/cpp/ignite/client/detail/compute/job_execution_impl.cpp
create mode 100644
modules/platforms/cpp/ignite/client/detail/compute/job_execution_impl.h
create mode 100644 modules/platforms/cpp/ignite/client/detail/utils_test.cpp
create mode 100644
modules/platforms/cpp/tests/client-test/column_order_test.cpp
copy modules/platforms/dotnet/{Apache.Ignite.Tests/Table/Poco.cs =>
Apache.Ignite/Internal/ClientSocket.Metrics.cs} (55%)
copy
modules/{eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/EventLog.java
=> platforms/dotnet/Apache.Ignite/Internal/MetricsContext.cs} (67%)
copy modules/platforms/dotnet/{Apache.Ignite.Tests/Table/Poco.cs =>
Apache.Ignite/MetricTags.cs} (60%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Table/DataStreamerItem.cs
copy modules/platforms/dotnet/Apache.Ignite/{Internal/Network/ClusterNode.cs
=> Table/DataStreamerOperationType.cs} (77%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/message/GetLowWatermarkResponse.java
=>
replicator/src/main/java/org/apache/ignite/internal/replicator/message/PrimaryReplicaChangeCommand.java}
(63%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/SqlIndexScanBenchmark.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItCustomKeyColumnOrderClientTest.java
rename
modules/{eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/IgniteEventTypes.java
=>
runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItCustomKeyColumnOrderEmbeddedTest.java}
(71%)
create mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/PublicApiThreadingTests.java
copy
modules/{eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/EventLog.java
=>
runner/src/testFixtures/java/org/apache/ignite/internal/TestDefaultProfilesNames.java}
(68%)
create mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/TestWrappers.java
create mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/BinaryRowConverterTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/api/ItKvKeyColumnPositionTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/api/ItRecordViewKeyPositionsTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSecondaryIndexMultiRangeScanTest.java
rename
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/{ItKeyValueGetTest.java
=> ItSqlUsesKeyValueGetTest.java} (98%)
rename
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/{ItKeyValuePutTest.java
=> ItSqlUsesKeyValuePutTest.java} (98%)
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/threading/ItSqlApiThreadingTest.java
create mode 100644
modules/sql-engine/src/integrationTest/sql/aggregate/group/test_group_by_distinct.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/aggregate/group/test_group_by_not_in_select.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/contstraint/test_not_null_contraint.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/types/date/date_parsing.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/types/date/test_date.test
rename
modules/sql-engine/src/integrationTest/sql/types/time/{test_time.test_ignore =>
test_time.test} (61%)
create mode 100644
modules/sql-engine/src/integrationTest/sql/types/time/time_parsing.test
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AntiHijackAsyncResultSet.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/PublicApiThreadingIgniteSql.java
copy
modules/{eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/EventLog.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/AlterZoneSetDefaultCommand.java}
(66%)
copy modules/{api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java =>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/TableOptionEnum.java}
(76%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlAlterZoneSetDefault.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/TpchQueryPlannerTest.java
delete mode 100644
modules/sql-engine/src/test/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
create mode 100644 modules/sql-engine/src/test/resources/tpch/plan/q1.plan
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/ClusterManagementConfigurationModule.java
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageConfigurationModule.java}
(79%)
rename
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/StorageProfilesConfigurationSchema.java
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageConfigurationSchema.java}
(62%)
rename modules/{api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java =>
storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageEngineConfigurationSchema.java}
(79%)
rename
modules/{schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage/DataStorageConfigurationSchema.java
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageProfileConfigurationSchema.java}
(74%)
delete mode 100644
modules/storage-api/src/test/java/org/apache/ignite/internal/storage/DataStorageManagerTest.java
delete mode 100644
modules/storage-api/src/test/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
rename
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/schema/{TestDataStorageConfigurationSchema.java
=> TestProfileConfigurationSchema.java} (73%)
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/PageMemoryDataRegionName.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/PageMemoryDataRegionValidatorImpl.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/BasePageMemoryStorageEngineConfigurationSchema.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/PersistentPageMemoryDataStorageConfigurationSchema.java
copy
modules/{page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/BasePageMemoryDataRegionConfigurationSchema.java
=>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/PersistentPageMemoryStorageEngineExtensionConfigurationSchema.java}
(62%)
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/VolatilePageMemoryDataStorageConfigurationSchema.java
copy
modules/{page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/BasePageMemoryDataRegionConfigurationSchema.java
=>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/VolatilePageMemoryStorageEngineExtensionConfigurationSchema.java}
(62%)
delete mode 100644
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/configuration/PageMemoryDataRegionValidatorImplTest.java
create mode 100644
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/configuration/PageMemoryStorageEngineLocalConfigurationModuleTest.java
delete mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/RocksDbDataRegionValidatorImpl.java
rename
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/{RocksDbDataRegionConfigurationSchema.java
=> RocksDbProfileConfigurationSchema.java} (67%)
rename
modules/{page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/BasePageMemoryDataRegionConfigurationSchema.java
=>
storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/RocksDbStorageEngineExtensionConfigurationSchema.java}
(62%)
copy modules/{platforms/dotnet/Apache.Ignite.Tests/Table/Poco.cs =>
storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/instance/IndexColumnFamily.java}
(58%)
delete mode 100644
modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/configuration/RocksDbDataRegionValidatorImplTest.java
delete mode 100644
modules/storage-rocksdb/src/test/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItTransactionPrimaryChangeTest.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/threading/ItTablesApiThreadingTest.java
delete mode 100644
modules/table/src/integrationTest/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/PublicApiThreadingKeyValueView.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/PublicApiThreadingRecordView.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/PublicApiThreadingViewBase.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/PublicApiThreadingIgniteTables.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/PublicApiThreadingTable.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/DisasterRecoveryManager.java
rename
modules/{distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones
=>
table/src/main/java/org/apache/ignite/internal/table/distributed}/disaster/DisasterRecoveryRequest.java
(86%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/ZoneOptionEnum.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/LocalPartitionStateEnum.java}
(53%)
rename
modules/{distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones
=>
table/src/main/java/org/apache/ignite/internal/table/distributed}/disaster/ManualGroupUpdateRequest.java
(92%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{message/GetLowWatermarkRequest.java
=> disaster/messages/LocalPartitionState.java} (54%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{message/GetLowWatermarkRequest.java
=> disaster/messages/LocalPartitionStatesRequest.java} (73%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{message/GetLowWatermarkRequest.java
=> disaster/messages/LocalPartitionStatesResponse.java} (72%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/SortedIndexLockerTest.java
create mode 100644
modules/transactions/src/integrationTest/java/org/apache/ignite/internal/tx/ItTransactionsApiThreadingTest.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/UpdateCommandResult.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/PublicApiThreadingIgniteTransactions.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/PublicApiThreadingTransaction.java
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{TxCleanupMessageResponse.java
=> CleanupReplicatedInfo.java} (54%)
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{TxCleanupMessageResponse.java
=> TxCleanupRecoveryRequest.java} (75%)
copy
modules/{sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/datatypes/uuid/ItUuidIndexTest.java
=>
transactions/src/main/java/org/apache/ignite/internal/tx/message/WriteIntentSwitchReplicatedInfo.java}
(50%)
delete mode 100644
modules/transactions/src/test/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
create mode 100644
modules/workers/src/test/java/org/apache/ignite/internal/worker/ThreadAssertionsTest.java
