This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/com.github.johnrengelman.shadow-8.1.1
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 77a6dd85e1 Bump com.github.johnrengelman.shadow from 7.1.2 to 8.1.1
add 7818239ed7 IGNITE-21729 Prevent threads from being hijacked via async
cursors in KV/Record view APIs (#3393)
add c7f57ee45e Bump org.junit-pioneer:junit-pioneer from 2.0.1 to 2.2.0
(#3394)
add 4506ebafd7 IGNITE-19744 Clean up IEP-54 leftovers (#2203)
add 02f5682181 IGNITE-21641 Fixed OOM in PartitionReplicaListenerTest
(#3357)
add 1fd9027cd1 Bump io.gsonfire:gson-fire from 1.8.5 to 1.9.0 (#3396)
add 3225241bb7 IGNITE-21552 Sql. Add hybrid timestamp propagation during
query execution (#3350)
add 92344a0a2c IGNITE-21742 Refactor creation and management of Page
Memory Indexes (#3406)
add 0bd6670724 IGNITE-21569 Introduce spotbugs checks for additional code
static analysis (#3373)
add c2b1c09b86 IGNITE-18258 .NET: LINQ: Clean up inlineConstArgs logic
(#3408)
add 5a0369a75f IGNITE-21311: Introduce pruning for SQL correlated scans
(#3318)
add b60daf24f3 IGNITE-21724 Support "-ea" version suffix in
ItInitializedClusterRestTest (#3391)
add 5a288a5351 Bump com.esotericsoftware:kryo from 4.0.1 to 5.6.0 (#3402)
add cfda840a37 Bump jackson from 2.16.1 to 2.17.0 (#3410)
add 3dea2b18a8 IGNITE-21749 Add assertions for destroyed/closed storages
behavior (#3409)
add 65fd2caf88 IGNITE-19976: Sql. ClassCastException when trying to select
from indexed smallint column (#3377)
add f773e0ea76 IGNITE-21752 Improve excludes for generated rest client
(#3412)
add 34b536a6bd IGNITE-21671 Remove destroyed PageMemory indexes on
recovery (#3399)
add 38d3c20693 IGNITE-21578 Improve tests readability and logic in
ItDurableFinishTest. (#3400)
add 14eecd4953 IGNITE-21088 Fix node restart with json config (#3376)
add 2c5482cfb1 IGNITE-21452: add fail handler to query task execution
(#3264)
add c2ec9c94e7 IGNITE-21428 Add WITH params for zone (#3374)
add 960f55fa72 IGNITE-21650 Extend PMD ruleset to cover performance and
multithreading issues (#3416)
add 1813f267ad Bump com.jakewharton.fliptables:fliptables from 1.1.0 to
1.1.1 (#3395)
add 51c6b43cc1 Bump com.google.guava:guava from 33.0.0-jre to 33.1.0-jre
(#3419)
add fb93b45862 Bump io.freefair.aggregate-javadoc from 6.5.1 to 6.6.3
(#3418)
add 3519740158 IGNITE-21719 Add optional syntax highlight and multiline
SQL. (#3390)
add 455d59fd20 IGNITE-21750 Throw a special exception when trying to read
from/write to a destroyed IndexStorage (#3415)
add f8b0785561 IGNITE-20870 Explain why snapshots lock is not taken in
PartitionReplicaListener (#3385)
add 296dab0238 IGNITE-21688 Remove modernizer from build checks (#3421)
add a2cdcda807 IGNITE-21348 Trigger the lease negotiation retry in case
when the lease candidate is no more contained in assignments (#3401)
add 52af924913 IGNITE-21634 Fixed NPE in HeapLockManager (#3375)
add 27aeb5788d IGNITE-21748 Rename
DataStreamerOptions.perNodeParallelOperations to perPartitionParallelOperations
(#3420)
add c52bbfb6bd IGNITE-21381 ActiveActorTest#testChangeLeaderForce is flaky
(#3150)
add aa5de0893c IGNITE-21353 Sql. Add support for choosing the primary key
index type (#3344)
add adb88ffb65 IGNITE-21696 Don't synchronize on AtomicReferenceArray
(#3429)
add 7897605f2a IGNITE-21766 Avoid a race while handling messages in jraft
(#3423)
add b7a31da88c IGNITE-21652 Extend codestyle checks made by PMD (#3431)
add addfbe240e Bump de.inetsoftware.setupbuilder from 7.2.13 to 7.2.21
(#3426)
add 5aff718297 Bump org.awaitility:awaitility from 4.2.0 to 4.2.1 (#3428)
add 6cabfeb9d2 Bump org.jetbrains.gradle.plugin.idea-ext from 1.1.7 to
1.1.8 (#3427)
add 1c9a3c7fc2 IGNITE-21391 Several tests enabled, some new disabled.
(#3434)
add fff5713c5b IGNITE-21585 Disable catalog compaction (#3358)
add c80510d0c2 IGNITE-21618 In-flights for read-only transactions (#3371)
add 97c8a65082 IGNITE-21514 Deal with index destruction on compaction of
catalog during a full state transfer (#3414)
add 79e6b8c440 IGNITE-21620 Increase clientConnector.idleTimeout for
client tests (#3437)
add 5db213640d IGNITE-21764 Fix
PersistentPageMemoryMvTableStorageTest.testIndexDestructionOnRecovery (#3438)
add 070fb11b9a Bump io.swagger:swagger-annotations from 1.6.13 to 1.6.14
(#3442)
add d0a034d3d2 IGNITE-21813 Fix checkstyle-supressions.xml (#3445)
add 799be00325 Bump io.github.bonede:tree-sitter from 0.21.0 to 0.22.2
(#3444)
add 8d7518941d Bump com.palantir.docker from 0.35.0 to 0.36.0 (#3443)
add 43e536820d Bump org.openapi.generator from 7.3.0 to 7.4.0 (#3425)
add 1f53d30cf0 IGNITE-21119 Complete index creation future when the index
is AVAILABLE or removed (#3424)
add 8aa7016620 IGNITE-21811 Cleanup in RocksDbClusterStateStorage (#3441)
add 399f0f15da IGNITE-21680 Remove destroyed RocksDB indexes on recovery
(#3435)
add e9df1de177 IGNITE-21798 Add properties to configure number of RAFT
threads (#3432)
add 4fce0cb309 IGNITE-21281 Sql. Partition pruning. Integrate static
partition pruning into MODIFY statements (#3335)
add 15a3cd3028 Bump io.dropwizard.metrics:metrics-core from 4.0.2 to
4.2.25 (#3457)
add fd3d6a909b Bump com.github.spotbugs from 6.0.7 to 6.0.8 (#3456)
add a643a9ff9c IGNITE-21795 Unconditionally update storage with proper
raft index within PartitionListener (#3454)
add 500c5d286b IGNITE-21819 Clear nextRowIdToBuild on rebalance (#3451)
add ed64c5c3c4 IGNITE-21754 Remove destroyed tables on recovery - Page
Memory (#3446)
add 7060006355 IGNITE-21708 Fix
CatalogManagerSelfTest::testPkAvailableIndexEvent flaky test (#3450)
add c02b3ea7eb IGNITE-18617 Clear rw tx context and cleanup ready futures
on tx finish (#3436)
add c3de575204 IGNITE-21521 Fix update order in upsertAll and DataStreamer
for a new key (#3439)
add cbc84ebce0 IGNITE-21815 Client handler: use QueryProcessor instead of
IgniteSql (#3459)
add 3a374adfd9 IGNITE-21817 CriteriaException must keep error code for
mapping from SqlException. (#3449)
add 20359d3a12 IGNITE-21540 Handle lock exception for transaction
operations (#3462)
add 07cebb426f IGNITE-21804 Fix macos build of Ignite CPP client (#3440)
add 384eb85497 IGNITE-21666 Define base Eventlog classes (#3430)
add 104b4903ba IGNITE-21674 Fix subcommand completion in CLI (#3461)
add 20d296db59 IGNITE-21669 Sql. Remove sessions from SQL API
add f27a761dc7 IGNITE-21834 Add more details to assertions in recovery
handhake managers (#3471)
add c4c0811f2e IGNITE-21615 Modify config update message (#3452)
add e1cdd29356 Bump netty from 4.1.107.Final to 4.1.108.Final (#3472)
add 5c102a3187 IGNITE-21821 Fix Error: Partition file page store is either
not initialized or deleted (#3478)
add 1ded6e226d IGNITE-21612 Send LWM of sender on full state transfer
(#3475)
add 0921c31652 IGNITE-21831 Group RocksDB indexes by table ID (#3473)
add 0efa2c207f IGNITE-21681 QueryCriteriaAsyncCursor doesn't satisfy
AsyncCursor contract. (#3460)
add a7188adc70 IGNITE-19809 Make maxClockSkew a cluster-wide configuration
property (#3470)
add 3726289112 IGNITE-21845 Destroy index out of LWM updater thread (#3487)
add 86ad10f411 IGNITE-21172 Fix incorrect error code usage (#3453)
add 095aeb01c0 IGNITE-21843 ItRebalanceDistributedTest silently fails to
start TableManager (#3480)
add b57c452541 IGNITE-21588 Fix CMG command idempotency (#3484)
add 625aad225d IGNITE-20009: Sql. Rework 2-phase aggregates part 2. AVG as
SUM / COUNT. (#3413)
add f17393e231 IGNITE-21759 Txn state vacuum implemented. (#3469)
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 f92605fb51 Bump com.github.johnrengelman.shadow from 7.1.2 to 8.1.1
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 (77a6dd85e1)
\
N -- N -- N
refs/heads/dependabot/gradle/com.github.johnrengelman.shadow-8.1.1 (f92605fb51)
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:
...ll checks [PMD, modernizer, checkstyle].run.xml | 29 -
.../All checks [PMD, spotbugs, checkstyle].run.xml | 30 +
.run/All checks [check].run.xml | 2 +-
.run/Modernizer check [modernizer].run.xml | 40 -
.run/PMD [pmdMain pmdTest].run.xml | 41 +
.run/PMD [pmdMain].run.xml | 41 -
.run/Spotbugs check [spotbugsMain].run.xml | 40 +
DEVNOTES.md | 18 +-
build.gradle | 2 +-
buildscripts/java-core.gradle | 72 +-
buildscripts/java-integration-test.gradle | 4 +
buildscripts/java-test-fixtures.gradle | 4 +
check-rules/checkstyle-disabled-modules.xml | 29 -
check-rules/checkstyle-rules.xml | 2 +-
check-rules/checkstyle-suppressions.xml | 4 +
check-rules/modernizer-rules.xml | 49 --
check-rules/pmd-rules.xml | 66 +-
check-rules/spotbugs-excludes.xml | 323 +++++++
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 -
.../apache/ignite/example/sql/SqlApiExample.java | 261 +++---
.../PersistentPageMemoryStorageExample.java | 2 +-
.../example/storage/RocksDbStorageExample.java | 2 +-
.../example/storage/StorageEngineExample.java | 15 +-
.../storage/VolatilePageMemoryStorageExample.java | 2 +-
gradle/libs.versions.toml | 45 +-
.../affinity/RendezvousAffinityFunction.java | 4 -
.../org/apache/ignite/catalog/IgniteCatalog.java | 6 +-
.../java/org/apache/ignite/catalog/ZoneEngine.java | 25 -
.../apache/ignite/catalog/annotations/Zone.java | 42 +-
.../catalog/definitions/ColumnDefinition.java | 5 +
.../catalog/definitions/TableDefinition.java | 10 +-
.../ignite/catalog/definitions/ZoneDefinition.java | 200 ++++-
.../org/apache/ignite/compute/IgniteCompute.java | 27 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 12 +-
.../main/java/org/apache/ignite/sql/IgniteSql.java | 194 ++++-
.../main/java/org/apache/ignite/sql/ResultSet.java | 4 +-
.../main/java/org/apache/ignite/sql/Session.java | 441 ----------
.../main/java/org/apache/ignite/sql/Statement.java | 27 +-
.../apache/ignite/sql/async/AsyncResultSet.java | 6 +-
.../ignite/sql/reactive/ReactiveResultSet.java | 72 --
.../apache/ignite/sql/reactive/package-info.java | 22 -
.../apache/ignite/table/DataStreamerOptions.java | 31 +-
.../java/org/apache/ignite/table/RecordView.java | 2 +-
.../internal/ConfigurationModuleArchTest.java | 92 --
.../internal/binarytuple/BinaryTupleBuilder.java | 23 +-
.../internal/binarytuple/BinaryTupleParser.java | 2 +-
.../internal/binarytuple/BinaryTupleReader.java | 14 +-
.../internal/binarytuple/BinaryTupleTest.java | 47 +-
.../ignite/internal/catalog/ItCatalogDslTest.java | 19 +-
.../internal/catalog/sql/AbstractCatalogQuery.java | 5 +-
.../catalog/sql/CreateFromAnnotationsImpl.java | 20 +-
.../catalog/sql/CreateFromDefinitionImpl.java | 21 +-
.../internal/catalog/sql/CreateZoneImpl.java | 63 +-
.../ignite/internal/catalog/sql/WithOption.java | 28 +
.../catalog/sql/CreateFromAnnotationsTest.java | 47 +-
.../catalog/sql/CreateFromDefinitionTest.java | 17 +-
.../internal/catalog/sql/CreateZoneTest.java | 13 +-
.../catalog/sql/InvalidDefinitionTest.java | 288 ++++---
.../ignite/internal/catalog/CatalogManager.java | 8 +-
.../internal/catalog/CatalogManagerImpl.java | 185 ++--
.../catalog/CatalogParamsValidationUtils.java | 44 +
.../ignite/internal/catalog/CatalogService.java | 3 +
.../CatalogVersionAwareValidationException.java | 41 +
.../ignite/internal/catalog/ClockWaiter.java | 202 -----
.../catalog/commands/AlterZoneCommand.java | 25 +-
.../catalog/commands/AlterZoneCommandBuilder.java | 7 +-
.../AlterZoneSetDefaultCatalogCommand.java | 76 ++
.../internal/catalog/commands/CatalogUtils.java | 92 +-
.../catalog/commands/CreateTableCommand.java | 149 +++-
.../commands/CreateTableCommandBuilder.java | 12 +-
.../catalog/commands/CreateZoneCommand.java | 28 +-
.../catalog/commands/CreateZoneCommandBuilder.java | 7 +-
.../catalog/commands/DataStorageParams.java | 90 --
.../catalog/commands/RenameTableCommand.java | 15 +-
.../catalog/commands/RenameZoneCommand.java | 2 +-
.../catalog/commands/StorageProfileParams.java | 67 ++
.../catalog/commands/TableHashPrimaryKey.java | 67 ++
.../internal/catalog/commands/TablePrimaryKey.java | 85 ++
.../catalog/commands/TableSortedPrimaryKey.java | 97 +++
.../SchemaSynchronizationConfigurationSchema.java | 14 +-
.../descriptors/CatalogDataStorageDescriptor.java | 88 --
.../descriptors/CatalogHashIndexDescriptor.java | 2 +-
.../descriptors/CatalogIndexColumnDescriptor.java | 2 +-
.../catalog/descriptors/CatalogIndexStatus.java | 13 +
.../descriptors/CatalogSchemaDescriptor.java | 2 +-
.../CatalogStorageProfileDescriptor.java | 73 ++
.../CatalogStorageProfilesDescriptor.java | 90 ++
.../descriptors/CatalogSystemViewDescriptor.java | 2 +-
.../descriptors/CatalogTableColumnDescriptor.java | 2 +-
.../descriptors/CatalogTableDescriptor.java | 27 +-
.../descriptors/CatalogTableSchemaVersions.java | 2 +-
.../catalog/descriptors/CatalogZoneDescriptor.java | 30 +-
.../internal/catalog/events/CatalogEvent.java | 6 -
.../internal/catalog/events/DestroyIndexEvent.java | 50 --
.../events/DestroyIndexEventParameters.java | 51 --
.../internal/catalog/events/DestroyTableEvent.java | 47 -
.../events/DestroyTableEventParameters.java | 43 -
.../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/CatalogSerializationUtils.java | 2 +-
.../serialization/MarshallableEntryType.java | 3 +-
...CatalogManagerDescriptorCausalityTokenTest.java | 48 +-
.../internal/catalog/CatalogManagerSelfTest.java | 385 +++++----
.../internal/catalog/CatalogTestUtilsTest.java | 5 +-
.../ignite/internal/catalog/ClockWaiterTest.java | 98 ---
.../commands/AbstractCommandValidationTest.java | 39 +-
.../AlterTableAddColumnCommandValidationTest.java | 2 +-
...AlterTableAlterColumnCommandValidationTest.java | 20 +-
.../AlterTableDropColumnCommandValidationTest.java | 4 +-
.../catalog/commands/CatalogUtilsTest.java | 14 +-
.../CreateAbstractIndexCommandValidationTest.java | 2 +-
.../commands/CreateTableCommandValidationTest.java | 160 +++-
.../commands/CreateZoneCommandValidationTest.java | 22 +
.../commands/DropIndexCommandValidationTest.java | 2 +-
.../commands/RenameTableCommandValidationTest.java | 22 +
.../catalog/commands/TablePrimaryKeyTest.java | 154 ++++
.../CatalogDataStorageDescriptorTest.java | 37 -
.../descriptors/CatalogTableDescriptorTest.java | 4 +-
.../descriptors/CatalogZoneDescriptorTest.java | 8 +-
.../storage/CatalogEntrySerializationTest.java | 41 +-
.../internal/catalog/BaseCatalogManagerTest.java | 22 +-
.../ignite/internal/catalog/CatalogTestUtils.java | 55 +-
modules/cli/build.gradle | 4 +
.../ignite/internal/cli/CliIntegrationTest.java | 6 +
.../internal/cli/commands/ItConfigCommandTest.java | 188 ----
.../cli/commands/ItConnectionHeartbeatTest.java | 109 +--
.../configuration/ItConfigCommandTest.java | 37 +-
.../repl/executor/ItIgnitePicocliCommandsTest.java | 10 +-
.../java/org/apache/ignite/internal/cli/Main.java | 24 +-
.../cli/call/cluster/unit/DeployUnitClient.java | 4 +-
.../call/configuration/NodeConfigUpdateCall.java | 6 +-
.../cli/commands/SpacedParameterMixin.java | 2 +-
.../cluster/config/ClusterConfigShowCommand.java | 11 +-
.../config/ClusterConfigShowReplCommand.java | 12 +-
.../node/config/NodeConfigShowCommand.java | 11 +-
.../node/config/NodeConfigShowReplCommand.java | 12 +-
.../internal/cli/commands/sql/SqlMetaData.java | 14 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 76 +-
.../highlighter/JsonAnsiHighlighter.java | 65 ++
.../SqlAttributedStringHighlighter.java | 66 ++
.../cli/commands/treesitter/parser/Indexer.java | 98 +++
.../commands/treesitter/parser/JsonTokenType.java | 63 ++
.../cli/commands/treesitter/parser/Parser.java | 55 ++
.../commands/treesitter/parser/SqlTokenType.java | 63 ++
.../ignite/internal/cli/config/CliConfigKeys.java | 10 +-
.../internal/cli/config/ini/IniConfigManager.java | 4 +
.../ignite/internal/cli/config/ini/IniFile.java | 4 +-
.../ignite/internal/cli/config/ini/IniParser.java | 8 +-
.../apache/ignite/internal/cli/core/flow/Flow.java | 2 +-
.../apache/ignite/internal/cli/core/repl/Repl.java | 22 +-
.../ignite/internal/cli/core/repl/ReplBuilder.java | 20 +-
.../core/repl/completer/LazyDynamicCompleter.java | 51 --
.../core/repl/config/ClientConnectorConfig.java | 30 -
.../internal/cli/core/repl/config/RootConfig.java | 28 -
.../core/repl/executor/IgnitePicocliCommands.java | 86 +-
.../cli/core/repl/executor/ReplExecutorImpl.java | 25 +-
.../repl/registry/impl/JdbcUrlRegistryImpl.java | 25 +-
.../repl/registry/impl/NodeNameRegistryImpl.java | 2 +-
.../internal/cli/core/style/AnsiStringSupport.java | 9 +-
.../cli/decorators/DefaultDecoratorRegistry.java | 2 +-
.../internal/cli/decorators/JsonDecorator.java | 15 +-
.../internal/cli/IgniteCliInterfaceTest.java | 7 +-
.../internal/cli/commands/CliCommandTestBase.java | 48 +-
.../internal/cli/commands/ProfileMixinTest.java | 45 +-
.../cluster/config/ConfigUpdateCommandTest.java | 131 +++
.../internal/cli/commands/flow/FlowTest.java | 1 +
.../treesitter/parser/JsonIndexerTest.java | 81 ++
.../commands/treesitter/parser/SqlIndexerTest.java | 116 +++
.../client/proto/ClientBinaryTupleUtils.java | 2 +-
.../client/proto/ClientMessageDecoder.java | 2 +-
.../table/MutableTupleBinaryTupleAdapter.java | 4 +-
.../internal/jdbc/proto/JdbcQueryEventHandler.java | 5 +-
modules/client-handler/build.gradle | 6 +-
.../apache/ignite/client/handler/TestServer.java | 11 +-
.../ignite/client/handler/ClientHandlerModule.java | 34 +-
.../handler/ClientInboundMessageHandler.java | 46 +-
.../handler/ClientPrimaryReplicaTracker.java | 180 ++--
.../client/handler/JdbcQueryCursorHandlerImpl.java | 5 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 53 +-
.../ClientComputeExecuteColocatedRequest.java | 2 +-
.../compute/ClientComputeExecuteRequest.java | 2 +-
.../requests/jdbc/ClientJdbcConnectRequest.java | 5 +-
.../handler/requests/jdbc/JdbcMetadataCatalog.java | 18 +-
.../handler/requests/sql/ClientSqlCommon.java | 50 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 86 +-
.../requests/sql/ClientSqlExecuteRequest.java | 84 +-
.../sql/ClientSqlExecuteScriptRequest.java | 14 +-
.../handler/requests/sql/ClientSqlProperties.java | 73 ++
.../handler/requests/sql/ClientSqlResultSet.java | 11 +-
.../handler/requests/table/ClientHandlerTuple.java | 22 +-
.../handler/requests/table/ClientTableCommon.java | 10 +-
...entTablePartitionPrimaryReplicasGetRequest.java | 19 +-
.../handler/ClientPrimaryReplicaTrackerTest.java | 7 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 9 +-
.../ignite/client/handler/FakeCatalogService.java | 6 +-
.../ignite/client/handler/FakePlacementDriver.java | 2 +-
modules/client/build.gradle | 2 +
.../apache/ignite/client/ClientOperationType.java | 10 +-
.../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/ClientSession.java | 381 ---------
.../internal/client/sql/ClientSessionBuilder.java | 153 ----
.../ignite/internal/client/sql/ClientSql.java | 258 +++++-
.../internal/client/sql/ClientStatement.java | 41 +-
.../client/sql/ClientStatementBuilder.java | 24 +-
.../internal/client/table/AbstractClientView.java | 19 +-
.../internal/client/table/ClientDataStreamer.java | 11 +-
.../client/table/ClientKeyValueBinaryView.java | 6 +-
.../internal/client/table/ClientKeyValueView.java | 41 +-
.../client/table/ClientRecordBinaryView.java | 6 +-
.../client/table/ClientRecordSerializer.java | 12 +-
.../internal/client/table/ClientRecordView.java | 6 +-
.../ignite/internal/client/table/ClientSchema.java | 2 +-
.../ignite/internal/client/table/ClientTable.java | 67 +-
.../client/table/ClientTupleSerializer.java | 4 +-
.../marshaller/ClientMarshallerReader.java | 19 +-
.../apache/ignite/client/AbstractClientTest.java | 4 +-
.../apache/ignite/client/ClientMetricsTest.java | 4 +-
.../org/apache/ignite/client/ClientSqlTest.java | 76 +-
.../org/apache/ignite/client/ClientTablesTest.java | 36 -
.../org/apache/ignite/client/ClientTupleTest.java | 4 +-
.../org/apache/ignite/client/DataStreamerTest.java | 8 +-
.../client/ObservableTimestampPropagationTest.java | 3 +-
.../ignite/client/PartitionAwarenessTest.java | 13 +-
.../org/apache/ignite/client/SchemaUpdateTest.java | 2 +-
.../apache/ignite/client/ServerMetricsTest.java | 12 +-
.../ignite/client/TestClientHandlerModule.java | 16 +-
.../java/org/apache/ignite/client/TestServer.java | 10 +-
.../ignite/client/fakes/FakeAsyncResultSet.java | 251 ------
.../org/apache/ignite/client/fakes/FakeCursor.java | 144 +++-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 2 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 42 +-
.../apache/ignite/client/fakes/FakeIgniteSql.java | 52 --
.../ignite/client/fakes/FakeIgniteTables.java | 16 +-
.../ignite/client/fakes/FakeInternalTable.java | 6 +
.../apache/ignite/client/fakes/FakeSession.java | 290 -------
.../ignite/client/fakes/FakeSessionBuilder.java | 136 ---
.../org/apache/ignite/client/fakes/FakeSqlRow.java | 290 -------
.../apache/ignite/client/fakes/FakeTxManager.java | 34 +-
.../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 +-
.../StorageProfileConfigurationSchema.java | 36 -
.../StorageProfilesConfigurationSchema.java | 34 -
.../management/raft/CmgRaftGroupListener.java | 2 +-
.../management/raft/CmgStorageException.java | 31 +
.../raft/RocksDbClusterStateStorage.java | 82 +-
.../raft/commands/ClusterNodeMessage.java | 3 +-
.../management/topology/api/LogicalNode.java | 25 +-
.../AbstractClusterStateStorageManagerTest.java | 21 +-
.../raft/AbstractClusterStateStorageTest.java | 38 +-
.../RocksDbClusterStateStorageManagerTest.java | 4 +-
.../raft/RocksDbClusterStateStorageTest.java | 4 +-
.../raft/TestClusterStateStorageManagerTest.java | 2 +-
.../raft/TestClusterStateStorageTest.java | 2 +-
.../management/BaseItClusterManagementTest.java | 8 +-
.../internal/cluster/management/MockNode.java | 6 +-
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/loader/JobClassLoaderFactory.java | 23 +-
.../compute/messaging/ComputeMessaging.java | 2 +
.../internal/compute/ComputeComponentImplTest.java | 288 ++-----
.../ignite/configuration/ConfigurationModule.java | 5 +-
.../configuration/ConfigurationTreeGenerator.java | 6 +-
.../tree/TraversableTreeNodeTest.java | 3 +-
.../configuration/ConfigurationTestUtils.java | 0
.../ignite/internal/components/LogSyncer.java | 28 +
.../ignite/internal/future/InFlightFutures.java | 11 +
.../apache/ignite/internal/hlc/ClockService.java | 104 +++
.../ignite/internal/hlc/ClockServiceImpl.java | 65 ++
.../apache/ignite/internal/hlc/ClockWaiter.java | 198 +++++
.../apache/ignite/internal/hlc/HybridClock.java | 6 +-
.../ignite/internal/hlc/HybridTimestamp.java | 50 --
.../internal/lang/IgniteStringFormatter.java | 8 +-
.../internal/lang/IgniteSystemProperties.java | 3 +
.../apache/ignite/internal/lang/InternalTuple.java | 3 +-
.../internal/replicator/ReplicatorConstants.java | 28 +
.../ignite/internal/sql/AbstractSession.java | 171 ----
.../ignite/internal/streamer/StreamerOptions.java | 4 +-
.../internal/streamer/StreamerSubscriber.java | 47 +-
.../criteria/CriteriaExceptionMapperUtil.java | 7 -
.../table/criteria/QueryCriteriaAsyncCursor.java | 2 +-
.../ignite/internal/thread/PublicApiThreading.java | 144 +++-
.../ignite/internal/thread/ThreadOperation.java | 4 +-
.../internal/tostring/IgniteToStringExclude.java | 6 +-
.../internal/tostring/IgniteToStringInclude.java | 6 +-
.../ignite/internal/util/ExceptionUtils.java | 4 +-
.../apache/ignite/internal/util/GridUnsafe.java | 4 +-
.../apache/ignite/internal/util/IgniteUtils.java | 6 +-
.../ignite/internal/util/OffheapReadWriteLock.java | 3 +-
.../util/subscription/OrderedMergePublisher.java | 58 +-
.../apache/ignite/internal/wrapper/Wrapper.java | 31 +
.../apache/ignite/internal/wrapper/Wrappers.java | 57 ++
.../causality/IncrementalVersionedValueTest.java | 2 +-
.../ignite/internal/hlc/ClockWaiterTest.java | 99 +++
.../internal/streamer/StreamerSubscriberTest.java | 32 +-
.../criteria/CriteriaExceptionMapperUtilTest.java | 2 +-
.../internal/thread/PublicApiThreadingTest.java | 88 ++
.../tostring/IgniteToStringBuilderSelfTest.java | 28 +-
.../ignite/internal/util/CollectionUtilsTest.java | 3 +-
.../IgniteUnsafeDataInputOutputByteOrderTest.java | 12 +-
.../ignite/internal/hlc/TestClockService.java | 76 ++
.../internal/testframework/IgniteTestUtils.java | 49 +-
.../testframework/TestIgnitionManager.java | 22 +-
.../src/testFixtures/resources/log4j2-test.xml | 17 +-
.../ItDistributionZonesFilterTest.java | 470 ----------
.../ItDistributionZonesFiltersTest.java | 481 +++++++++++
...niteDistributionZoneManagerNodeRestartTest.java | 45 +-
.../distributionzones/DistributionZoneManager.java | 38 +-
.../distributionzones/DistributionZonesUtil.java | 61 +-
.../distributionzones/NodeWithAttributes.java | 46 +-
.../CausalityDataNodesEngine.java | 6 +-
.../disaster/DisasterRecoveryManager.java | 172 ----
.../disaster/DisasterRecoveryRequest.java | 52 --
.../disaster/ManualGroupUpdateRequest.java | 106 ---
.../rebalance/DistributionZoneRebalanceEngine.java | 2 +-
.../RebalanceRaftGroupEventsListener.java | 13 +-
.../distributionzones/rebalance/RebalanceUtil.java | 14 +-
.../BaseDistributionZoneManagerTest.java | 17 +
.../DistributionZoneAttributeFiltersTest.java | 207 +++++
.../DistributionZoneFiltersTest.java | 207 -----
.../DistributionZoneManagerAlterFilterTest.java | 24 +-
...ibutionZoneManagerConfigurationChangesTest.java | 8 +-
.../DistributionZoneManagerFilterTest.java | 24 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 145 ++--
...butionZoneManagerStorageProfilesFilterTest.java | 120 +++
.../DistributionZoneStorageProfilesFilterTest.java | 71 ++
.../DistributionZoneCausalityDataNodesTest.java | 31 +-
.../DistributionZoneRebalanceEngineTest.java | 13 +
.../RebalanceUtilUpdateAssignmentsTest.java | 4 +-
.../DistributionZonesTestUtil.java | 124 ++-
modules/eventlog/README.MD | 43 +
modules/eventlog/build.gradle | 54 ++
.../ItEventLogConfigurationValidationTest.java | 55 ++
.../ItLogSinkConfigurationValidationTest.java | 89 ++
.../eventlog/impl/InMemoryCollectionSink.java | 37 +
.../InMemoryCollectionSinkConfigurationSchema.java | 26 +
.../eventlog/impl/ItEventLogConfigurationTest.java | 225 +++++
.../internal/eventlog/impl/TestEventTypes.java | 32 +
.../internal/eventlog/impl/TestSinkFactory.java | 38 +
.../apache/ignite/internal/eventlog/api/Event.java | 46 +
.../ignite/internal/eventlog/api/EventChannel.java | 37 +
.../ignite/internal/eventlog/api/EventFactory.java | 41 +
.../ignite/internal/eventlog/api/EventLog.java | 50 ++
.../internal/eventlog/api/IgniteEventType.java | 36 +
.../ignite/internal/eventlog/api/IgniteEvents.java | 56 ++
.../apache/ignite/internal/eventlog/api/Sink.java | 40 +
.../config/EventLogConfigurationModule.java | 60 ++
.../config/schema/ChannelConfigurationSchema.java | 40 +
.../config/schema/EventLogConfigurationSchema.java | 33 +
.../config/schema/EventTypeValidatorImpl.java | 49 ++
.../config/schema/LogSinkConfigurationSchema.java | 45 +
.../config/schema/SinkConfigurationSchema.java | 40 +
.../eventlog/config/schema/ValidEventType.java | 28 +
.../internal/eventlog/event/EventBuilder.java | 124 +++
.../ignite/internal/eventlog/event/EventImpl.java | 103 +++
.../internal/eventlog/event/EventTypeRegistry.java | 57 ++
.../ignite/internal/eventlog/event/EventUser.java | 78 ++
.../event/exception/InvalidEventTypeException.java | 39 +
.../exception/InvalidProductVersionException.java | 40 +
.../event/exception/MissingEventTypeException.java | 32 +
.../event/exception/MissingEventUserException.java | 32 +
.../exception/NotUniqueEventTypeException.java | 40 +
.../internal/eventlog/impl/ChannelFactory.java | 33 +
.../internal/eventlog/impl/ChannelRegistry.java | 43 +
.../impl/ConfigurationBasedChannelRegistry.java | 115 +++
.../impl/ConfigurationBasedSinkRegistry.java | 95 ++
.../internal/eventlog/impl/EventChannelImpl.java | 47 +
.../internal/eventlog/impl/EventLogImpl.java | 61 ++
.../ignite/internal/eventlog/impl/LogSink.java | 45 +
.../ignite/internal/eventlog/impl/SinkFactory.java | 45 +
.../internal/eventlog/impl/SinkRegistry.java | 27 +
.../internal/eventlog/ser/EventSerializer.java | 26 +
.../internal/eventlog/ser/JsonEventSerializer.java | 110 +++
.../internal/eventlog/event/EventBuilderTest.java | 142 +++
.../eventlog/event/EventTypeRegistryTest.java | 60 ++
.../internal/eventlog/event/IgniteEventsTest.java | 66 ++
.../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 | 4 +
.../ignite/internal/failure/FailureProcessor.java | 19 +
.../internal/failure/NoOpFailureProcessor.java | 41 +
.../internal/network/file/ChunkedFileReader.java | 4 +-
.../internal/network/file/ChunkedFileWriter.java | 4 +-
.../network/file/FileTransferServiceImplTest.java | 6 +-
modules/index/build.gradle | 5 +
.../internal/index/ItBuildIndexOneNodeTest.java | 34 +-
.../ignite/internal/index/ItBuildIndexTest.java | 15 +-
.../index/ItDropIndexMultipleNodesTest.java | 46 +-
.../internal/index/ItDropIndexOneNodeTest.java | 19 +-
.../ItIndexAndIndexStorageDestructionTest.java | 165 ++++
.../ignite/internal/index/ItIndexManagerTest.java | 3 +-
...IndexNodeFinishedRwTransactionsCheckerTest.java | 30 +-
.../index/ItRwTransactionAndIndexesTest.java | 66 +-
.../internal/index/ChangeIndexStatusTask.java | 24 +-
.../index/ChangeIndexStatusTaskScheduler.java | 19 +-
.../internal/index/IndexBuildController.java | 12 +-
.../internal/index/IndexBuildingManager.java | 18 +-
.../apache/ignite/internal/index/IndexChooser.java | 272 ------
.../apache/ignite/internal/index/IndexManager.java | 132 ++-
.../internal/index/ChangeIndexStatusTaskTest.java | 11 +-
.../index/IndexAvailabilityControllerTest.java | 3 +-
.../internal/index/IndexBuildControllerTest.java | 13 +-
.../ignite/internal/index/IndexChooserTest.java | 391 ---------
.../ignite/internal/index/IndexManagerTest.java | 55 +-
.../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 | 75 +-
.../internal/jdbc/JdbcClientQueryEventHandler.java | 7 +-
.../ignite/internal/jdbc/JdbcConnection.java | 64 +-
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 3 +-
.../internal/jdbc/PreparedStatementParamsTest.java | 10 +-
modules/low-watermark/README.md | 5 +
modules/low-watermark/build.gradle | 49 ++
.../ignite/internal/lowwatermark/LowWatermark.java | 62 ++
.../lowwatermark/LowWatermarkCandidate.java | 42 +
.../lowwatermark/LowWatermarkChangedListener.java | 37 +
.../internal/lowwatermark/LowWatermarkImpl.java | 339 ++++++++
.../message/GetLowWatermarkRequest.java | 28 +
.../message/GetLowWatermarkResponse.java | 31 +
.../message/LowWatermarkMessageGroup.java | 30 +
.../lowwatermark/LowWatermarkImplTest.java | 319 +++++++
.../internal/lowwatermark/TestLowWatermark.java | 130 +++
.../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 | 7 +-
.../impl/MetaStorageRocksDbRangeTest.java | 3 +-
.../RocksDbCompactionKeyValueStorageTest.java | 3 +-
.../server/RocksDbKeyValueStorageTest.java | 3 +-
.../metastorage/server/WatchProcessorTest.java | 6 +-
.../server/SimpleInMemoryKeyValueStorage.java | 3 +-
.../server/TestRocksDbKeyValueStorage.java | 3 +-
.../metrics/exporters/jmx/MetricSetMbean.java | 2 +-
.../messages/MarshallableTypesBlackList.java | 4 +-
.../processor/messages/MessageImplGenerator.java | 15 +-
.../internal/network/LazyStripedExecutors.java | 4 +-
.../stream/DirectByteBufferStreamImplV1.java | 24 +-
.../internal/network/netty/ConnectionManager.java | 4 +-
.../recovery/RecoveryClientHandshakeManager.java | 8 +-
.../recovery/RecoveryServerHandshakeManager.java | 5 +-
.../serialization/ClassDescriptorFactory.java | 4 +-
.../serialization/marshal/BuiltInMarshalling.java | 6 +-
.../marshal/DefaultUserObjectMarshaller.java | 4 +-
.../internal/network/AllTypesMessageTest.java | 17 +
.../internal/network/netty/InboundDecoderTest.java | 2 +-
...TransferableObjectProcessorIncrementalTest.java | 2 +-
...erObjectMarshallerWithArbitraryObjectsTest.java | 4 +-
...ltUserObjectMarshallerWithSchemaChangeTest.java | 6 +-
.../network/ssl/SslContextProviderTest.java | 8 +-
.../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 +-
...asePageMemoryDataRegionConfigurationSchema.java | 36 -
...entPageMemoryDataRegionConfigurationSchema.java | 56 --
...istentPageMemoryProfileConfigurationSchema.java | 61 ++
...ilePageMemoryDataRegionConfigurationSchema.java | 74 --
...latilePageMemoryProfileConfigurationSchema.java | 80 ++
.../pagememory/inmemory/VolatilePageMemory.java | 32 +-
.../internal/pagememory/persistence/FastCrc.java | 4 +-
.../persistence/PersistentPageMemory.java | 45 +-
.../persistence/RobinHoodBackwardShiftHashMap.java | 14 +-
.../persistence/checkpoint/CheckpointManager.java | 5 +-
.../persistence/checkpoint/Checkpointer.java | 17 +-
.../persistence/store/FilePageStoreManager.java | 31 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 15 +-
.../internal/pagememory/tree/io/BplusLeafIo.java | 2 +-
.../pagememory/freelist/AbstractFreeListTest.java | 18 +-
.../inmemory/VolatilePageMemoryNoLoadSelfTest.java | 25 +-
.../PersistentPageMemoryNoLoadTest.java | 21 +-
.../checkpoint/CheckpointManagerTest.java | 3 +
.../persistence/checkpoint/CheckpointerTest.java | 28 +-
.../store/AbstractFilePageStoreIoTest.java | 3 +-
.../store/FilePageStoreManagerTest.java | 32 +-
.../internal/placementdriver/ActiveActorTest.java | 38 +-
.../ItPrimaryReplicaChoiceTest.java | 144 ++--
.../MultiActorPlacementDriverTest.java | 13 +-
.../PlacementDriverManagerTest.java | 3 +-
...apache.ignite.configuration.ConfigurationModule | 1 -
.../placementdriver/AssignmentsTracker.java | 28 +-
.../internal/placementdriver/LeaseUpdater.java | 80 +-
.../placementdriver/PlacementDriverManager.java | 10 +-
.../internal/placementdriver/TopologyTracker.java | 13 +-
.../internal/placementdriver/leases/Lease.java | 34 +-
.../placementdriver/leases/LeaseTracker.java | 16 +-
.../negotiation/LeaseAgreement.java | 62 +-
.../negotiation/LeaseNegotiator.java | 41 +-
.../placementdriver/LeaseNegotiationTest.java | 296 +++++++
.../internal/placementdriver/LeaseTrackerTest.java | 10 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 3 +-
.../placementdriver/PlacementDriverTest.java | 22 +-
.../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 | 45 +
.../cpp/ignite/client/compute/job_status.h | 48 ++
.../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/common/error_codes.h | 6 +-
.../detail/macos/macos_async_worker_thread.cpp | 6 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 2 +-
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/HeartbeatTests.cs | 14 +-
.../Apache.Ignite.Tests/Linq/LinqTests.Cast.cs | 16 +-
.../Linq/LinqTests.Functions.cs | 4 +-
.../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 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 10 +-
.../Internal/Buffers/PooledArrayBuffer.cs | 34 +-
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 34 +-
.../Apache.Ignite/Internal/ClientSocket.Metrics.cs | 39 +
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 73 +-
.../Apache.Ignite/Internal/ConnectionContext.cs | 3 +-
.../Apache.Ignite/Internal/IgniteClientInternal.cs | 6 +-
.../Internal/Linq/IgniteQueryExpressionVisitor.cs | 5 +
.../Apache.Ignite/Internal/Linq/MethodVisitor.cs | 41 +-
.../dotnet/Apache.Ignite/Internal/Metrics.cs | 10 +-
.../Apache.Ignite/Internal/MetricsContext.cs | 28 +
.../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 +-
.../platforms/dotnet/Apache.Ignite/MetricTags.cs | 37 +
.../dotnet/Apache.Ignite/RetryReadPolicy.cs | 1 +
.../dotnet/Apache.Ignite/Table/DataStreamerItem.cs | 53 ++
.../Table/DataStreamerOperationType.cs | 34 +
.../Apache.Ignite/Table/IDataStreamerTarget.cs | 31 +-
.../apache/ignite/internal/raft/RaftManager.java | 4 +
.../configuration/RaftConfigurationSchema.java | 18 +
.../raft/ItTruncateSuffixAndRestartTest.java | 4 +
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 4 +-
.../raft/server/ItJraftCounterServerTest.java | 15 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 20 +
.../internal/raft/server/impl/JraftServerImpl.java | 27 +-
.../internal/raft/storage/LogStorageFactory.java | 3 +-
.../storage/impl/DefaultLogStorageFactory.java | 6 +
.../raft/storage/impl/LocalLogStorageFactory.java | 5 +
.../raft/storage/impl/RocksDbSharedLogStorage.java | 2 +-
.../storage/impl/VolatileLogStorageFactory.java | 5 +
.../raft/storage/logit/LogitLogStorageFactory.java | 6 +
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 7 +-
.../java/org/apache/ignite/raft/jraft/Node.java | 10 +
.../apache/ignite/raft/jraft/core/NodeImpl.java | 40 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 6 +-
.../raft/jraft/disruptor/StripedDisruptor.java | 14 +-
.../org/apache/ignite/raft/jraft/entity/LogId.java | 2 +-
.../org/apache/ignite/raft/jraft/entity/Task.java | 2 +-
.../ignite/raft/jraft/option/NodeOptions.java | 43 +-
.../rpc/impl/cli/GetLeaderRequestProcessor.java | 1 -
.../impl/core/AppendEntriesRequestProcessor.java | 52 +-
.../snapshot/local/LocalSnapshotCopier.java | 2 +-
.../snapshot/local/LocalSnapshotStorage.java | 4 +-
.../ignite/disruptor/StripedDisruptorTest.java | 2 +
.../ignite/internal/raft/RaftGroupServiceTest.java | 2 +-
.../ignite/raft/jraft/core/FSMCallerTest.java | 9 +-
.../raft/jraft/core/ReadOnlyServiceTest.java | 13 +-
.../core/AppendEntriesRequestProcessorTest.java | 28 +-
.../impl/core/BaseNodeRequestProcessorTest.java | 2 +-
.../raft/jraft/storage/impl/LogManagerTest.java | 15 +-
.../ItPlacementDriverReplicaSideTest.java | 70 +-
.../raft/client/TopologyAwareRaftGroupService.java | 2 +-
.../apache/ignite/internal/replicator/Replica.java | 51 +-
.../ignite/internal/replicator/ReplicaManager.java | 92 +-
.../ignite/internal/replicator/ReplicaService.java | 42 +-
.../ReplicationConfigurationSchema.java | 5 +
.../exception/PrimaryReplicaMissException.java | 14 +
.../message/PrimaryReplicaChangeCommand.java | 33 +
.../replicator/message/ReplicaMessageGroup.java | 3 +
.../replicator/PlacementDriverReplicaSideTest.java | 7 +-
.../internal/replicator/ReplicaManagerTest.java | 11 +-
.../AbstractTopologyAwareGroupServiceTest.java | 70 +-
modules/rest/build.gradle | 1 +
.../rest/ItInitializedClusterRestTest.java | 3 +-
.../ignite/internal/rest/RestComponentTest.java | 2 +-
.../ClusterConfigurationControllerTest.java | 2 +-
.../NodeConfigurationControllerTest.java | 2 +-
.../apache/ignite/internal/rocksdb/RocksUtils.java | 3 +-
.../rocksdb/flush/RocksDbFlushListener.java | 19 +-
.../internal/rocksdb/flush/RocksDbFlusher.java | 16 +-
modules/runner/build.gradle | 6 +
.../configuration/generator/DefaultsGenerator.java | 3 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 8 +-
.../benchmark/CriteriaEmbeddedNodeBenchmark.java | 18 +-
.../benchmark/CriteriaThinClientBenchmark.java | 10 +-
.../ignite/internal/benchmark/InsertBenchmark.java | 37 +-
.../ignite/internal/benchmark/SelectBenchmark.java | 53 +-
.../ignite/internal/benchmark/SqlBenchmark.java | 18 +-
.../internal/benchmark/SqlIndexScanBenchmark.java | 240 ++++++
.../benchmark/SqlMultiStatementBenchmark.java | 56 +-
.../benchmark/SqlPartitionPruningBenchmark.java | 78 +-
.../ignite/internal/benchmark/TpchBenchmark.java | 30 +-
.../ItDistributedConfigurationPropertiesTest.java | 6 +-
.../ItNodeBootstrapConfigurationTest.java | 2 +-
.../configuration/ItNodeConfigurationFileTest.java | 2 +-
.../ItDistributedConfigurationStorageTest.java | 6 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 29 +-
.../runner/app/AbstractSchemaChangeTest.java | 23 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 71 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 51 +-
.../runner/app/ItIgniteNodeRestartTest.java | 299 ++++---
.../internal/runner/app/ItNoThreadsLeftTest.java | 7 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 1 +
.../internal/runner/app/ItSingleNodeTest.java | 5 +-
.../internal/runner/app/ItTablesApiTest.java | 84 +-
.../runner/app/PlatformTestNodeRunner.java | 69 +-
.../app/client/ItAbstractThinClientTest.java | 14 +-
.../client/ItCustomKeyColumnOrderClientTest.java | 398 +++++++++
.../client/ItCustomKeyColumnOrderEmbeddedTest.java | 30 +
.../app/client/ItThinClientAuthenticationTest.java | 7 +-
.../runner/app/client/ItThinClientComputeTest.java | 20 +-
.../app/client/ItThinClientConnectionTest.java | 19 +-
.../app/client/ItThinClientMarshallingTest.java | 25 +-
.../client/ItThinClientPartitionAwarenessTest.java | 2 +-
.../ItThinClientSchemaSynchronizationTest.java | 44 +-
.../runner/app/client/ItThinClientSqlTest.java | 108 ++-
.../ItSchemaForwardCompatibilityTest.java | 4 +-
.../schemasync/ItSchemaSyncAndReplicationTest.java | 10 +-
.../schemasync/ItSchemaSyncMultiNodeTest.java | 2 +-
.../schemasync/ItSchemaSyncSingleNodeTest.java | 8 +-
.../streamer/ItAbstractDataStreamerTest.java | 35 +-
.../streamer/ItServerDataStreamerTest.java | 3 -
.../ignite/internal/table/ItDurableFinishTest.java | 216 +++--
.../ignite/internal/table/ItInternalTableTest.java | 86 +-
.../internal/table/ItPublicApiColocationTest.java | 31 +-
.../internal/table/ItReadOnlyTransactionTest.java | 56 +-
.../internal/table/ItTablePutGetEmbeddedTest.java | 114 +++
.../internal/table/ItTablePutGetThinTest.java | 35 +
.../ignite/internal/table/ItTableScanTest.java | 29 +-
.../internal/table/ItThinClientColocationTest.java | 12 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 185 ++--
.../ignite/internal/app/ThreadPoolsManager.java | 3 +-
.../storage/LocalFileConfigurationStorage.java | 49 +-
.../storage/LocalFileConfigurationStorageTest.java | 36 +-
.../ignite/internal/BaseIgniteRestartTest.java | 4 +
.../java/org/apache/ignite/internal/Cluster.java | 32 +-
.../internal/ClusterPerClassIntegrationTest.java | 157 ++--
.../internal/ClusterPerTestIntegrationTest.java | 11 +
.../ignite/internal/IgniteIntegrationTest.java | 12 -
.../org/apache/ignite/internal/IndexTestUtils.java | 43 +
.../ignite/internal/PublicApiThreadingTests.java | 81 ++
.../org/apache/ignite/internal/SessionUtils.java | 22 +-
.../ignite/internal/TestDefaultProfilesNames.java | 31 +
.../org/apache/ignite/internal/TestWrappers.java | 102 +++
.../apache/ignite/internal/table/NodeUtils.java | 147 ++--
.../internal/test/WatchListenerInhibitor.java | 16 +
modules/schema/build.gradle | 2 +-
.../ignite/internal/schema/BinaryRowConverter.java | 17 +-
.../ignite/internal/schema/BinaryTupleSchema.java | 38 +-
.../org/apache/ignite/internal/schema/Column.java | 145 ++--
.../org/apache/ignite/internal/schema/Columns.java | 376 --------
.../ignite/internal/schema/SchemaDescriptor.java | 252 +++---
.../ignite/internal/schema/SchemaManager.java | 37 +-
.../apache/ignite/internal/schema/SchemaUtils.java | 33 +-
.../CatalogToSchemaDescriptorConverter.java | 27 +-
.../LowWatermarkConfigurationSchema.java | 12 +-
.../storage/DataStorageConfigurationSchema.java | 32 -
.../internal/schema/mapping/ColumnMapperImpl.java | 2 +-
.../internal/schema/marshaller/KvMarshaller.java | 9 +
.../internal/schema/marshaller/MarshallerUtil.java | 10 +-
.../marshaller/asm/AsmMarshallerGenerator.java | 30 +-
.../marshaller/reflection/KvMarshallerImpl.java | 43 +-
.../marshaller/reflection/ObjectStatistics.java | 9 +-
.../reflection/RecordMarshallerImpl.java | 18 +-
.../schema/marshaller/reflection/RowReader.java | 98 ++-
.../schema/AbstractSchemaSerializer.java | 116 ---
.../schema/marshaller/schema/SchemaSerializer.java | 50 --
.../marshaller/schema/SchemaSerializerImpl.java | 951 ---------------------
.../schema/registry/UpgradingRowAdapter.java | 2 +-
.../org/apache/ignite/internal/schema/row/Row.java | 28 +-
.../ignite/internal/schema/row/RowAssembler.java | 13 -
.../internal/schema/BinaryRowConverterTest.java | 132 +++
.../internal/schema/BinaryTupleSchemaTest.java | 100 ++-
.../internal/schema/ColumnDefinitionTest.java | 56 --
.../apache/ignite/internal/schema/ColumnsTest.java | 458 ----------
.../org/apache/ignite/internal/schema/RowTest.java | 6 +-
.../internal/schema/SchemaColumnMapperTest.java | 45 +-
.../internal/schema/SchemaDescriptorTest.java | 94 --
.../ignite/internal/schema/SchemaManagerTest.java | 20 +-
.../CatalogToSchemaDescriptorConverterTest.java | 24 +-
.../schema/marshaller/KvMarshallerTest.java | 294 ++++++-
.../schema/registry/SchemaRegistryImplTest.java | 4 +-
.../schema/registry/UpgradingRowAdapterTest.java | 6 +-
.../schema/serializer/AbstractSerializerTest.java | 380 --------
.../AuthenticationProviderConfigurationSchema.java | 1 -
modules/security/build.gradle | 1 +
.../authentication/AuthenticationManagerImpl.java | 17 +-
.../AuthenticationManagerImplTest.java | 2 +-
modules/sql-engine/build.gradle | 5 +
.../ignite/internal/sql/api/ItCommonApiTest.java | 80 +-
.../sql/api/ItKvKeyColumnPositionTest.java | 382 +++++++++
.../sql/api/ItRecordViewKeyPositionsTest.java | 248 ++++++
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 452 +++++-----
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 63 +-
.../sql/api/ItSqlClientAsynchronousApiTest.java | 32 +-
.../internal/sql/api/ItSqlClientMetricsTest.java | 64 +-
.../sql/api/ItSqlClientSynchronousApiTest.java | 20 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 54 +-
.../sql/engine/BaseSqlMultiStatementTest.java | 9 +-
.../internal/sql/engine/ItAggregatesTest.java | 195 ++++-
.../internal/sql/engine/ItCorrelatesTest.java | 56 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 161 +++-
.../internal/sql/engine/ItDataTypesTest.java | 4 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 44 +-
.../internal/sql/engine/ItFunctionsTest.java | 2 +
.../sql/engine/ItIndexAvailabilityTest.java | 62 ++
.../ignite/internal/sql/engine/ItIndexDdlTest.java | 66 +-
.../internal/sql/engine/ItIndexSpoolTest.java | 8 +-
.../sql/engine/ItIndexesSystemViewTest.java | 2 +-
.../internal/sql/engine/ItKeyValueGetTest.java | 124 ---
.../internal/sql/engine/ItKeyValuePutTest.java | 143 ----
.../internal/sql/engine/ItLimitOffsetTest.java | 21 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 4 +-
.../internal/sql/engine/ItMultistatementTest.java | 19 +-
.../internal/sql/engine/ItOrToUnionRuleTest.java | 2 -
.../sql/engine/ItPkOnlyTableCrossApiTest.java | 13 +-
.../engine/ItSecondaryIndexMultiRangeScanTest.java | 369 ++++++++
.../internal/sql/engine/ItSecondaryIndexTest.java | 66 +-
.../ignite/internal/sql/engine/ItSetOpTest.java | 59 +-
.../sql/engine/ItSqlMultiStatementTest.java | 3 +-
.../sql/engine/ItSqlUsesKeyValueGetTest.java | 121 +++
.../sql/engine/ItSqlUsesKeyValuePutTest.java | 140 +++
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 14 +-
.../internal/sql/engine/ItZonesSystemViewTest.java | 6 +-
.../engine/datatypes/tests/BaseDataTypeTest.java | 3 +-
.../datatypes/tests/BaseIndexDataTypeTest.java | 2 +-
.../sql/engine/datatypes/uuid/ItUuidIndexTest.java | 7 -
.../internal/sql/sqllogic/ItSqlLogicTest.java | 13 +-
.../internal/sql/sqllogic/ScriptContext.java | 33 +-
.../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 +
.../integrationTest/sql/types/time/test_time.test | 35 +
.../sql/types/time/test_time.test_ignore | 32 -
.../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 | 5 +
.../src/main/codegen/includes/parserImpls.ftl | 60 +-
.../internal/sql/api/AntiHijackAsyncResultSet.java | 74 ++
.../internal/sql/api/AsyncResultSetImpl.java | 14 +-
.../internal/sql/api/IdleExpirationTracker.java | 99 ---
.../ignite/internal/sql/api/IgniteSqlImpl.java | 640 ++++++++++++--
.../sql/api/PublicApiThreadingIgniteSql.java | 177 ++++
.../internal/sql/api/SessionBuilderImpl.java | 232 -----
.../apache/ignite/internal/sql/api/SessionId.java | 66 --
.../ignite/internal/sql/api/SessionImpl.java | 667 ---------------
.../internal/sql/api/StatementBuilderImpl.java | 19 +-
.../ignite/internal/sql/api/StatementImpl.java | 7 +-
.../ignite/internal/sql/engine/QueryProcessor.java | 32 +-
.../internal/sql/engine/SqlQueryProcessor.java | 181 ++--
.../sql/engine/exec/DestinationFactory.java | 27 +-
.../sql/engine/exec/DynamicPartitionProvider.java | 60 ++
.../sql/engine/exec/ExchangeServiceImpl.java | 18 +-
.../engine/exec/ExecutableTableRegistryImpl.java | 18 +-
.../internal/sql/engine/exec/ExecutionContext.java | 27 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 116 +--
.../sql/engine/exec/LogicalRelImplementor.java | 20 +-
.../sql/engine/exec/PartitionProvider.java | 62 ++
.../sql/engine/exec/QueryTaskExecutorImpl.java | 44 +-
.../engine/exec/RehashingPartitionExtractor.java | 4 +
.../sql/engine/exec/SqlOutputBinaryRow.java | 22 +-
.../sql/engine/exec/StaticPartitionProvider.java | 45 +
.../engine/exec/TableRowConverterFactoryImpl.java | 70 --
.../sql/engine/exec/TableRowConverterImpl.java | 63 +-
.../sql/engine/exec/UpdatableTableImpl.java | 14 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 126 ++-
.../exec/ddl/DdlToCatalogCommandConverter.java | 49 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 201 ++++-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 80 ++
.../internal/sql/engine/exec/exp/RexImpTable.java | 3 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 24 +-
.../sql/engine/exec/exp/agg/Accumulators.java | 5 +-
.../sql/engine/exec/mapping/ColocationGroup.java | 25 +-
.../exec/mapping/ExecutionTargetFactory.java | 7 +-
.../engine/exec/mapping/FragmentDescription.java | 13 +-
.../sql/engine/exec/mapping/FragmentMapper.java | 2 +-
.../sql/engine/exec/mapping/MappedFragment.java | 23 +-
.../engine/exec/mapping/MappingServiceImpl.java | 3 +-
.../exec/mapping/smallcluster/AbstractTarget.java | 11 +-
.../mapping/smallcluster/SmallClusterFactory.java | 3 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 16 +-
.../sql/engine/exec/rel/IndexScanNode.java | 20 +-
.../sql/engine/exec/rel/TableScanNode.java | 21 +-
.../sql/engine/externalize/RelJsonReader.java | 25 +-
.../sql/engine/externalize/RelJsonWriter.java | 17 +
.../sql/engine/message/MessageServiceImpl.java | 14 +-
.../sql/engine/message/QueryBatchMessage.java | 3 +-
.../sql/engine/message/QueryStartRequest.java | 3 +-
.../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 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 2 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 4 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 13 +-
.../prepare/ddl/AlterZoneSetDefaultCommand.java | 34 +
.../sql/engine/prepare/ddl/CreateTableCommand.java | 56 ++
.../sql/engine/prepare/ddl/CreateZoneCommand.java | 43 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 323 ++++---
.../sql/engine/prepare/ddl/TableOptionEnum.java | 29 +
.../sql/engine/prepare/ddl/ZoneOptionEnum.java | 4 +-
.../prepare/pruning/PartitionPrunerImpl.java | 17 +-
.../prepare/pruning/PartitionPruningColumns.java | 91 +-
.../prepare/pruning/PartitionPruningMetadata.java | 7 +-
.../pruning/PartitionPruningMetadataExtractor.java | 235 ++++-
.../prepare/pruning/PartitionPruningPredicate.java | 91 +-
.../internal/sql/engine/rel/AbstractIndexScan.java | 9 +-
.../internal/sql/engine/rel/IgniteAggregate.java | 22 +-
.../internal/sql/engine/rel/IgniteMergeJoin.java | 3 +-
.../internal/sql/engine/rel/IgniteProject.java | 45 +-
.../engine/rel/agg/IgniteSortAggregateBase.java | 56 +-
.../sql/engine/rel/agg/MapReduceAggregates.java | 381 ++++++++-
.../engine/rule/HashAggregateConverterRule.java | 24 +-
.../sql/engine/rule/SetOpConverterRule.java | 5 +
.../engine/rule/SortAggregateConverterRule.java | 19 +-
.../sql/engine/rule/UnionConverterRule.java | 8 +-
.../sql/engine/rule/ValuesConverterRule.java | 4 +-
.../engine/rule/logical/LogicalOrToUnionRule.java | 7 +-
.../engine/sql/IgniteSqlAlterZoneSetDefault.java | 67 ++
.../sql/engine/sql/IgniteSqlCreateZone.java | 25 +-
.../sql/engine/sql/IgniteSqlKeyConstraint.java | 70 ++
.../engine/sql/IgniteSqlPrimaryKeyConstraint.java | 101 +++
.../engine/sql/IgniteSqlPrimaryKeyIndexType.java | 32 +
.../internal/sql/engine/sql/ParserServiceImpl.java | 27 -
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 27 +
.../sql/engine/trait/DistributionFunction.java | 2 +-
.../sql/engine/trait/DistributionTrait.java | 4 +-
.../internal/sql/engine/trait/Partitioned.java | 15 +-
.../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 | 22 +-
.../ignite/internal/sql/engine/util/PlanUtils.java | 12 +-
.../ignite/internal/sql/engine/util/RexUtils.java | 292 ++++++-
.../ignite/internal/sql/api/IgniteSqlImplTest.java | 346 ++++++--
.../ignite/internal/sql/api/SessionImplTest.java | 522 -----------
.../engine/QueryTransactionWrapperSelfTest.java | 6 +-
.../engine/benchmarks/TpchPrepareBenchmark.java | 3 +-
.../exec/ExecutableTableRegistrySelfTest.java | 10 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 38 +-
.../exec/IdentityDistributionFunctionSelfTest.java | 4 +-
.../sql/engine/exec/PartitionProvidersTest.java | 233 +++++
.../sql/engine/exec/TableRowConverterSelfTest.java | 121 +--
.../sql/engine/exec/TransactionEnlistTest.java | 175 ++++
.../DdlCommandHandlerExceptionHandlingTest.java | 16 +-
.../ddl/DistributionZoneDdlCommandHandlerTest.java | 5 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 261 +++++-
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 40 +
.../engine/exec/mapping/FragmentMappingTest.java | 6 +-
.../sql/engine/exec/mapping/FragmentPrinter.java | 24 +-
.../sql/engine/exec/mapping/MappingTestRunner.java | 30 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 17 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 5 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 24 +-
.../sql/engine/exec/rel/ExecutionTest.java | 25 +-
.../exec/rel/HashAggregateExecutionTest.java | 8 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 4 +-
.../exec/rel/IndexScanNodeExecutionTest.java | 4 +-
.../engine/exec/rel/ModifyNodeExecutionTest.java | 5 +-
.../exec/rel/SortAggregateExecutionTest.java | 8 +-
.../exec/rel/TableScanNodeExecutionTest.java | 36 +-
.../sql/engine/framework/TestBuilders.java | 154 +++-
.../internal/sql/engine/framework/TestCluster.java | 8 +-
.../sql/engine/framework/TestClusterTest.java | 67 ++
.../internal/sql/engine/framework/TestNode.java | 43 +-
.../planner/AbstractAggregatePlannerTest.java | 58 +-
.../sql/engine/planner/AbstractPlannerTest.java | 64 +-
.../sql/engine/planner/AggregatePlannerTest.java | 323 ++++---
.../planner/ColocatedHashAggregatePlannerTest.java | 91 +-
.../planner/ColocatedSortAggregatePlannerTest.java | 80 ++
.../planner/CorrelatedSubqueryPlannerTest.java | 2 +-
.../sql/engine/planner/DmlPlannerTest.java | 5 +-
.../planner/IndexSearchBoundsPlannerTest.java | 258 ++++--
.../engine/planner/MapReduceAggregatesTest.java | 11 +-
.../planner/MapReduceHashAggregatePlannerTest.java | 231 +++--
.../planner/MapReduceSortAggregatePlannerTest.java | 172 +++-
.../planner/PartitionPruningMetadataTest.java | 154 +++-
.../sql/engine/planner/PartitionPruningTest.java | 48 +-
.../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 | 160 +++-
.../DistributionZoneSqlToCommandConverterTest.java | 67 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 72 +-
.../pruning/PruningMetadataSerializationTest.java | 94 ++
.../engine/schema/SqlSchemaManagerImplTest.java | 54 +-
.../sql/engine/sql/ParserServiceImplTest.java | 143 +---
.../internal/sql/engine/sql/SqlDdlParserTest.java | 129 ++-
.../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 | 138 +++
.../sql-engine/src/test/resources/mapping/dml.test | 12 +-
.../resources/mapping/test_partition_pruning.test | 74 ++
.../src/test/resources/mapping/union.test | 50 +-
.../src/test/resources/tpch/plan/q1.plan | 7 +
.../internal/sql/engine/util/QueryChecker.java | 4 +-
.../internal/sql/engine/util/QueryCheckerImpl.java | 5 +-
.../internal/sql/engine/util/SqlTestUtils.java | 2 +-
.../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 | 4 +-
.../internal/storage/DataStorageManager.java | 89 +-
.../ignite/internal/storage/DataStorageModule.java | 9 +-
.../internal/storage/DataStorageModules.java | 95 +-
.../internal/storage/StorageClosedException.java | 2 +-
.../storage/StorageDestroyedException.java | 51 ++
.../storage/ThreadAssertingMvPartitionStorage.java | 8 +-
.../configurations/StorageConfigurationModule.java | 43 +
.../configurations/StorageConfigurationSchema.java | 44 +
.../StorageEngineConfigurationSchema.java | 27 +
.../StorageProfileConfigurationSchema.java | 37 +
.../internal/storage/engine/StorageEngine.java | 8 +
.../storage/engine/StorageTableDescriptor.java | 14 +-
.../engine/ThreadAssertingStorageEngine.java | 5 +
.../storage/index/BinaryTupleComparator.java | 6 +-
.../internal/storage/index/IndexStorage.java | 3 +-
.../index/StorageIndexDescriptorSupplier.java | 38 +-
.../storage/index/ThreadAssertingIndexStorage.java | 8 +-
.../ignite/internal/storage/util/StorageState.java | 13 +-
.../ignite/internal/storage/util/StorageUtils.java | 69 +-
.../internal/storage/DataStorageManagerTest.java | 157 ----
.../internal/storage/DataStorageModulesTest.java | 109 +--
.../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 | 878 +++++++++++++------
.../internal/storage/BaseMvStoragesTest.java | 2 +-
.../storage/engine/AbstractStorageEngineTest.java | 242 +++++-
.../storage/impl/TestDataStorageModule.java | 4 +-
.../storage/impl/TestMvPartitionStorage.java | 18 +-
.../TestPersistStorageConfigurationModule.java | 52 --
.../TestPersistStorageConfigurationSchema.java | 34 -
.../internal/storage/impl/TestStorageEngine.java | 5 +
.../impl/TestStorageLocalConfigurationModule.java | 4 +-
.../schema/TestDataStorageConfigurationSchema.java | 31 -
.../schema/TestProfileConfigurationSchema.java | 30 +
.../storage/index/AbstractIndexStorageTest.java | 6 +-
.../index/AbstractSortedIndexStorageTest.java | 39 +-
.../index/impl/AbstractTestIndexStorage.java | 53 +-
.../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 | 59 +-
.../PersistentPageMemoryTableStorage.java | 5 +-
.../pagememory/VolatilePageMemoryDataRegion.java | 6 +-
.../VolatilePageMemoryDataStorageModule.java | 15 +-
.../VolatilePageMemoryStorageEngine.java | 45 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 9 +-
.../configuration/PageMemoryDataRegionName.java | 34 -
.../PageMemoryDataRegionValidatorImpl.java | 93 --
...emoryStorageEngineLocalConfigurationModule.java | 38 +-
...PageMemoryStorageEngineConfigurationSchema.java | 41 -
...ntPageMemoryDataStorageConfigurationSchema.java | 38 -
...PageMemoryStorageEngineConfigurationSchema.java | 33 +-
...yStorageEngineExtensionConfigurationSchema.java | 31 +
...lePageMemoryDataStorageConfigurationSchema.java | 38 -
...PageMemoryStorageEngineConfigurationSchema.java | 35 +-
...yStorageEngineExtensionConfigurationSchema.java | 31 +
.../index/AbstractPageMemoryIndexStorage.java | 223 +++--
.../pagememory/index/hash/HashIndexTree.java | 87 +-
.../index/hash/PageMemoryHashIndexStorage.java | 63 +-
.../storage/pagememory/index/meta/IndexMeta.java | 38 +-
.../pagememory/index/meta/IndexMetaKey.java | 19 +
.../UpdateLastRowIdUuidToBuildInvokeClosure.java | 60 ++
.../UpdateLastRowIdUuidToBuiltInvokeClosure.java | 60 --
.../pagememory/index/meta/io/IndexMetaIo.java | 21 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 72 +-
.../pagememory/index/sorted/SortedIndexTree.java | 112 ++-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 315 ++-----
.../storage/pagememory/mv/IndexStorageFactory.java | 298 +++++++
.../storage/pagememory/mv/PageMemoryIndexes.java | 252 ++++++
.../mv/PersistentPageMemoryMvPartitionStorage.java | 93 +-
.../mv/RenewablePartitionStorageState.java | 17 +
.../storage/pagememory/mv/ScanVersionsCursor.java | 40 +-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 70 +-
.../PersistentPageMemoryDataRegionTest.java | 46 +-
.../PersistentPageMemoryMvTableStorageTest.java | 66 +-
.../VolatilePageMemoryMvTableStorageTest.java | 14 +-
.../PageMemoryDataRegionValidatorImplTest.java | 178 ----
...yStorageEngineLocalConfigurationModuleTest.java | 74 ++
.../PersistentPageMemoryStorageEngineTest.java | 10 +-
.../AbstractPageMemoryHashIndexStorageTest.java | 11 +-
.../AbstractPageMemorySortedIndexStorageTest.java | 9 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 25 +-
...PersistentPageMemorySortedIndexStorageTest.java | 19 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 17 +-
.../VolatilePageMemorySortedIndexStorageTest.java | 17 +-
.../storage/pagememory/mv/BlobStorageTest.java | 13 +-
.../pagememory/mv/PageMemoryIndexesTest.java | 106 +++
...ageMemoryMvPartitionStorageConcurrencyTest.java | 24 +-
...rsistentPageMemoryMvPartitionStorageGcTest.java | 24 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 23 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 14 +-
...VolatilePageMemoryMvPartitionStorageGcTest.java | 15 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 14 +-
.../storage/rocksdb/ColumnFamilyUtils.java | 2 +-
.../ignite/internal/storage/rocksdb/HashIndex.java | 85 +-
.../ignite/internal/storage/rocksdb/Index.java | 128 +++
.../internal/storage/rocksdb/IndexIdCursor.java | 173 ++++
.../storage/rocksdb/RocksDbDataRegion.java | 39 +-
.../storage/rocksdb/RocksDbDataStorageModule.java | 14 +-
.../internal/storage/rocksdb/RocksDbIndexes.java | 219 +++++
.../storage/rocksdb/RocksDbMetaStorage.java | 52 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 36 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 123 +--
.../storage/rocksdb/RocksDbStorageUtils.java | 23 +-
.../storage/rocksdb/RocksDbTableStorage.java | 188 +---
.../internal/storage/rocksdb/SortedIndex.java | 91 +-
.../configuration/RocksDbDataRegionName.java | 32 -
.../RocksDbDataRegionValidatorImpl.java | 56 --
...cksDbStorageEngineLocalConfigurationModule.java | 24 +-
.../RocksDbDataRegionConfigurationSchema.java | 60 --
.../RocksDbDataStorageConfigurationSchema.java | 38 -
.../schema/RocksDbProfileConfigurationSchema.java | 44 +
.../RocksDbStorageEngineConfigurationSchema.java | 23 +-
...bStorageEngineExtensionConfigurationSchema.java | 32 +
.../rocksdb/index/AbstractRocksDbIndexStorage.java | 94 +-
.../index/RocksDbBinaryTupleComparator.java | 43 +-
.../rocksdb/index/RocksDbHashIndexStorage.java | 32 +-
.../rocksdb/index/RocksDbSortedIndexStorage.java | 68 +-
.../rocksdb/instance/IndexColumnFamily.java | 40 +
.../rocksdb/instance/SharedRocksDbInstance.java | 303 +++++--
.../instance/SharedRocksDbInstanceCreator.java | 12 +-
.../storage/rocksdb/IndexIdCursorTest.java | 135 +++
.../RocksDbMvPartitionStorageConcurrencyTest.java | 16 +-
.../rocksdb/RocksDbMvPartitionStorageGcTest.java | 16 +-
.../rocksdb/RocksDbMvPartitionStorageTest.java | 16 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 17 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 46 +-
.../RocksDbDataRegionValidatorImplTest.java | 107 ---
.../rocksdb/engine/RocksDbStorageEngineTest.java | 8 +-
.../rocksdb/index/RocksDbHashIndexStorageTest.java | 16 +-
.../index/RocksDbSortedIndexStorageTest.java | 16 +-
.../instance/SharedRocksDbInstanceTest.java | 336 ++++++++
...apache.ignite.configuration.ConfigurationModule | 1 -
.../internal/systemview/SystemViewManagerTest.java | 6 +-
modules/table/build.gradle | 8 +
.../ItInternalTableReadOnlyOperationsTest.java | 2 +-
.../apache/ignite/distributed/ItLockTableTest.java | 24 +-
.../ItTxAbstractDistributedTestSingleNode.java | 44 +
.../ItTxDistributedCleanupRecoveryTest.java | 3 +-
...xDistributedTestSingleNodeNoCleanupMessage.java | 24 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 9 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 20 +-
.../ReplicasSafeTimePropagationTest.java | 98 +--
.../ItDisasterRecoveryReconfigurationTest.java | 70 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 21 +-
.../rebalance/ItRebalanceDistributedTest.java | 164 ++--
.../rebalance/ItRebalanceRecoveryTest.java | 10 +-
.../ignite/internal/rebalance/ItRebalanceTest.java | 4 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 16 +-
.../ignite/internal/table/ItColocationTest.java | 44 +-
.../ignite/internal/table/ItCriteriaQueryTest.java | 60 +-
.../internal/table/ItOperationRetryTest.java | 134 +++
.../table/ItTransactionPrimaryChangeTest.java | 221 +++++
.../internal/table/ItTransactionRecoveryTest.java | 68 +-
.../threading/ItKvRecordApiThreadingTest.java | 352 ++++++--
.../threading/ItTablesApiThreadingTest.java | 95 ++
...apache.ignite.configuration.ConfigurationModule | 1 -
.../schema/marshaller/TupleMarshallerImpl.java | 20 +-
.../internal/table/AbstractRowTupleAdapter.java | 78 +-
.../ignite/internal/table/AbstractTableView.java | 90 +-
.../internal/table/AntiHijackAsyncCursor.java | 67 ++
.../apache/ignite/internal/table/DataStreamer.java | 15 +-
.../ignite/internal/table/InternalTable.java | 8 +
.../internal/table/KeyValueBinaryViewImpl.java | 49 +-
...aluePojoStreamerPartitionAwarenessProvider.java | 2 +-
.../ignite/internal/table/KeyValueViewImpl.java | 59 +-
.../ignite/internal/table/LongPriorityQueue.java | 124 +++
.../PojoStreamerPartitionAwarenessProvider.java | 2 +-
.../table/PublicApiThreadingKeyValueView.java | 244 ++++++
.../table/PublicApiThreadingRecordView.java | 218 +++++
.../internal/table/PublicApiThreadingViewBase.java | 91 ++
.../internal/table/RecordBinaryViewImpl.java | 49 +-
.../ignite/internal/table/RecordViewImpl.java | 77 +-
.../apache/ignite/internal/table/TableImpl.java | 20 +-
.../org/apache/ignite/internal/table/TableRow.java | 21 +-
.../CatalogStorageIndexDescriptorSupplier.java | 73 ++
.../table/distributed/DroppedTableInfo.java | 67 ++
.../internal/table/distributed/IndexLocker.java | 5 +-
.../internal/table/distributed/LowWatermark.java | 280 ------
.../distributed/LowWatermarkChangedListener.java | 37 -
.../PartitionReplicatorNodeRecovery.java | 2 +-
.../PublicApiThreadingIgniteTables.java | 94 ++
.../table/distributed/PublicApiThreadingTable.java | 80 ++
.../table/distributed/SortedIndexLocker.java | 9 +-
.../internal/table/distributed/TableManager.java | 326 ++++---
.../table/distributed/TableMessageGroup.java | 17 +
.../internal/table/distributed/TableUtils.java | 39 +
.../table/distributed/command/FinishTxCommand.java | 6 +
.../distributed/command/UpdateAllCommand.java | 5 +
.../table/distributed/command/UpdateCommand.java | 3 +
.../disaster/DisasterRecoveryManager.java | 392 +++++++++
.../disaster/DisasterRecoveryRequest.java | 51 ++
.../disaster/LocalPartitionStateEnum.java | 41 +
.../disaster/ManualGroupUpdateRequest.java | 106 +++
.../disaster/messages/LocalPartitionState.java | 41 +
.../messages/LocalPartitionStatesRequest.java | 32 +
.../messages/LocalPartitionStatesResponse.java | 31 +
.../ignite/internal/table/distributed/gc/MvGc.java | 2 +-
.../distributed/index/IndexUpdateHandler.java | 125 ++-
.../table/distributed/index/IndexUtils.java | 31 +-
.../index/TableRowToIndexKeyConverter.java | 2 +-
.../table/distributed/raft/PartitionListener.java | 106 ++-
.../snapshot/FullStateTransferIndexChooser.java | 147 +++-
.../distributed/raft/snapshot/PartitionAccess.java | 7 +
.../raft/snapshot/PartitionAccessImpl.java | 13 +-
.../raft/snapshot/ReadOnlyIndexInfo.java | 34 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 47 +-
.../raft/snapshot/outgoing/SnapshotMetaUtils.java | 2 +-
.../request/SingleRowReplicaRequest.java | 2 +
.../replicator/PartitionReplicaListener.java | 514 ++++++++---
.../replicator/TransactionStateResolver.java | 21 +-
.../distributed/schema/SchemaVersionsImpl.java | 16 +-
.../distributed/storage/InternalTableImpl.java | 335 ++++++--
.../TupleMarshallerFixlenOnlyBenchmark.java | 12 +-
.../TupleMarshallerVarlenOnlyBenchmark.java | 10 +-
.../table/ColocationHashCalculationTest.java | 14 +-
.../internal/table/InteropOperationsTest.java | 6 +-
.../table/KeyValueBinaryViewOperationsTest.java | 10 +-
.../internal/table/KeyValueViewOperationsTest.java | 2 -
.../internal/table/LongPriorityQueueSelfTest.java | 174 ++++
.../internal/table/MutableRowTupleAdapterTest.java | 54 +-
.../table/RecordBinaryViewOperationsTest.java | 20 +-
.../internal/table/RecordViewOperationsTest.java | 4 +-
.../CatalogStorageIndexDescriptorSupplierTest.java | 221 +++++
.../internal/table/distributed/IndexBaseTest.java | 4 +-
.../table/distributed/LowWatermarkTest.java | 197 -----
.../table/distributed/SortedIndexLockerTest.java | 68 ++
.../table/distributed/StorageCleanupTest.java | 4 +-
.../distributed/StorageUpdateHandlerTest.java | 4 +-
.../distributed/TableManagerRecoveryTest.java | 462 ++++++++++
.../table/distributed/TableManagerTest.java | 73 +-
.../internal/table/distributed/TableUtilsTest.java | 215 +++--
.../PartitionRaftCommandsSerializationTest.java | 2 +
.../PersistentPageMemoryGcUpdateHandlerTest.java | 22 +-
.../distributed/gc/RocksDbGcUpdateHandlerTest.java | 18 +-
.../gc/VolatilePageMemoryGcUpdateHandlerTest.java | 18 +-
.../distributed/index/IndexUpdateHandlerTest.java | 232 ++++-
.../raft/PartitionCommandListenerTest.java | 280 ++++--
.../FullStateTransferIndexChooserTest.java | 67 +-
.../raft/snapshot/PartitionAccessImplTest.java | 7 +-
.../incoming/IncomingSnapshotCopierTest.java | 28 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 8 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 7 +-
.../PartitionReplicaListenerIndexLockingTest.java | 9 +-
.../replication/PartitionReplicaListenerTest.java | 96 ++-
.../SchemaCompatibilityValidatorTest.java | 2 +-
.../schema/CatalogValidationSchemasSourceTest.java | 6 +-
.../PartitionCommandsMarshallerImplTest.java | 2 +
.../distributed/storage/InternalTableImplTest.java | 13 +-
.../table/type/NumericTypesSerializerTest.java | 38 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 151 +++-
.../distributed/TestPartitionDataStorage.java | 9 +-
.../ignite/internal/table/TableTestUtils.java | 55 +-
.../ignite/internal/table/TxAbstractTest.java | 7 +-
.../table/impl/DummyInternalTableImpl.java | 53 +-
.../table/impl/DummyValidationSchemasSource.java | 10 +-
modules/transactions/build.gradle | 2 +
.../ignite/internal/tx/ItMultipleLocksTest.java | 53 ++
.../tx/ItTransactionsApiThreadingTest.java | 169 ++++
.../org/apache/ignite/internal/tx/TxManager.java | 57 +-
.../java/org/apache/ignite/internal/tx/TxMeta.java | 17 +-
.../org/apache/ignite/internal/tx/TxStateMeta.java | 60 +-
.../ignite/internal/tx/UpdateCommandResult.java | 100 +++
.../TransactionConfigurationSchema.java | 21 +
.../impl/FinishedReadOnlyTransactionTracker.java | 61 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 4 +-
.../ignite/internal/tx/impl/OrphanDetector.java | 3 +-
.../internal/tx/impl/PlacementDriverHelper.java | 60 +-
.../impl/PublicApiThreadingIgniteTransactions.java | 67 ++
.../tx/impl/PublicApiThreadingTransaction.java | 133 +++
.../internal/tx/impl/ReadOnlyTransactionImpl.java | 9 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 2 +-
.../internal/tx/impl/ResourceCleanupManager.java | 146 ----
.../internal/tx/impl/ResourceVacuumManager.java | 167 ++++
.../internal/tx/impl/TransactionInflights.java | 321 +++++++
.../internal/tx/impl/TxCleanupRequestHandler.java | 121 ++-
.../internal/tx/impl/TxCleanupRequestSender.java | 114 ++-
.../ignite/internal/tx/impl/TxManagerImpl.java | 366 +++-----
.../ignite/internal/tx/impl/TxMessageSender.java | 59 +-
.../tx/impl/VolatileTxStateMetaStorage.java | 67 +-
.../tx/impl/WriteIntentSwitchProcessor.java | 9 +-
.../internal/tx/message/CleanupReplicatedInfo.java | 48 ++
.../tx/message/TxCleanupMessageResponse.java | 6 +
.../tx/message/TxCleanupRecoveryRequest.java | 29 +
.../ignite/internal/tx/message/TxMessageGroup.java | 5 +
.../message/WriteIntentSwitchReplicatedInfo.java | 53 ++
.../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 | 41 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 73 +-
.../internal/tx/impl/OrphanDetectorTest.java | 6 +-
.../tx/impl/ReadOnlyTransactionImplTest.java | 6 +-
.../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 +
.../internal/worker/CriticalWorkerWatchdog.java | 33 +-
.../ignite/internal/worker/ThreadAssertions.java | 41 +-
.../internal/worker/ThreadAssertionsTest.java | 95 ++
settings.gradle | 4 +
1332 files changed, 47576 insertions(+), 24292 deletions(-)
delete mode 100644 .run/All checks [PMD, modernizer, checkstyle].run.xml
create mode 100644 .run/All checks [PMD, spotbugs, checkstyle].run.xml
delete mode 100644 .run/Modernizer check [modernizer].run.xml
create mode 100644 .run/PMD [pmdMain pmdTest].run.xml
delete mode 100644 .run/PMD [pmdMain].run.xml
create mode 100644 .run/Spotbugs check [spotbugsMain].run.xml
delete mode 100644 check-rules/checkstyle-disabled-modules.xml
delete mode 100644 check-rules/modernizer-rules.xml
create mode 100644 check-rules/spotbugs-excludes.xml
delete mode 100644
modules/api/src/main/java/org/apache/ignite/catalog/ZoneEngine.java
delete mode 100644 modules/api/src/main/java/org/apache/ignite/sql/Session.java
delete mode 100644
modules/api/src/main/java/org/apache/ignite/sql/reactive/ReactiveResultSet.java
delete mode 100644
modules/api/src/main/java/org/apache/ignite/sql/reactive/package-info.java
delete mode 100644
modules/arch-test/src/test/java/org/apache/ignite/internal/ConfigurationModuleArchTest.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/CatalogVersionAwareValidationException.java
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/ClockWaiter.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/AlterZoneSetDefaultCatalogCommand.java
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/DataStorageParams.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/StorageProfileParams.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/TableHashPrimaryKey.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/TablePrimaryKey.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/TableSortedPrimaryKey.java
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
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/events/DestroyIndexEvent.java
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/events/DestroyIndexEventParameters.java
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/events/DestroyTableEvent.java
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/events/DestroyTableEventParameters.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/ClockWaiterTest.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/commands/TablePrimaryKeyTest.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/main/java/org/apache/ignite/internal/cli/commands/treesitter/highlighter/JsonAnsiHighlighter.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/treesitter/highlighter/SqlAttributedStringHighlighter.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/treesitter/parser/Indexer.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/treesitter/parser/JsonTokenType.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/treesitter/parser/Parser.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/treesitter/parser/SqlTokenType.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/completer/LazyDynamicCompleter.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/config/ClientConnectorConfig.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/config/RootConfig.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/cluster/config/ConfigUpdateCommandTest.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/treesitter/parser/JsonIndexerTest.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/treesitter/parser/SqlIndexerTest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlProperties.java
delete mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSession.java
delete mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSessionBuilder.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeAsyncResultSet.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeIgniteSql.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSessionBuilder.java
delete mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSqlRow.java
delete mode 100644
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/StorageProfileConfigurationSchema.java
delete mode 100644
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/StorageProfilesConfigurationSchema.java
create mode 100644
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/raft/CmgStorageException.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%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/components/LogSyncer.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/hlc/ClockService.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/hlc/ClockServiceImpl.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/hlc/ClockWaiter.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/replicator/ReplicatorConstants.java
delete mode 100755
modules/core/src/main/java/org/apache/ignite/internal/sql/AbstractSession.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/wrapper/Wrapper.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/wrapper/Wrappers.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/hlc/ClockWaiterTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/thread/PublicApiThreadingTest.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/hlc/TestClockService.java
delete mode 100644
modules/distribution-zones/src/integrationTest/java/org/apache/ignite/internal/distributionzones/ItDistributionZonesFilterTest.java
create mode 100644
modules/distribution-zones/src/integrationTest/java/org/apache/ignite/internal/distributionzones/ItDistributionZonesFiltersTest.java
delete mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/disaster/DisasterRecoveryManager.java
delete mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/disaster/DisasterRecoveryRequest.java
delete mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/disaster/ManualGroupUpdateRequest.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/DistributionZoneAttributeFiltersTest.java
delete mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/DistributionZoneFiltersTest.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/DistributionZoneManagerStorageProfilesFilterTest.java
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/build.gradle
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
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/impl/InMemoryCollectionSink.java
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/impl/InMemoryCollectionSinkConfigurationSchema.java
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/impl/ItEventLogConfigurationTest.java
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/impl/TestEventTypes.java
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/impl/TestSinkFactory.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/Event.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/EventChannel.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/EventFactory.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/EventLog.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/IgniteEventType.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/IgniteEvents.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/Sink.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/EventLogConfigurationModule.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/ChannelConfigurationSchema.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/EventLogConfigurationSchema.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/EventTypeValidatorImpl.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/LogSinkConfigurationSchema.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/SinkConfigurationSchema.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/ValidEventType.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/EventBuilder.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/EventImpl.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/EventTypeRegistry.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/EventUser.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/InvalidEventTypeException.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/InvalidProductVersionException.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/MissingEventTypeException.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/MissingEventUserException.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/event/exception/NotUniqueEventTypeException.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/ChannelFactory.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/ChannelRegistry.java
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
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/EventChannelImpl.java
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
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/SinkFactory.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/SinkRegistry.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/ser/EventSerializer.java
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/event/EventBuilderTest.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/event/EventTypeRegistryTest.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/event/IgniteEventsTest.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
create mode 100755
modules/failure-handler/src/testFixtures/java/org/apache/ignite/internal/failure/NoOpFailureProcessor.java
create mode 100644
modules/index/src/integrationTest/java/org/apache/ignite/internal/index/ItIndexAndIndexStorageDestructionTest.java
delete mode 100644
modules/index/src/main/java/org/apache/ignite/internal/index/IndexChooser.java
delete mode 100644
modules/index/src/test/java/org/apache/ignite/internal/index/IndexChooserTest.java
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/jdbc/ItJdbcClientTimeZoneTest.java
create mode 100644 modules/low-watermark/README.md
create mode 100644 modules/low-watermark/build.gradle
create mode 100644
modules/low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/LowWatermark.java
create mode 100644
modules/low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/LowWatermarkCandidate.java
create mode 100644
modules/low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/LowWatermarkChangedListener.java
create mode 100644
modules/low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/LowWatermarkImpl.java
create mode 100644
modules/low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/message/GetLowWatermarkRequest.java
create mode 100644
modules/low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/message/GetLowWatermarkResponse.java
create mode 100644
modules/low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/message/LowWatermarkMessageGroup.java
create mode 100644
modules/low-watermark/src/test/java/org/apache/ignite/internal/lowwatermark/LowWatermarkImplTest.java
create mode 100644
modules/low-watermark/src/testFixtures/java/org/apache/ignite/internal/lowwatermark/TestLowWatermark.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/BasePageMemoryDataRegionConfigurationSchema.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/PersistentPageMemoryDataRegionConfigurationSchema.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/PersistentPageMemoryProfileConfigurationSchema.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/VolatilePageMemoryDataRegionConfigurationSchema.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/VolatilePageMemoryProfileConfigurationSchema.java
delete mode 100644
modules/placement-driver/src/integrationTest/resources/META-INF/services/org.apache.ignite.configuration.ConfigurationModule
create mode 100644
modules/placement-driver/src/test/java/org/apache/ignite/internal/placementdriver/LeaseNegotiationTest.java
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
create mode 100644 modules/platforms/cpp/ignite/client/compute/job_state.h
create mode 100644 modules/platforms/cpp/ignite/client/compute/job_status.h
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
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/ClientSocket.Metrics.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/MetricsContext.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/MetricTags.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Table/DataStreamerItem.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Table/DataStreamerOperationType.cs
create mode 100644
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/PrimaryReplicaChangeCommand.java
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
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItCustomKeyColumnOrderEmbeddedTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItTablePutGetEmbeddedTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItTablePutGetThinTest.java
create mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/IndexTestUtils.java
create mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/PublicApiThreadingTests.java
create mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/TestDefaultProfilesNames.java
create mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/TestWrappers.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/Columns.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage/DataStorageConfigurationSchema.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/schema/AbstractSchemaSerializer.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/schema/SchemaSerializer.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/schema/SchemaSerializerImpl.java
create mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/BinaryRowConverterTest.java
delete mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/ColumnDefinitionTest.java
delete mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/ColumnsTest.java
delete mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/SchemaDescriptorTest.java
delete mode 100644
modules/schema/src/test/java/org/apache/ignite/internal/schema/serializer/AbstractSerializerTest.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/ItIndexAvailabilityTest.java
delete mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItKeyValueGetTest.java
delete mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItKeyValuePutTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSecondaryIndexMultiRangeScanTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlUsesKeyValueGetTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlUsesKeyValuePutTest.java
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
create mode 100644
modules/sql-engine/src/integrationTest/sql/types/time/test_time.test
delete mode 100644
modules/sql-engine/src/integrationTest/sql/types/time/test_time.test_ignore
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
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/IdleExpirationTracker.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/PublicApiThreadingIgniteSql.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/SessionBuilderImpl.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/SessionId.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/SessionImpl.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/DynamicPartitionProvider.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/PartitionProvider.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/StaticPartitionProvider.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/AlterZoneSetDefaultCommand.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/TableOptionEnum.java
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/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlKeyConstraint.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlPrimaryKeyConstraint.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlPrimaryKeyIndexType.java
delete mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/api/SessionImplTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/PartitionProvidersTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/TransactionEnlistTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/TpchQueryPlannerTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/prepare/pruning/PruningMetadataSerializationTest.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
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/StorageDestroyedException.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageConfigurationModule.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageConfigurationSchema.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageEngineConfigurationSchema.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/configurations/StorageProfileConfigurationSchema.java
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
delete mode 100644
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestPersistStorageConfigurationModule.java
delete mode 100644
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestPersistStorageConfigurationSchema.java
delete mode 100644
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/schema/TestDataStorageConfigurationSchema.java
create mode 100644
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/schema/TestProfileConfigurationSchema.java
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
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/PersistentPageMemoryStorageEngineExtensionConfigurationSchema.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/VolatilePageMemoryDataStorageConfigurationSchema.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/configuration/schema/VolatilePageMemoryStorageEngineExtensionConfigurationSchema.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/meta/UpdateLastRowIdUuidToBuildInvokeClosure.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/meta/UpdateLastRowIdUuidToBuiltInvokeClosure.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/IndexStorageFactory.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/PageMemoryIndexes.java
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
create mode 100644
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/mv/PageMemoryIndexesTest.java
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/Index.java
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/IndexIdCursor.java
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbIndexes.java
delete mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/RocksDbDataRegionName.java
delete mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/RocksDbDataRegionValidatorImpl.java
delete mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/RocksDbDataRegionConfigurationSchema.java
delete mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/RocksDbDataStorageConfigurationSchema.java
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/RocksDbProfileConfigurationSchema.java
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/RocksDbStorageEngineExtensionConfigurationSchema.java
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/instance/IndexColumnFamily.java
create mode 100644
modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/IndexIdCursorTest.java
delete mode 100644
modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/configuration/RocksDbDataRegionValidatorImplTest.java
create mode 100644
modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/instance/SharedRocksDbInstanceTest.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/ItOperationRetryTest.java
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/AntiHijackAsyncCursor.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/LongPriorityQueue.java
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/CatalogStorageIndexDescriptorSupplier.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/DroppedTableInfo.java
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/LowWatermark.java
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/LowWatermarkChangedListener.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
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/DisasterRecoveryRequest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/LocalPartitionStateEnum.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/ManualGroupUpdateRequest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages/LocalPartitionState.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages/LocalPartitionStatesRequest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages/LocalPartitionStatesResponse.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/LongPriorityQueueSelfTest.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/CatalogStorageIndexDescriptorSupplierTest.java
delete mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/LowWatermarkTest.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/SortedIndexLockerTest.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/TableManagerRecoveryTest.java
create mode 100644
modules/transactions/src/integrationTest/java/org/apache/ignite/internal/tx/ItMultipleLocksTest.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
delete mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ResourceCleanupManager.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ResourceVacuumManager.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TransactionInflights.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/CleanupReplicatedInfo.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/TxCleanupRecoveryRequest.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/WriteIntentSwitchReplicatedInfo.java
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
