This is an automated email from the ASF dual-hosted git repository.
apolovtsev pushed a change to branch ignite-20086
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit a93737b3ef Implement ArchUnit rule to detect wrong test classes
hierarchy.
add 3e15298821 IGNITE-20148 Explicit writeIntent cleanup on primary
replica (#2405)
add 86b9b2a1dd IGNITE-19835 Java client: Reject POJOs and Tuples with
unmapped fields (#2401)
add c24e6e0497 IGNITE-20146 Add improvements to the catalog associated
with the DistributionZone (#2403)
add cdddfae611 IGNITE-19937 Remove BinaryRow#byteBuffer method (#2408)
add d5c265d933 IGNITE-19770 Add a mechanism to wait till a schema is
available via Schema Sync at a ts (#2402)
add 6546bc46f9 IGNITE-20128: Clean up ignored SQL tests (#2392)
add 5d9494fc7a IGNITE-19783 StripedScheduledExecutorService is created for
DistributionZoneManager#executor (#2380)
add 23d886ad2a IGNITE-20058 Flaky distribution zone tests were fixed by
fixing order of the meta storage watches deploying and a distribution zone
manager start (#2400)
add fa8d626f57 IGNITE-19566 Remove ignite-core dependency from ignite-api
module (#2349)
add 28111df1a2 IGNITE-19839 Java client: Reload schema when unmapped
columns are detected (#2410)
add 0ab2627e50 IGNITE-20105 Set default precision and scale for new column
descriptor when needed (#2391)
add fb3c5e2033 IGNITE-15927 One-phase commit - Fixes #2329.
add 606f17fc3c IGNITE-19960 Sync with JRaft repo - Fixes #2321.
add 194ad21949 IGNITE-15927 Fixed compilation
add ed6493a563 IGNITE-20167 Always use version to get SQL schema (#2413)
add 551401872e Merge branch 'main' of
https://gitbox.apache.org/repos/asf/ignite-3
add 8451881ebf IGNITE-20161 Fix NPE in AppendEntriesRequestProcessor
(#2407)
add 9f4dd29a0a IGNITE-19361: Sql. Add negative test cases for UUID custom
type (#2416)
add dfdc132f5b IGNITE-20153 Prepare existing tests for the distributed
zone to switch to the catalog (#2420)
add e51f3d9799 [IGNITE-19785] Sql. Rework execution of 2-phase aggregates
(#2312)
add 9f5c135ea7 IGNITE-19953 Fix --verbose/-v option in CLI interactive
mode (#2419)
add da612fd99a IGNITE-19841 Add tests for schema validation consistency in
client and embedded API (#2421)
add 8e37291b97 IGNITE-19108 Check connection during REPL session in CLI
(#2359)
add f4c33ff66f IGNITE-14865 Sql. Public SQL API should only throw public
exceptions (#2345)
add ee06eb1bc0 IGNITE-19978 Java client: Change Gradle dependencies from
implementation to api (#2427)
add 4dd4743579 IGNITE-20152 Fix PartitionAwarenessTest.startServer2
flakiness (#2430)
add 47bf25dedd IGNITE-19877 Sql. Fix not allowed CAST operations - Fixes
#2368.
add e490bfe781 IGNITE-20056 .NET: Track observable timestamp (#2426)
add ae8c6c5011 IGNITE-19947 Sql. Fix CAST(n AS DECIMAL(precision, scale))
behaviour for scale > precision issues (#2396)
add 0e0ba6a3ca IGNITE-20180 Fix flaky ItTablePersistenceTest#testSnapshot
(#2428)
add c1a6a07307 IGNITE-19838 .NET: Retry outdated schema error (#2434)
add 960ce0a72d IGNITE-19294 Support merged configuration roots for
multiple modules (#2386)
add 76410e1f86 IGNITE-19995 testMultithreadedWaitForWithValue muted (#2438)
add 791abd1831 IGNITE-19789 Sql. Introduce RowSchema for RowFactory (#2398)
add 3efece8245 IGNITE-19919 Sql. ResultSet#close should close implicit
transaction if any (#2423)
add 027bdd1681 IGNITE-20200 Fix Gradle non-zero exit code on test failure
(#2442)
add af65a70c4c IGNITE-20053 ItRebalanceDistributedTest fixed (#2433)
add a5a7bac093 IGNITE-20030 Sql. Delete operation fails if PK is set on
arbitrary columns (#2397)
add cfe909d121 IGNITE-19936 Add username and password parameters to the
connect command (#2339)
add c00e7ed902 IGNITE-20192 Fix default length for variable-length columns
(#2435)
add 7b5d0b3a3b IGNITE-20188 Add improvements to the catalog associated
with the DistributionZone #2 (#2432)
add 4a646a7cd7 IGNITE-19836 .NET: Reject Tuples and POCOs with unmapped
fields (#2444)
add f6214ae730 IGNITE-20035 Sql. Fixed handling "maxRows" jdbc query
parameter (#2437)
add 99f7775253 IGNITE-20049 Remove BinaryRow#hasValue method (#2424)
add e98dee77ee IGNITE-20214 Fix flaky
ItSimpleCounterServerTest#testRefreshLeader test (#2445)
add 7989e7e253 IGNITE-20189 Prepare existing tests for the distributed
zone to switch to the catalog #2 (#2436)
add 19bc621eaf IGNITE-20171 Handle case when there is no Problem json in
response (#2418)
add 730d214f92 IGNITE-19840 .NET: Reload schema when unmapped columns are
detected (#2454)
add 1e9fe13003 IGNITE-20229 Get rid of configurations in
PlacementDriverManager (#2453)
add bb2c93aa6b IGNITE-20243 Introduce a Matcher for BinaryRows (#2457)
add 2c22342bb1 IGNITE-20082 Fix ODBC DEB\RPM packages (#2376)
add 641b340d76 IGNITE-16700 Fix flaky
ItTxDistributedTestThreeNodesThreeReplicas#testBalance (#2439)
add bb382455ea IGNITE-20183 Fix testNonNullTxDisablesPartitionAwareness
flakiness (#2458)
add b04aee524e IGNITE-19096 Sql. Replace placeholder values from
ModifyNode (#2446)
add 0e680321e1 IGNITE-20251 NPE in
ItTxDistributedTestThreeNodesThreeReplicas (#2464)
add db52d5016d IGNITE-20159 Add README for the project (#2409)
add 5295cd0d5e IGNITE-20249 Refactoring some tests to make it easier to
switch to catalog (#2465)
add e32fd8d092 IGNITE 19148 Switch tests from using JUL to log4j2 (#2429)
add eeeadbe5b2 IGNITE-20197 .NET: Fix excessive dictionary lookups in
GetFieldByColumnName (#2467)
add 77d9823c37 IGNITE-19009 Introduce file transfer support in messaging
(#2390)
add 6112498dd7 IGNITE-20196 Sql. Review list of reserved keywords (#2452)
add b584cd863b IGNITE-19631 (#2466) Allow passing extra JVM args to
bin/ignite3db
add fefcadb4d2 IGNITE-19893: Sql. Add plan checks to
BaseIndexDataTypeTest. (#2422)
add f72bf5f036 IGNITE-20261 Configure Xmx for unit tests (#2474)
add c8e47892b9 IGNITE-19711 Add a note for CREATE INDEX (#2362)
add 7e0987afe1 IGNITE-19920 Fix ALTER TABLE syntax (#2361)
add 49601d2fcb IGNITE-20057 Track observable timestamp in C++ client and
ODBC (#2471)
add 7efadf98c1 IGNITE-19957 Refactor ODBC to re-use protocol-related code
from client (#2470)
add accf8ea49b IGNITE-19211 ODBC 3.0: Type traits clean up (#2478)
add 3afaddcda9 IGNITE-20257 fix flaky ItCliServiceTest#testSnapshot test
@alievmirza (#2469)
add 6b987b721c IGNITE-20248 Fix validation of autoAdjust, scaleUp and
scaleDown when creating a zone in the catalog (#2462)
add c87284c92a IGNITE-20219 Fix the typo of user name to username (#2451)
add 40d611dea0 IGNITE-20230
ItRebalanceDistributedTest#testDestroyPartitionStoragesOnEvictNode fixed.
(#2477)
add b191cf8c42 IGNITE-19983 C++: Support BOOLEAN datatype (#2481)
add 4a5b7357d6 IGNITE-19995
PendingComparableValuesTrackerTest#testMultithreadedWaitFor fails with
ConcurrentModificationException (#2482)
add d15b975b97 IGNITE-19542 .NET: Add BinaryTupleIgniteTupleAdapter (#2479)
add 18d79f347d IGNITE-20246 Sql. Decouple distribution trait and function
(#2463)
add d748e48ed4 IGNITE-19951 Enable checks of using NotNull annotation.
(#2468)
add 6404013215 IGNITE-20104 Sql. Improve error messages from Sql parser
(#2460)
add 19f158ceff IGNITE-20185 Sql. Fix missed casting rules (#2431)
add df5734462d IGNITE-19992 Sql. Rework execution of 2-phase set operators
(#2443)
add fe84f76259 IGNITE-20270 Improve RocksDB iterator performance (#2487)
add f9bfb52907 IGNITE-19570 Write intent resolution for RW transactions
(#2475)
add 73150f1b45 IGNITE-20155 Validate BinaryTuple coming from client (#2491)
add 18f67c8fe2 IGNITE-20271 Error in CLI on SQL repl command (#2486)
new 0beda7a18a Implement ArchUnit rule to detect wrong test classes
hierarchy.
new 455976f38b IGNITE-20086
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 (a93737b3ef)
\
N -- N -- N refs/heads/ignite-20086 (455976f38b)
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.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/PULL_REQUEST_TEMPLATE.md | 12 +-
.idea/codeStyles/Project.xml | 3 +-
.idea/inspectionProfiles/Project_Default.xml | 8 +-
README.md | 103 ++-
build.gradle | 2 +-
buildscripts/java-core.gradle | 4 +-
buildscripts/java-integration-test.gradle | 5 +
buildscripts/java-junit5.gradle | 6 +
buildscripts/java-test-fixtures.gradle | 5 +
buildscripts/sql-parser-generator.gradle | 33 +-
check-rules/pmd-rules.xml | 19 +
config/java.util.logging.properties | 57 --
docs/_docs/sql-reference/ddl.adoc | 23 +-
gradle/libs.versions.toml | 13 +-
.../affinity/RendezvousAffinityFunctionTest.java | 2 -
modules/api/build.gradle | 11 +-
.../org/apache/ignite/InitParametersBuilder.java | 2 +-
.../org/apache/ignite/compute/IgniteCompute.java | 35 +-
.../ignite/lang/ColumnAlreadyExistsException.java | 2 +-
.../ignite/lang/ColumnNotFoundException.java | 12 +-
.../java/org/apache/ignite/lang/ErrorGroup.java | 0
.../java/org/apache/ignite/lang/ErrorGroups.java | 0
.../apache/ignite/lang/IgniteCheckedException.java | 2 +-
.../org/apache/ignite/lang/IgniteException.java | 2 +-
.../apache/ignite/lang/IgniteExceptionUtils.java | 544 ---------------
.../ignite/lang/IndexAlreadyExistsException.java | 5 +-
.../apache/ignite/lang/IndexNotFoundException.java | 5 +-
.../ignite/lang/SchemaNotFoundException.java | 3 +-
.../ignite/lang/TableAlreadyExistsException.java | 2 +-
.../apache/ignite/lang/TableNotFoundException.java | 2 +-
.../org/apache/ignite/lang/TraceableException.java | 0
.../apache/ignite/lang}/util/IgniteNameUtils.java | 12 +-
.../org/apache/ignite/lang}/util/StringUtils.java | 2 +-
.../org/apache/ignite/lang/util/TraceIdUtils.java | 56 ++
.../org/apache/ignite/network/ClusterNode.java | 90 +--
.../main/java/org/apache/ignite/sql/Session.java | 61 +-
.../org/apache/ignite/sql/SqlBatchException.java | 19 +-
.../java/org/apache/ignite/sql/SqlException.java | 13 -
.../main/java/org/apache/ignite/sql/Statement.java | 19 +-
.../java/org/apache/ignite/table/KeyValueView.java | 77 +-
.../java/org/apache/ignite/table/RecordView.java | 57 +-
.../main/java/org/apache/ignite/table/Table.java | 3 +-
.../main/java/org/apache/ignite/table/Tuple.java | 29 +-
.../java/org/apache/ignite/table/TupleImpl.java | 47 +-
.../org/apache/ignite/table/mapper/Mapper.java | 20 +-
.../apache/ignite/table/mapper/MapperBuilder.java | 19 +-
.../ignite/table/mapper/OneColumnMapperImpl.java | 5 +-
.../org/apache/ignite/table/mapper/PojoMapper.java | 13 +-
.../apache/ignite/table/mapper/PojoMapperImpl.java | 14 +-
modules/arch-test/build.gradle | 6 +
.../internal/TestClassHierarchyArchTest.java | 39 +-
.../apache/ignite/lang/IgniteTestImportOption.java | 8 +-
modules/binary-tuple/build.gradle | 1 +
.../internal/binarytuple/BinaryTupleCommon.java | 6 -
modules/catalog/build.gradle | 16 +-
.../apache/ignite/internal/catalog/Catalog.java | 4 +-
.../ignite/internal/catalog/CatalogManager.java | 8 +-
.../internal/catalog/CatalogManagerImpl.java | 145 ++--
.../catalog/CatalogParamsValidationUtils.java | 175 +++++
.../ignite/internal/catalog/CatalogService.java | 26 +-
.../catalog/CatalogValidationException.java | 53 ++
.../commands/AbstractUpdateZoneCommandParams.java | 195 ++++++
.../commands/AbstractZoneCommandParams.java | 32 +-
.../internal/catalog/commands/AlterZoneParams.java | 193 ++---
.../internal/catalog/commands/CatalogUtils.java | 224 +++++-
.../internal/catalog/commands/ColumnParams.java | 19 +-
.../catalog/commands/CreateZoneParams.java | 201 ++----
...{DropZoneParams.java => DataStorageParams.java} | 56 +-
.../internal/catalog/commands/DropZoneParams.java | 49 +-
.../catalog/commands/RenameZoneParams.java | 20 +-
.../descriptors/CatalogDataStorageDescriptor.java | 5 +-
.../catalog/descriptors/CatalogZoneDescriptor.java | 44 +-
.../internal/catalog/CatalogManagerSelfTest.java | 145 ++--
.../catalog/CatalogManagerValidationTest.java | 585 ++++++++++++++++
.../catalog/commands/CatalogUtilsTest.java | 219 ++++++
.../catalog/storage/UpdateLogImplTest.java | 3 +-
.../internal/catalog/BaseCatalogManagerTest.java | 84 +++
modules/cli/build.gradle | 1 +
...liCommandTestNotInitializedIntegrationBase.java | 12 +-
.../cli/commands/ItClusterCommandTest.java | 44 +-
.../cli/commands/ItConnectionHeartbeatTest.java | 142 ++++
.../cli/commands/connect/ItConnectCommandTest.java | 23 +
...tConnectWithBasicAuthenticationCommandTest.java | 195 +++++-
.../cli/commands/sql/ItSqlCommandTest.java | 2 +-
.../repl/executor/ItIgnitePicocliCommandsTest.java | 7 +-
.../apache/ignite/internal/cli/ssl/ItSslTest.java | 4 +-
.../apache/ignite/internal/cli/ReplManager.java | 5 +
.../internal/cli/call/connect/ConnectCall.java | 111 +--
.../cli/call/connect/ConnectCallInput.java | 105 +++
.../internal/cli/call/connect/ConnectSslCall.java | 7 +-
.../cli/call/connect/ConnectSslConfigCall.java | 5 +-
.../internal/cli/call/connect/DisconnectCall.java | 23 +-
.../ignite/internal/cli/commands/Options.java | 18 +
.../cli/commands/connect/ConnectCommand.java | 16 +-
.../cli/commands/connect/ConnectOptions.java | 49 ++
.../cli/commands/connect/ConnectReplCommand.java | 28 +-
.../questions/ConnectToClusterQuestion.java | 33 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 7 +-
.../ignite/internal/cli/config/ConfigManager.java | 4 +
.../ignite/internal/cli/core/JdbcUrlFactory.java | 2 +-
.../handler/IgniteCliApiExceptionHandler.java | 25 +-
...SessionEventListener.java => ConnectEvent.java} | 26 +-
.../cli/core/repl/ConnectionHeartBeat.java | 134 ++++
...EventListener.java => ConnectionLostEvent.java} | 17 +-
...tListener.java => ConnectionRestoredEvent.java} | 17 +-
...sionEventListener.java => DisconnectEvent.java} | 17 +-
.../core/repl/EventListeningActivationPoint.java | 91 +++
.../cli/core/repl/PeriodicSessionTaskExecutor.java | 3 +-
.../apache/ignite/internal/cli/core/repl/Repl.java | 11 +-
.../ignite/internal/cli/core/repl/ReplBuilder.java | 16 +-
.../ignite/internal/cli/core/repl/Session.java | 42 +-
.../ignite/internal/cli/core/repl/SessionInfo.java | 50 +-
.../cli/core/repl/executor/ReplExecutor.java | 2 +
.../cli/core/repl/prompt/ReplPromptProvider.java | 19 +-
.../registry/impl/ClusterConfigRegistryImpl.java | 4 +-
.../repl/registry/impl/MetricRegistryImpl.java | 4 +-
.../repl/registry/impl/NodeConfigRegistryImpl.java | 4 +-
.../core/repl/registry/impl/UnitsRegistryImpl.java | 4 +-
.../internal/cli/core/rest/ApiClientFactory.java | 82 ++-
.../cli/event/ConnectionEventListener.java | 65 ++
.../apache/ignite/internal/cli/event/Event.java} | 12 +-
.../ignite/internal/cli/event/EventFactory.java | 84 +++
.../ignite/internal/cli/event/EventListener.java | 14 +-
.../ignite/internal/cli/event/EventPublisher.java | 18 +-
.../EventSubscriptionManager.java} | 14 +-
.../ignite/internal/cli/event/EventType.java} | 15 +-
.../apache/ignite/internal/cli/event/Events.java | 67 ++
.../ignite/internal/cli/logger/HttpLogging.java | 5 +
.../cli/commands/connect/ConnectCommandTest.java | 48 ++
.../cli/config/ini/IniConfigManagerTest.java | 2 +-
.../handler/IgniteCliApiExceptionHandlerTest.java | 87 +++
.../core/repl/SessionDefaultValueProviderTest.java | 6 +-
.../filter/DynamicCompleterFilterTest.java | 10 +-
.../internal/cli/logger/HttpLoggingTest.java | 35 +-
.../ignite/internal/cli/AbstractCliTest.java | 3 +-
.../client/proto/ClientBinaryTupleUtils.java | 6 +-
.../table/MutableTupleBinaryTupleAdapter.java | 35 +-
.../proto/ClientMessagePackerUnpackerTest.java | 3 +-
modules/client-handler/build.gradle | 1 -
.../client/handler/ItClientHandlerMetricsTest.java | 3 +-
.../ignite/client/handler/ItClientHandlerTest.java | 3 +-
.../client/handler/ItSslClientHandlerTest.java | 3 +-
.../ignite/client/handler/ClientResource.java | 3 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 5 +-
.../handler/requests/jdbc/JdbcQueryCursor.java | 11 +-
.../handler/requests/table/ClientTableCommon.java | 2 -
.../client/handler/requests/table/ClientTuple.java | 5 +-
.../requests/jdbc/JdbcQueryCursorSelfTest.java | 101 +++
modules/client/build.gradle | 4 +-
.../ignite/internal/client/ClientClusterNode.java} | 40 +-
.../apache/ignite/internal/client/ClientUtils.java | 7 +-
.../ignite/internal/client/TcpClientChannel.java | 13 +-
.../ignite/internal/client/TcpIgniteClient.java | 2 +-
.../internal/client/compute/ClientCompute.java | 49 ++
.../ignite/internal/client/sql/ClientSession.java | 4 +-
.../ignite/internal/client/sql/ClientSqlRow.java | 7 +-
.../internal/client/sql/ClientStatement.java | 7 +-
.../client/sql/ClientStatementBuilder.java | 13 +-
.../internal/client/table/ClientDataStreamer.java | 2 -
.../client/table/ClientKeyValueBinaryView.java | 77 +-
.../internal/client/table/ClientKeyValueView.java | 85 ++-
.../client/table/ClientRecordBinaryView.java | 57 +-
.../client/table/ClientRecordSerializer.java | 5 +-
.../internal/client/table/ClientRecordView.java | 57 +-
.../ignite/internal/client/table/ClientSchema.java | 11 +-
.../ignite/internal/client/table/ClientTable.java | 190 ++---
.../ignite/internal/client/table/ClientTuple.java | 7 +-
.../client/table/ClientTupleSerializer.java | 94 ++-
.../internal/client/tx/ClientTransaction.java | 3 +-
.../internal/client/tx/ClientTransactions.java | 2 -
.../ignite/client/AbstractClientTableTest.java | 104 ++-
.../apache/ignite/client/AbstractClientTest.java | 3 +-
.../ignite/client/ClientKeyValueViewTest.java | 85 +--
.../apache/ignite/client/ClientRecordViewTest.java | 41 +-
.../org/apache/ignite/client/ClientTableTest.java | 4 +-
.../java/org/apache/ignite/client/CustomTuple.java | 32 +-
.../org/apache/ignite/client/DataStreamerTest.java | 12 +-
.../client/ObservableTimestampPropagationTest.java | 3 +-
.../ignite/client/PartitionAwarenessTest.java | 48 +-
.../java/org/apache/ignite/client/TestServer.java | 3 +-
.../ignite/client/fakes/FakeAsyncResultSet.java | 2 -
.../apache/ignite/client/fakes/FakeCompute.java | 50 ++
.../ignite/client/fakes/FakeIgniteTables.java | 24 +-
.../ignite/client/fakes/FakeInternalTable.java | 133 ++--
.../ignite/client/fakes/FakeSchemaRegistry.java | 17 +-
.../apache/ignite/client/fakes/FakeSession.java | 4 +-
.../org/apache/ignite/client/fakes/FakeSqlRow.java | 32 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 3 +-
modules/cluster-management/build.gradle | 1 -
.../management/raft/ItCmgRaftServiceTest.java | 3 +-
.../cluster/management/ClusterInitializer.java | 2 +-
.../raft/commands/ClusterNodeMessage.java | 3 +-
.../management/topology/api/LogicalNode.java | 3 +-
.../cluster/management/ClusterInitializerTest.java | 17 +-
.../AbstractClusterStateStorageManagerTest.java | 4 +-
.../ignite/internal/deployunit/UnitContent.java | 2 -
.../metastore/DeploymentUnitStoreImplTest.java | 3 +-
.../deployunit/DeploymentUnitAccessorImplTest.java | 3 +-
.../DeploymentUnitAcquiredWaiterTest.java | 5 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 52 +-
.../internal/compute/ComputeComponentImplTest.java | 3 +-
.../internal/compute/IgniteComputeImplTest.java | 5 +-
.../compute/JobExecutionContextImplTest.java | 3 +-
.../compute/loader/JobClassLoaderFactoryTest.java | 3 +-
.../compute/loader/JobClassLoaderTest.java | 3 +-
...tibleSchemaAnnotations0ConfigurationSchema.java | 6 +-
.../ErrorInjectedName4ConfigurationSchema.java | 6 +-
.../ErrorInjectedName5ConfigurationSchema.java | 4 +-
.../ErrorInternal0ConfigurationSchema.java | 6 +-
.../ErrorInternal1ConfigurationSchema.java | 6 +-
.../ErrorInternal2ConfigurationSchema.java | 6 +-
.../ErrorInternal3ConfigurationSchema.java | 6 +-
.../ErrorInternal4ConfigurationSchema.java | 4 +-
.../ErrorInternal5ConfigurationSchema.java | 4 +-
.../ExtendedSimpleConfigurationSchema.java | 4 +-
.../ExtendedSimpleRootConfigurationSchema.java | 4 +-
.../ErrorPolymorphic2ConfigurationSchema.java | 6 +-
...rorPolymorphicInstance2ConfigurationSchema.java | 6 +-
.../processor/ConfigurationProcessor.java | 32 +-
.../ignite/configuration/ConfigurationModule.java | 14 +-
.../org/apache/ignite/configuration/RootKey.java | 10 +-
...figuration.java => ConfigurationExtension.java} | 12 +-
modules/configuration-presentation/build.gradle | 1 -
modules/configuration/README.md | 76 ++
modules/configuration/build.gradle | 1 +
.../configuration/ConfigurationTreeGenerator.java | 30 +-
.../configuration/DynamicConfiguration.java | 7 +-
.../configuration/NamedListConfiguration.java | 2 +-
.../internal/configuration/RootInnerNode.java | 4 +-
.../configuration/asm/AbstractAsmGenerator.java | 19 +-
.../asm/ConfigurationAsmGenerator.java | 47 +-
.../asm/ConfigurationImplAsmGenerator.java | 73 +-
.../configuration/asm/DirectProxyAsmGenerator.java | 16 +-
.../configuration/asm/InnerNodeAsmGenerator.java | 94 +--
.../configuration/hocon/HoconConverter.java | 3 +-
.../internal/configuration/tree/InnerNode.java | 7 +-
.../configuration/util/ConfigurationFlattener.java | 3 +-
.../configuration/util/ConfigurationUtil.java | 52 +-
.../validation/ConfigurationValidatorImpl.java | 6 +-
.../configuration/ConfigurationRegistryTest.java | 4 +-
.../asm/ConfigurationTreeGeneratorTest.java | 44 +-
.../notifications/ConfigurationListenerTest.java | 4 +-
.../ExtendedDiscoveryConfigurationSchema.java | 4 +-
.../testframework/ConfigurationExtensionTest.java | 11 +-
.../tree/ConverterToMapVisitorTest.java | 3 +-
.../configuration/tree/InternalIdTest.java | 4 +-
.../configuration/util/ConfigurationUtilTest.java | 228 +++++-
.../validation/ConfigurationValidatorImplTest.java | 7 +-
.../validation/OneOfValidatorTest.java | 3 +-
.../validation/PowerOfTwoValidatorTest.java | 3 +-
.../validation/RangeValidatorTest.java | 3 +-
.../storage/TestConfigurationStorage.java | 3 +-
.../testframework/ConfigurationExtension.java | 23 +-
.../testframework/ExtendedConfigurationSchema.java | 4 +-
.../testframework/InjectConfiguration.java | 6 +-
modules/core/build.gradle | 15 +-
.../DistributionZoneAlreadyExistsException.java | 4 +-
.../DistributionZoneBindTableException.java | 4 +-
.../DistributionZoneNotFoundException.java | 4 +-
.../ignite/internal/hlc/HybridTimestamp.java | 19 +-
.../ignite/internal/logger/IgniteLogger.java | 3 +-
.../ignite/internal/manager/EventListener.java | 5 +-
.../internal/properties/IgniteProductVersion.java | 2 +-
.../ignite/internal/sql/AbstractSession.java | 153 ++++
.../ignite/internal}/sql/SyncResultSetAdapter.java | 8 +-
...java => AbstractStripedThreadPoolExecutor.java} | 116 ++-
.../thread/StripedScheduledThreadPoolExecutor.java | 105 +++
.../internal/thread/StripedThreadPoolExecutor.java | 196 +-----
.../internal/tostring/IgniteToStringBuilder.java | 3 +-
.../ignite/internal/util/ExceptionUtils.java | 548 ++++++++++++++-
.../ignite/internal/util/FilteringIterator.java | 5 +-
.../apache/ignite/internal/util/GridUnsafe.java | 10 +-
.../apache/ignite/internal/util/IgniteUtils.java | 47 +-
.../PendingIndependentComparableValuesTracker.java | 4 +-
.../apache/ignite/lang/IgniteExceptionMapper.java | 0
.../ignite/lang/IgniteExceptionMapperUtil.java | 0
.../lang/IgniteExceptionMappersProvider.java | 0
.../lang/IgniteInternalCheckedException.java | 2 +-
.../ignite/lang/IgniteInternalException.java | 15 +-
...eFiveFunction.java => IgnitePentaFunction.java} | 2 +-
...eTetraFunction.java => IgniteQuadFunction.java} | 2 +-
.../apache/ignite/internal/HybridClockTest.java | 3 +-
.../causality/CompletableVersionedValueTest.java | 3 +-
.../causality/IncrementalVersionedValueTest.java | 3 +-
.../ignite/internal/hlc/HybridTimestampTest.java | 80 +++
.../ignite/internal/manager/ProducerTest.java | 5 +-
.../apache/ignite/internal/util/CursorTest.java | 3 +-
.../ignite/internal/util/IgniteNameUtilsTest.java | 12 +-
.../ignite/internal/util/IgniteUtilsTest.java | 7 +-
.../util/PendingComparableValuesTrackerTest.java | 2 -
.../internal/util/RefCountedObjectPoolTest.java | 2 +-
.../subscription/TransformingPublisherTest.java | 3 +-
.../apache/ignite/lang/ExceptionUtilsTest.java} | 7 +-
.../ignite/lang/IgniteExceptionMapperUtilTest.java | 0
.../apache/ignite/lang/IgniteExceptionTest.java | 11 +-
.../lang/TestIgniteExceptionMappersProvider.java | 0
.../testframework/BaseIgniteAbstractTest.java | 14 -
.../testframework/IntegrationTestBase.java | 0
.../testframework/TestIgnitionManager.java | 0
.../testframework/log4j2/LogInspector.java | 364 ++++++++++
.../testframework/matchers/PathMatcher.java | 105 +++
.../resources/java.util.logging.properties | 57 --
.../src/testFixtures/resources/log4j2-test.xml | 58 ++
modules/distribution-zones/build.gradle | 1 +
.../distributionzones/DistributionZoneManager.java | 59 +-
.../distributionzones/DistributionZonesUtil.java | 14 +-
.../CausalityDataNodesEngine.java | 2 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 2 +-
.../distributionzones/rebalance/RebalanceUtil.java | 8 +-
.../utils/CatalogAlterZoneEventListener.java | 212 ++++++
.../BaseDistributionZoneManagerTest.java | 64 +-
.../DistributionZoneFiltersTest.java | 1 -
.../DistributionZoneManagerAlterFilterTest.java | 184 ++---
...ibutionZoneManagerConfigurationChangesTest.java | 101 +--
.../DistributionZoneManagerFilterTest.java | 42 +-
.../DistributionZoneManagerScaleUpTest.java | 618 ++++++++--------
.../DistributionZoneManagerTest.java | 776 +--------------------
.../DistributionZoneManagerWatchListenerTest.java | 36 +-
.../DistributionZoneMockTest.java | 3 +-
.../DistributionZonesSchedulersTest.java | 237 ++++---
.../DistributionZoneCausalityDataNodesTest.java | 545 ++++++---------
.../DistributionZoneRebalanceEngineTest.java | 58 +-
.../utils/CatalogAlterZoneEventListenerTest.java | 267 +++++++
.../DistributionZonesTestUtil.java | 181 +++--
modules/file-transfer/README.md | 26 +
.../{configuration => file-transfer}/build.gradle | 29 +-
.../internal/network/file/ItFileTransferTest.java | 518 ++++++++++++++
.../ignite/internal/network/file/TestCluster.java | 188 +++++
.../ignite/internal/network/file/Channel.java} | 17 +-
.../internal/network/file/ChunkedFileReader.java | 119 ++++
.../internal/network/file/ChunkedFileWriter.java | 112 +++
.../network/file/FileChunkMessagesStream.java | 166 +++++
.../internal/network/file/FileConsumer.java} | 21 +-
.../internal/network/file/FileProvider.java} | 19 +-
.../ignite/internal/network/file/FileReceiver.java | 197 ++++++
.../ignite/internal/network/file/FileSender.java | 266 +++++++
.../network/file/FileTransferMessagesHandler.java | 168 +++++
.../internal/network/file/FileTransferService.java | 69 ++
.../network/file/FileTransferServiceImpl.java | 641 +++++++++++++++++
.../network/file/TransferredFilesCollector.java} | 18 +-
.../network/file/exception/ErrorCodes.java} | 17 +-
.../file/exception/FileTransferException.java} | 31 +-
.../file/exception/FileValidationException.java} | 21 +-
.../network/file/messages/FileChunkMessage.java} | 41 +-
.../network/file/messages/FileChunkResponse.java} | 23 +-
.../file/messages/FileDownloadRequest.java} | 29 +-
.../file/messages/FileDownloadResponse.java} | 23 +-
.../internal/network/file/messages/FileHeader.java | 68 ++
.../network/file/messages/FileTransferError.java | 66 ++
.../file/messages/FileTransferErrorMessage.java} | 29 +-
.../file/messages/FileTransferInitMessage.java} | 50 +-
.../file/messages/FileTransferInitResponse.java} | 23 +-
.../file/messages/FileTransferMessageType.java | 76 ++
.../network/file/messages/Identifier.java} | 19 +-
.../network/file/ChunkedFileReaderTest.java | 86 +++
.../network/file/ChunkedFileWriterTest.java | 81 +++
.../network/file/FileChunkMessagesStreamTest.java | 121 ++++
.../internal/network/file/FileReceiverTest.java | 174 +++++
.../internal/network/file/FileSenderTest.java | 297 ++++++++
.../network/file/FileTransferServiceImplTest.java | 301 ++++++++
.../network/file/TestMessagingService.java | 81 +++
.../internal/network/file/TestTopologyService.java | 68 ++
.../internal/network/file/FileGenerator.java} | 38 +-
.../internal/network/file/PathAssertions.java | 44 ++
modules/index/build.gradle | 1 -
.../apache/ignite/internal/index/IndexManager.java | 51 +-
.../ignite/internal/index/IndexManagerTest.java | 3 +-
modules/jdbc/build.gradle | 1 +
.../apache/ignite/jdbc/ItJdbcErrorsSelfTest.java | 6 +-
.../ignite/jdbc/ItJdbcResultSetSelfTest.java | 24 +-
.../internal/jdbc/ConnectionPropertiesImpl.java | 2 -
.../internal/jdbc/PreparedStatementParamsTest.java | 3 +-
.../ignite/internal/marshaller/FieldAccessor.java | 1 +
.../ignite/internal/marshaller/Marshaller.java | 71 +-
.../ignite/internal/marshaller/MarshallerUtil.java | 58 ++
.../marshaller/UnmappedColumnsException.java | 14 +-
.../TestObjectWithNoDefaultConstructor.java | 4 +
modules/metastorage/build.gradle | 1 +
.../server/AbstractCompoundCondition.java | 3 +-
.../server/AbstractSimpleCondition.java | 11 +-
.../metastorage/server/ExistenceCondition.java | 6 +-
.../metastorage/server/RevisionCondition.java | 6 +-
.../metastorage/server/TombstoneCondition.java | 5 +-
.../ignite/internal/metastorage/server/Value.java | 4 +-
.../metastorage/server/ValueCondition.java | 7 +-
.../impl/MetaStorageManagerRecoveryTest.java | 3 +-
.../metastorage/impl/MetaStorageRangeTest.java | 3 +-
.../metastorage/server/OrConditionTest.java | 3 +-
.../metastorage/server/time/ClusterTimeTest.java | 3 +-
.../server/AbstractKeyValueStorageTest.java | 3 +-
modules/metrics/build.gradle | 1 +
.../metrics/exporters/ItJvmMetricSourceTest.java | 3 +-
.../exporters/ItMetricExportersLoadingTest.java | 3 +-
.../ignite/internal/metrics/MetricManager.java | 2 -
.../ignite/internal/metrics/MetricRegistry.java | 8 +-
.../ignite/internal/metrics/JmxExporterTest.java | 3 +-
.../internal/metrics/MetricConfigurationTest.java | 3 +-
modules/network-annotation-processor/build.gradle | 1 +
.../network/processor/tests/GenerationTest.java | 3 +-
.../apache/ignite/network/ClusterNodeImpl.java} | 33 +-
.../apache/ignite/network/MessagingService.java | 20 +
modules/network/build.gradle | 3 +-
.../network/netty/ItConnectionManagerTest.java | 3 +-
.../network/scalecube/ItClusterServiceTest.java | 3 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 36 +-
.../FileTransferConfigurationSchema.java} | 29 +-
.../configuration/NetworkConfigurationSchema.java | 4 +
.../SslConfigurationValidatorImpl.java | 2 +-
.../network/netty/InboundRecoveryHandler.java | 3 +-
.../serialization/marshal/BuiltInMarshalling.java | 2 -
.../ignite/network/DefaultMessagingService.java | 13 +
.../ScaleCubeDirectMarshallerTransport.java | 3 +-
.../scalecube/ScaleCubeTopologyService.java | 3 +-
.../SslConfigurationValidatorImplTest.java | 3 +-
.../netty/IoExceptionSuppressingHandlerTest.java | 3 +-
.../network/processor/InheritedMessageTest.java | 3 +-
.../network/processor/SerializationOrderTest.java | 3 +-
...TransferableObjectProcessorIncrementalTest.java | 3 +-
.../network/recovery/VaultStateIdsTest.java | 3 +-
.../serialization/ClassDescriptorMergerTest.java | 3 +-
.../network/serialization/MarshallableTest.java | 3 +-
.../marshal/BestEffortInstantiationTest.java | 3 +-
.../marshal/DefaultSchemaMismatchHandlerTest.java | 3 +-
.../DefaultUserObjectMarshallerCommonTest.java | 2 +-
...erObjectMarshallerWithArbitraryObjectsTest.java | 3 -
...ltUserObjectMarshallerWithSchemaChangeTest.java | 3 +-
...ltUserObjectMarshallerWithSerializableTest.java | 14 -
.../marshal/SerializableInstantiationTest.java | 3 +-
.../network/ssl/SslContextProviderTest.java | 3 +-
.../network/AbstractMessagingServiceTest.java | 3 +-
.../network/DefaultMessagingServiceTest.java | 7 +-
.../MessageSerializationRegistryImplTest.java | 3 +-
.../pagememory/datastructure/DataStructure.java | 2 +-
.../persistence/PartitionMetaManagerTest.java | 3 +-
.../AwaitTasksCompletionExecutorTest.java | 3 +-
.../checkpoint/CheckpointDirtyPagesTest.java | 3 +-
.../checkpoint/CheckpointManagerTest.java | 3 +-
.../checkpoint/CheckpointPagesWriterTest.java | 3 +-
.../persistence/checkpoint/CheckpointTest.java | 3 +-
.../checkpoint/CheckpointTimeoutLockTest.java | 7 +-
.../checkpoint/CheckpointWorkflowTest.java | 7 +-
.../persistence/checkpoint/CheckpointerTest.java | 3 +-
.../ReentrantReadWriteLockWithTrackingTest.java | 6 +-
.../persistence/compaction/CompactorTest.java | 7 +-
.../store/AbstractFilePageStoreIoTest.java | 3 +-
.../store/FilePageStoreManagerTest.java | 3 +-
.../persistence/store/FilePageStoreTest.java | 3 +-
.../persistence/store/GroupPageStoresMapTest.java | 3 +-
.../pagememory/util/GradualTaskExecutorTest.java | 3 +-
modules/placement-driver/build.gradle | 2 +
.../internal/placementdriver/ActiveActorTest.java | 14 +-
.../placementdriver/BasePlacementDriverTest.java | 75 ++
.../MultiActorPlacementDriverTest.java | 100 +--
.../PlacementDriverManagerTest.java | 88 +--
.../internal/placementdriver/LeaseUpdater.java | 106 ++-
.../placementdriver/PlacementDriverManager.java | 104 ++-
.../internal/placementdriver/TopologyTracker.java | 3 +-
.../placementdriver/leases/LeaseTracker.java | 168 ++---
.../internal/placementdriver/leases/Leases.java} | 42 +-
.../placementdriver/PlacementDriverTest.java | 3 +-
modules/platforms/build.gradle | 3 +
.../ignite/client/detail/cluster_connection.cpp | 14 +-
.../cpp/ignite/client/detail/cluster_connection.h | 48 +-
.../ignite/client/detail/compute/compute_impl.cpp | 7 +-
.../client/detail/connection_event_handler.h} | 42 +-
.../ignite/client/detail/ignite_client_impl.cpp | 2 +-
.../cpp/ignite/client/detail/node_connection.cpp | 65 +-
.../cpp/ignite/client/detail/node_connection.h | 29 +-
.../cpp/ignite/client/detail/sql/result_set_impl.h | 4 +-
.../cpp/ignite/client/detail/sql/sql_impl.cpp | 7 +-
.../cpp/ignite/client/detail/table/table_impl.cpp | 61 +-
.../cpp/ignite/client/detail/table/tables_impl.cpp | 4 +-
.../client/detail/transaction/transaction_impl.h | 3 +-
.../client/detail/transaction/transactions_impl.h | 8 +-
.../platforms/cpp/ignite/client/detail/utils.cpp | 6 +
modules/platforms/cpp/ignite/odbc/CMakeLists.txt | 1 -
.../platforms/cpp/ignite/odbc/meta/column_meta.cpp | 24 +-
.../platforms/cpp/ignite/odbc/meta/column_meta.h | 18 +-
.../platforms/cpp/ignite/odbc/protocol_version.cpp | 136 ----
.../platforms/cpp/ignite/odbc/protocol_version.h | 186 -----
.../platforms/cpp/ignite/odbc/query/data_query.cpp | 12 +-
.../platforms/cpp/ignite/odbc/sql_connection.cpp | 110 ++-
modules/platforms/cpp/ignite/odbc/sql_connection.h | 42 +-
.../platforms/cpp/ignite/odbc/sql_statement.cpp | 1 +
modules/platforms/cpp/ignite/odbc/type_traits.cpp | 117 +++-
modules/platforms/cpp/ignite/odbc/type_traits.h | 51 --
.../platforms/cpp/ignite/protocol/CMakeLists.txt | 3 +
.../cpp/ignite/protocol/client_operation.h | 4 +-
modules/platforms/cpp/ignite/protocol/messages.cpp | 76 ++
modules/platforms/cpp/ignite/protocol/messages.h | 61 ++
.../{client/detail => protocol}/protocol_context.h | 11 +-
.../cpp/ignite/protocol/protocol_version.cpp | 82 +++
.../{client/detail => protocol}/protocol_version.h | 100 ++-
modules/platforms/cpp/ignite/protocol/utils.cpp | 6 +-
.../cpp/tests/client-test/all_fields_type.h | 3 +
.../client-test/key_value_binary_view_test.cpp | 1 +
.../cpp/tests/client-test/key_value_view_test.cpp | 2 +
.../tests/client-test/record_binary_view_test.cpp | 1 +
.../cpp/tests/client-test/record_view_test.cpp | 2 +
.../platforms/cpp/tests/client-test/sql_test.cpp | 11 +-
.../cpp/tests/odbc-test/connection_test.cpp | 4 +-
.../cpp/tests/odbc-test/meta_queries_test.cpp | 2 +-
.../cpp/tests/odbc-test/odbc_connection.h | 2 +-
.../platforms/cpp/tests/odbc-test/queries_test.cpp | 22 +-
.../dotnet/Apache.Ignite.Benchmarks/Program.cs | 4 +-
.../SerializerHandlerReadBenchmarks.cs | 55 +-
.../ErrorGroupsGenerator.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/.editorconfig | 3 +
.../Apache.Ignite.Tests/ClientSocketTests.cs | 23 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 10 +-
.../dotnet/Apache.Ignite.Tests/ErrorGroupTests.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 23 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 6 +-
.../Linq/LinqSqlGenerationTests.cs | 4 +-
.../Linq/LinqTests.Aggregate.cs | 22 +-
.../Apache.Ignite.Tests/Linq/LinqTests.GroupBy.cs | 22 +-
.../Apache.Ignite.Tests/Linq/LinqTests.KvView.cs | 22 +-
.../dotnet/Apache.Ignite.Tests/Linq/LinqTests.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/ListLogger.cs | 3 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 2 +-
.../Apache.Ignite.Tests/ProjectFilesTests.cs | 5 +-
.../Proto/ColocationHashTests.cs | 7 +-
.../dotnet/Apache.Ignite.Tests/RetryPolicyTests.cs | 8 +-
.../Sql/IgniteDbDataReaderTests.cs | 4 +-
.../Sql/SqlResultSetObjectMappingTests.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 8 +-
.../Table/BinaryTupleIgniteTupleAdapterTests.cs | 111 +++
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 2 +-
.../Apache.Ignite.Tests/Table/IgniteTupleTests.cs | 36 +-
.../CollectionExtensions.cs => Table/KeyPoco.cs} | 23 +-
.../Table/KeyValueViewBinaryTests.cs | 2 +-
.../Table/KeyValueViewPocoPrimitiveTests.cs | 118 ++--
.../Table/KeyValueViewPocoTests.cs | 123 ++--
.../Table/KeyValueViewPrimitivePocoTests.cs | 97 ++-
.../Apache.Ignite.Tests/Table/PocoAllColumnsSql.cs | 10 +-
.../Table/PocoAllColumnsSqlNullable.cs | 10 +-
.../dotnet/Apache.Ignite.Tests/Table/PocoStruct.cs | 4 +-
.../Table/RecordViewBinaryTests.cs | 17 +-
.../Table/RecordViewCustomMappingTest.cs | 13 +-
.../Table/RecordViewPocoTests.cs | 2 +-
.../Table/RecordViewPrimitiveTests.cs | 3 +-
.../Table/SchemaSynchronizationTest.cs | 371 ++++++++++
.../Table/SchemaValidationTest.cs | 357 ++++++++++
.../Table/Serialization/ReflectionUtilsTests.cs | 21 +-
.../CollectionExtensions.cs => Table/ValPoco.cs} | 26 +-
.../dotnet/Apache.Ignite.Tests/ToStringTests.cs | 3 +-
.../Transactions/TransactionsTests.cs | 29 +-
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 60 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 40 +-
.../Column.cs => Common/CollectionExtensions.cs} | 25 +-
.../Internal/Common/ExceptionExtensions.cs | 52 ++
.../Apache.Ignite/Internal/Compute/Compute.cs | 23 +-
.../Column.cs => IClientSocketEventListener.cs} | 27 +-
.../Internal/Linq/IgniteQueryExecutor.cs | 3 +-
.../Internal/Linq/IgniteQueryExpressionVisitor.cs | 8 +-
.../Apache.Ignite/Internal/Linq/ResultSelector.cs | 27 +-
.../BinaryTuple/BinaryTupleIgniteTupleAdapter.cs | 143 ++++
.../{Table/Column.cs => Proto/ErrorExtensions.cs} | 20 +-
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 16 +-
.../dotnet/Apache.Ignite/Internal/Table/Column.cs | 8 +-
.../Table/{Column.cs => IgniteTupleCommon.cs} | 33 +-
.../Apache.Ignite/Internal/Table/RecordView.cs | 233 +++++--
.../Internal/Table/Serialization/KvPair.cs | 2 +
.../Table/Serialization/ObjectSerializerHandler.cs | 120 +++-
.../Table/Serialization/ReflectionUtils.cs | 22 +-
.../Serialization/SerializerExceptionExtensions.cs | 50 ++
.../Serialization/TuplePairSerializerHandler.cs | 67 ++
.../Table/Serialization/TupleSerializerHandler.cs | 81 ++-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 24 +-
.../Internal/Transactions/Transactions.cs | 4 +-
.../dotnet/Apache.Ignite/Table/IIgniteTuple.cs | 18 +
.../dotnet/Apache.Ignite/Table/IgniteTuple.cs | 53 +-
modules/raft/build.gradle | 1 -
.../apache/ignite/internal/raft/ItLozaTest.java | 3 +-
.../raft/ItTruncateSuffixAndRestartTest.java | 3 +-
.../ignite/raft/jraft/core/ItCliServiceTest.java | 23 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 168 +++--
.../raft/server/ItJraftCounterServerTest.java | 2 -
.../raft/server/ItSimpleCounterServerTest.java | 6 +-
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 4 +-
.../ignite/raft/jraft/core/FSMCallerImpl.java | 6 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 108 +--
.../raft/jraft/core/ReadOnlyServiceImpl.java | 53 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 19 +-
.../raft/jraft/disruptor/DisruptorBuilder.java | 1 -
.../apache/ignite/raft/jraft/entity/LogEntry.java | 25 +
.../ignite/raft/jraft/entity/ReadIndexStatus.java | 7 +
.../raft/jraft/error/OverloadException.java} | 43 +-
.../ignite/raft/jraft/option/ApplyTaskMode.java} | 15 +-
.../ignite/raft/jraft/option/NodeOptions.java | 78 ++-
.../ignite/raft/jraft/option/RaftOptions.java | 19 +
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 2 +-
.../raft/jraft/rpc/impl/AbstractClientService.java | 2 +-
.../ignite/raft/jraft/storage/LogManager.java | 8 +
.../raft/jraft/storage/impl/LogManagerImpl.java | 106 +--
.../raft/jraft/storage/impl/RocksDBLogStorage.java | 34 +-
.../storage/snapshot/SnapshotExecutorImpl.java | 2 +-
.../snapshot/local/LocalSnapshotStorage.java | 2 +-
.../raft/jraft/util/StorageOptionsFactory.java | 2 -
.../org/apache/ignite/raft/jraft/util/Utils.java | 11 +
.../raft/JraftGroupEventsListenerTest.java | 3 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 7 +-
.../impl/RocksDbSharedLogStorageAdvancedTest.java | 3 +-
.../raft/jraft/conf/ConfigurationEntryTest.java | 11 +-
.../raft/jraft/conf/ConfigurationManagerTest.java | 13 +-
.../ignite/raft/jraft/core/BallotBoxTest.java | 15 +-
.../ignite/raft/jraft/core/FSMCallerTest.java | 11 +-
.../ignite/raft/jraft/core/IteratorImplTest.java | 17 +-
.../ignite/raft/jraft/core/IteratorTest.java | 15 +-
.../raft/jraft/core/ReadOnlyServiceTest.java | 51 +-
.../raft/jraft/core/ReplicatorGroupTest.java | 14 +-
.../ignite/raft/jraft/core/ReplicatorTest.java | 21 +-
.../ignite/raft/jraft/entity/LogEntryTest.java | 36 +
.../entity/codec/BaseLogEntryCodecFactoryTest.java | 12 +-
.../raft/jraft/rpc/AbstractClientServiceTest.java | 23 +-
.../jraft/rpc/impl/PingRequestProcessorTest.java | 7 +-
.../impl/cli/AbstractCliRequestProcessorTest.java | 3 +-
.../rpc/impl/cli/BaseCliRequestProcessorTest.java | 13 +-
.../impl/core/BaseNodeRequestProcessorTest.java | 3 +-
.../rpc/impl/core/NodeRequestProcessorTest.java | 11 +-
.../ignite/raft/jraft/storage/BaseStorageTest.java | 3 +-
.../ignite/raft/jraft/storage/FileServiceTest.java | 9 +-
.../raft/jraft/storage/impl/LogManagerTest.java | 7 +
.../impl/VolatileLogStorageSpecificsTest.java | 3 +-
.../storage/snapshot/remote/CopySessionTest.java | 13 +-
.../snapshot/remote/RemoteFileCopierTest.java | 11 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 3 +-
.../ignite/raft/jraft/util/ThreadIdTest.java | 11 +-
.../service/ItAbstractListenerSnapshotTest.java | 7 +
.../ignite/raft/jraft/core/ExpectClosure.java | 29 +-
.../ignite/raft/jraft/core/MockStateMachine.java | 17 +-
.../ignite/internal/replicator/ReplicaManager.java | 25 +-
.../ignite/internal/replicator/ReplicaService.java | 2 +-
.../client/TopologyAwareRaftGroupServiceTest.java | 3 -
.../replicator/PlacementDriverReplicaSideTest.java | 5 +-
modules/rest-api/build.gradle | 1 +
.../internal/rest/api/cluster/InitCommand.java | 2 +-
.../handler/IgniteExceptionHandlerTest.java | 3 +-
modules/rest/build.gradle | 1 -
.../ConfigurationControllerBaseTest.java | 2 -
modules/rocksdb-common/build.gradle | 1 +
.../ignite/internal/rocksdb/ColumnFamily.java | 11 +-
.../ignite/internal/rocksdb/RocksUtilsTest.java | 3 +-
modules/runner/README.md | 2 +-
modules/runner/build.gradle | 1 -
.../configuration/generator/DefaultsGenerator.java | 2 +-
.../ItDistributedConfigurationPropertiesTest.java | 3 +-
.../ItDistributedConfigurationStorageTest.java | 3 +-
.../storage/ItRebalanceDistributedTest.java | 388 ++++++-----
...niteDistributionZoneManagerNodeRestartTest.java | 366 +++++-----
.../inmemory/ItRaftStorageVolatilityTest.java | 31 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 81 +--
.../rest/authentication/ItAuthenticationTest.java | 3 +-
.../runner/app/AbstractSchemaChangeTest.java | 2 +-
.../runner/app/ItIgniteNodeRestartTest.java | 5 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 64 +-
.../runner/app/PlatformTestNodeRunner.java | 10 +-
.../ItThinClientMarshallingEmbeddedTest.java} | 20 +-
.../app/client/ItThinClientMarshallingTest.java | 348 +++++++++
.../ItThinClientSchemaSynchronizationTest.java | 176 ++++-
.../runner/app/client/ItThinClientSqlTest.java | 13 +-
.../ignite/internal/sql/api/ItCommonApiTest.java | 33 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 205 ++++--
.../internal/sql/api/ItSqlSynchronousApiTest.java | 126 +++-
.../internal/sql/engine/ItAggregatesTest.java | 188 ++++-
.../internal/sql/engine/ItDataTypesTest.java | 43 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 79 ++-
.../sql/engine/ItDynamicParameterTest.java | 7 +-
.../internal/sql/engine/ItFunctionsTest.java | 29 +-
.../ignite/internal/sql/engine/ItIntervalTest.java | 4 +
.../internal/sql/engine/ItLimitOffsetTest.java | 41 +-
.../ignite/internal/sql/engine/ItSetOpTest.java | 123 +++-
.../internal/sql/engine/ItSqlOperatorsTest.java | 7 +-
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 122 ++--
.../sql/engine/datatypes/DataTypeTestSpecs.java | 10 +-
.../engine/datatypes/tests/BaseDataTypeTest.java | 32 +-
.../datatypes/tests/BaseDmlDataTypeTest.java | 21 +
.../tests/BaseExpressionDataTypeTest.java | 11 +
.../datatypes/tests/BaseIndexDataTypeTest.java | 20 +-
.../datatypes/tests/BaseQueryDataTypeTest.java | 6 +
.../engine/datatypes/tests/TestTypeArguments.java | 2 +
.../datatypes/uuid/ItUuidExpressionTest.java | 19 +
.../sql/engine/datatypes/uuid/ItUuidQueryTest.java | 2 +-
.../datatypes/varbinary/ItVarBinaryDmlTest.java | 2 +-
.../varbinary/ItVarBinaryExpressionTest.java | 13 -
.../datatypes/varbinary/ItVarBinaryIndexTest.java | 99 +++
.../datatypes/varbinary/ItVarBinaryQueryTest.java | 2 +-
.../apache/ignite/internal/sqllogic/Script.java | 2 -
.../apache/ignite/internal/start/ItStartTest.java | 42 +-
.../streamer/ItAbstractDataStreamerTest.java | 31 +-
.../internal/table/ItReadOnlyTransactionTest.java | 4 +-
.../ignite/internal/table/ItRoReadsTest.java | 112 ++-
.../ignite/internal/table/ItTableScanTest.java | 8 +-
.../internal/table/ItThinClientColocationTest.java | 4 +-
.../sql/aggregate/having/test_having.test | 6 +-
.../sql/cast/test_boolean_cast.test | 73 +-
.../filter/test_constant_comparisons.test_ignore | 12 -
.../sql/filter/test_obsolete_filters.test_ignore | 281 --------
...sert_type.test_ignore => test_insert_type.test} | 1 -
.../src/integrationTest/sql/sqlite/join/join1.test | 7 +-
.../sql/sqlite/join/join1.test_ignore | 159 -----
...est_ignored => select2_erroneous_hash_res.test} | 0
...res.test_ignored => select2_erroneous_res.test} | 0
...test_ignore => select3_erroneous_hash_res.test} | 0
..._res.test_ignore => select3_erroneous_res.test} | 0
.../any_all/test_uncorrelated_all_subquery.test | 22 +-
.../test_uncorrelated_all_subquery.test_ignore | 217 ------
...ignored => test_uncorrelated_any_subquery.test} | 1 -
.../subquery/exists/test_correlated_exists.test | 16 +
.../exists/test_correlated_exists.test_ignore | 17 -
.../scalar/test_count_star_subquery.test_ignore | 2 +-
.../scalar/test_uncorrelated_scalar_subquery.test | 7 +-
.../test_uncorrelated_scalar_subquery.test_ignore | 126 ----
...est_aliasing.test_ignore => test_aliasing.test} | 2 -
.../sql/subquery/table/test_table_subquery.test | 6 +
.../subquery/table/test_table_subquery.test_ignore | 55 --
.../integrationTest/sql/subquery/test_neumann.test | 6 +-
.../integrationTest/sql/types/blob/test_blob.test | 34 +-
.../sql/types/blob/test_blob_cast.test | 20 +-
.../sql/types/blob/test_blob_function.test | 27 +-
.../sql/types/blob/test_blob_operator.test | 45 +-
.../sql/types/blob/test_blob_string.test | 2 +-
.../types/timestamp/test_incorrect_timestamp.test | 30 +-
.../sql/types/timestamp/test_timestamp.test | 26 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 9 +-
.../internal/configuration/CompoundModule.java | 4 +-
.../internal/configuration/CompoundModuleTest.java | 9 +-
.../configuration/ConfigurationModulesTest.java | 3 +-
.../DistributedConfigurationUpdaterTest.java | 3 +-
.../ignite/internal/sql/engine/util/VarBinary.java | 3 +-
modules/schema/build.gradle | 3 +
.../apache/ignite/internal/schema/BinaryRow.java | 19 -
.../ignite/internal/schema/BinaryRowConverter.java | 82 ++-
.../ignite/internal/schema/BinaryRowImpl.java | 18 +-
.../ignite/internal/schema/ByteBufferRow.java | 84 ---
.../org/apache/ignite/internal/schema/Column.java | 3 +-
.../ignite/internal/schema/ColumnsExtractor.java} | 29 +-
.../ignite/internal/schema/DecimalNativeType.java | 6 -
.../apache/ignite/internal/schema/NativeType.java | 3 +-
.../ignite/internal/schema/NativeTypeSpec.java | 2 +-
.../apache/ignite/internal/schema/NativeTypes.java | 10 +-
.../ignite/internal/schema/SchemaDescriptor.java | 3 +-
.../ignite/internal/schema/SchemaRegistry.java | 10 +-
.../ignite/internal/schema/TemporalNativeType.java | 24 +-
.../ExtendedTableConfigurationSchema.java | 4 +-
.../SchemaDistributedConfigurationModule.java | 2 +-
.../internal/schema/mapping/ColumnMapper.java | 3 +-
.../internal/schema/mapping/ColumnMapperImpl.java | 3 +-
.../internal/schema/mapping/ColumnMapping.java | 3 +-
.../internal/schema/marshaller/KvMarshaller.java | 9 +-
.../internal/schema/marshaller/MarshallerUtil.java | 3 +-
.../schema/marshaller/RecordMarshaller.java | 7 +-
.../marshaller/asm/AsmMarshallerGenerator.java | 5 +-
.../asm/ObjectMarshallerCodeGenerator.java | 12 +
.../marshaller/reflection/ColumnBinding.java | 8 +-
.../marshaller/reflection/KvMarshallerImpl.java | 49 +-
.../schema/marshaller/reflection/Marshaller.java | 72 +-
.../marshaller/reflection/ObjectStatistics.java | 6 +-
.../reflection/RecordMarshallerImpl.java | 32 +-
.../reflection/ReflectionMarshallerFactory.java | 5 +-
.../schema/registry/SchemaRegistryImpl.java | 58 +-
.../schema/registry/UpgradingRowAdapter.java | 40 +-
.../org/apache/ignite/internal/schema/row/Row.java | 52 +-
.../ignite/internal/schema/row/RowAssembler.java | 60 +-
.../apache/ignite/internal/util/ObjectFactory.java | 2 +
.../benchmarks/SerializerBenchmarkTest.java | 7 +-
.../schema/AbstractSchemaConverterTest.java | 6 +-
.../internal/schema/CatalogSchemaManagerTest.java | 3 +-
.../org/apache/ignite/internal/schema/RowTest.java | 2 +-
.../SchemaDistributedConfigurationModuleTest.java | 2 +-
.../configuration/TableValidatorImplTest.java | 3 +-
.../index/IndexValidatorImplTest.java | 3 +-
.../schema/marshaller/KvMarshallerTest.java | 207 +++---
.../schema/marshaller/RecordMarshallerTest.java | 90 ++-
.../RecordMarshallerValidationsTest.java | 9 +-
.../schema/registry/UpgradingRowAdapterTest.java | 3 +-
.../schema/serializer/AbstractSerializerTest.java | 6 +-
.../ignite/internal/schema/BinaryRowMatcher.java | 62 ++
.../schema/testobjects/TestBitmaskObject.java} | 32 +-
.../schema/testobjects/TestSimpleObjectKey.java} | 39 +-
.../schema/testobjects/TestSimpleObjectVal.java} | 41 +-
.../testutils/SchemaConfigurationConverter.java | 3 +-
.../testutils/builder/AbstractIndexBuilder.java | 2 +-
.../builder/ColumnDefinitionBuilderImpl.java | 2 +-
.../builder/HashIndexDefinitionBuilderImpl.java | 2 +-
.../builder/PrimaryKeyDefinitionBuilderImpl.java | 2 +-
.../schema/testutils/builder/SchemaBuilders.java | 2 +-
.../builder/SortedIndexDefinitionBuilderImpl.java | 2 +-
.../builder/TableDefinitionBuilderImpl.java | 2 +-
.../schema/testutils/definition/ColumnType.java | 6 +-
.../AuthenticationProvidersValidatorImpl.java | 2 +-
.../AuthenticationConfigurationValidatorTest.java | 3 +-
.../AuthenticationProvidersValidatorTest.java | 3 +-
.../SecurityConfigurationModuleTest.java | 4 +-
.../AuthenticationManagerImplTest.java | 3 +-
modules/sql-engine/build.gradle | 5 +-
modules/sql-engine/src/main/codegen/config.fmpp | 345 +--------
.../src/main/codegen/includes/parserImpls.ftl | 8 +-
.../internal/sql/api/AsyncResultSetImpl.java | 31 +-
.../internal/sql/api/SessionBuilderImpl.java | 5 +-
.../ignite/internal/sql/api/SessionImpl.java | 76 +-
.../internal/sql/api/StatementBuilderImpl.java | 13 +-
.../ignite/internal/sql/api/StatementImpl.java | 7 +-
.../internal/sql/engine/AsyncSqlCursorImpl.java | 22 +-
.../internal/sql/engine/SqlQueryProcessor.java | 21 +-
.../internal/sql/engine/exec/ArrayRowHandler.java | 6 +-
.../sql/engine/exec/DestinationFactory.java | 110 +++
.../sql/engine/exec/ExchangeServiceImpl.java | 43 +-
.../internal/sql/engine/exec/ExecutableTable.java | 6 +
.../engine/exec/ExecutableTableRegistryImpl.java | 6 +
.../engine/exec/ExecutionDependencyResolver.java | 3 +-
.../exec/ExecutionDependencyResolverImpl.java | 37 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 19 +-
.../sql/engine/exec/LogicalRelImplementor.java | 89 ++-
.../sql/engine/exec/ResolvedDependencies.java | 9 +
.../internal/sql/engine/exec/RowHandler.java | 34 +-
.../internal/sql/engine/exec/RuntimeHashIndex.java | 2 -
.../sql/engine/exec/TableFunctionScan.java | 2 -
.../sql/engine/exec/UpdatableTableImpl.java | 147 ++--
.../sql/engine/exec/ddl/DdlCommandHandler.java | 6 +-
.../engine/exec/ddl/DdlCommandHandlerWrapper.java | 12 +-
.../exec/ddl/DdlToCatalogCommandConverter.java | 13 +
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 57 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 111 +--
.../internal/sql/engine/exec/exp/RexImpTable.java | 13 +-
.../sql/engine/exec/exp/agg/Accumulator.java | 5 +-
.../engine/exec/exp/agg/AccumulatorWrapper.java | 4 -
.../sql/engine/exec/exp/agg/Accumulators.java | 178 +----
.../engine/exec/exp/agg/AccumulatorsFactory.java | 25 +-
.../sql/engine/exec/exp/agg/AggregateRow.java | 86 +++
.../internal/sql/engine/exec/exp/agg/GroupKey.java | 21 +-
.../sql/engine/exec/rel/AbstractSetOpNode.java | 170 +++--
.../sql/engine/exec/rel/HashAggregateNode.java | 146 ++--
.../sql/engine/exec/rel/IntersectNode.java | 97 ++-
.../sql/engine/exec/rel/MergeJoinNode.java | 17 +-
.../internal/sql/engine/exec/rel/MinusNode.java | 94 ++-
.../internal/sql/engine/exec/rel/ModifyNode.java | 60 +-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 17 +-
.../internal/sql/engine/exec/rel/RootNode.java | 14 +-
.../internal/sql/engine/exec/rel/SingleNode.java | 5 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 69 +-
.../sql/engine/exec/row/BaseTypeSpec.java} | 65 +-
.../sql/engine/exec/row/NullTypeSpec.java} | 34 +-
.../internal/sql/engine/exec/row/RowSchema.java | 104 +++
.../sql/engine/exec/row/RowSchemaTypes.java | 85 +++
.../internal/sql/engine/exec/row/RowType.java} | 63 +-
.../internal/sql/engine/exec/row/TypeSpec.java} | 43 +-
.../internal/sql/engine/externalize/RelJson.java | 24 +-
.../sql/engine/metadata/ColocationGroup.java | 2 -
.../sql/engine/metadata/FragmentMapping.java | 3 +-
.../internal/sql/engine/prepare/CacheKey.java | 26 +-
.../engine/prepare/IgniteSqlToRelConvertor.java | 119 +++-
.../sql/engine/prepare/IgniteSqlValidator.java | 73 +-
.../sql/engine/prepare/IgniteTypeCoercion.java | 2 +-
.../sql/engine/prepare/PlanningContext.java | 5 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 36 +-
.../sql/engine/rel/agg/IgniteMapHashAggregate.java | 26 +-
.../sql/engine/rel/agg/IgniteMapSortAggregate.java | 20 +-
.../engine/rel/agg/IgniteReduceHashAggregate.java | 5 -
.../sql/engine/rel/agg/MapReduceAggregates.java | 347 +++++++++
.../engine/rel/set/IgniteColocatedIntersect.java | 9 +
.../sql/engine/rel/set/IgniteColocatedMinus.java | 9 +
.../sql/engine/rel/set/IgniteMapIntersect.java | 17 +-
.../sql/engine/rel/set/IgniteMapMinus.java | 12 +-
.../sql/engine/rel/set/IgniteMapSetOp.java | 32 +-
.../internal/sql/engine/rel/set/IgniteMinus.java | 10 +-
.../sql/engine/rel/set/IgniteMinusBase.java | 104 ---
.../sql/engine/rel/set/IgniteReduceIntersect.java | 18 +-
.../sql/engine/rel/set/IgniteReduceMinus.java | 12 +-
.../engine/rule/HashAggregateConverterRule.java | 71 +-
.../sql/engine/rule/SetOpConverterRule.java | 3 +-
.../engine/rule/SortAggregateConverterRule.java | 68 +-
.../sql/engine/rule/TableModifyConverterRule.java | 27 +-
.../sql/engine/schema/CatalogColumnDescriptor.java | 11 +-
.../sql/engine/schema/CatalogSqlSchemaManager.java | 98 ++-
.../internal/sql/engine/schema/IgniteSchema.java | 32 +-
.../sql/engine/schema/IgniteSchemaTable.java | 4 +-
.../sql/engine/schema/SqlSchemaManager.java | 24 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 54 +-
.../internal/sql/engine/sql/IgniteSqlParser.java | 103 ++-
.../sql/engine/trait/DistributionFunction.java | 73 --
.../sql/engine/trait/DistributionTrait.java | 8 -
.../sql/engine/trait/IgniteDistribution.java | 11 -
.../sql/engine/type/IgniteTypeFactory.java | 5 +-
.../internal/sql/engine/type/IgniteTypeSystem.java | 11 +-
.../ignite/internal/sql/engine/util/Commons.java | 47 +-
.../sql/engine/util/HashFunctionFactory.java | 6 +-
.../sql/engine/util/HashFunctionFactoryImpl.java | 25 +-
.../engine/util/IgniteCustomAssigmentsRules.java | 275 ++++++++
.../internal/sql/engine/util/IgniteResource.java | 14 +-
.../ignite/internal/sql/engine/util/PlanUtils.java | 125 ++++
.../engine/util/SqlExceptionMapperProvider.java | 63 ++
.../ignite/internal/sql/engine/util/TypeUtils.java | 93 ++-
.../sql/engine/AsyncSqlCursorImplTest.java | 117 ++++
.../internal/sql/engine/StopCalciteModuleTest.java | 13 +-
.../apache/ignite/internal/sql/engine/TestRow.java | 2 -
.../exec/ExecutableTableRegistrySelfTest.java | 3 +-
.../exec/ExecutionDependencyResolverSelfTest.java | 10 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 22 +-
.../sql/engine/exec/MockedStructuresTest.java | 25 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../engine/exec/TestExecutableTableRegistry.java | 6 +
.../DdlCommandHandlerExceptionHandlingTest.java | 95 +--
.../exec/ddl/DdlToCatalogCommandConverterTest.java | 150 ++++
.../ddl/DistributionZoneDdlCommandHandlerTest.java | 179 +----
.../engine/exec/exp/ExpressionFactoryImplTest.java | 4 +-
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 34 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 6 +-
.../exec/rel/AbstractSetOpExecutionTest.java | 20 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 20 +
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 13 +-
.../sql/engine/exec/rel/ExecutionTest.java | 16 +-
.../exec/rel/HashAggregateExecutionTest.java | 9 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 129 ++--
.../exec/rel/HashIndexSpoolExecutionTest.java | 3 +-
.../exec/rel/IndexScanNodeExecutionTest.java | 7 +-
.../engine/exec/rel/IntersectExecutionTest.java | 4 +-
.../sql/engine/exec/rel/MinusExecutionTest.java | 4 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 22 +-
.../exec/rel/SortAggregateExecutionTest.java | 9 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 3 +-
.../exec/rel/TableScanNodeExecutionTest.java | 13 +-
.../engine/exec/rel/TableSpoolExecutionTest.java | 3 +-
.../sql/engine/exec/row/RowSchemaTest.java | 76 ++
.../sql/engine/exec/row/RowSchemaTypesTest.java | 221 ++++++
.../engine/exec/schema/SqlSchemaManagerTest.java | 37 +-
.../engine/framework/ClusterServiceFactory.java | 12 +-
.../sql/engine/framework/NoOpTransaction.java | 30 +-
.../engine/framework/PredefinedSchemaManager.java | 39 +-
.../sql/engine/framework/TestBuilders.java | 27 +-
.../sql/engine/framework/TestClusterTest.java | 3 +-
.../internal/sql/engine/framework/TestNode.java | 5 +-
.../planner/AbstractAggregatePlannerTest.java | 115 +--
.../sql/engine/planner/AbstractPlannerTest.java | 12 +-
.../sql/engine/planner/AggregatePlannerTest.java | 69 +-
.../sql/engine/planner/CastResolutionTest.java | 362 ++++++++++
.../planner/ColocatedHashAggregatePlannerTest.java | 33 +
.../planner/ColocatedSortAggregatePlannerTest.java | 34 +
.../sql/engine/planner/DmlPlannerTest.java | 52 +-
.../sql/engine/planner/DynamicParametersTest.java | 10 +-
.../sql/engine/planner/ImplicitCastsTest.java | 2 +-
.../sql/engine/planner/JoinCommutePlannerTest.java | 6 +-
.../planner/MapReduceHashAggregatePlannerTest.java | 90 ++-
.../planner/MapReduceSortAggregatePlannerTest.java | 89 ++-
.../sql/engine/planner/UnionPlannerTest.java | 23 +-
.../sql/engine/prepare/TypeCoercionTest.java | 30 +-
.../engine/schema/CatalogSqlSchemaManagerTest.java | 25 +-
.../engine/sql/IgniteSqlDecimalLiteralTest.java | 10 -
.../sql/engine/sql/IgniteSqlParserTest.java | 61 +-
.../internal/sql/engine/sql/SqlDdlParserTest.java | 4 +-
.../sql/engine/sql/SqlReservedWordsTest.java | 265 +++++++
.../internal/sql/engine/util/CommonsTest.java | 54 ++
.../internal/sql/engine/util/PlanUtilsTest.java | 113 +++
.../internal/sql/engine/util/StatementChecker.java | 27 +-
.../internal/sql/engine/util/TypeUtilsTest.java | 183 ++++-
modules/sql-engine/src/test/resources/tpch/q11.sql | 4 +-
.../internal/sql/engine/util/SqlTestUtils.java | 22 +
.../internal/storage/DataStorageManagerTest.java | 3 +-
.../internal/storage/DataStorageModulesTest.java | 3 +-
.../ExistingDataStorageValidatorTest.java | 3 +-
.../internal/storage/util/LockHolderTest.java | 4 +-
.../storage/util/MvPartitionStoragesTest.java | 3 +-
.../AbstractMvPartitionStorageConcurrencyTest.java | 35 +-
.../storage/AbstractMvPartitionStorageGcTest.java | 21 +-
.../storage/AbstractMvPartitionStorageTest.java | 117 ++--
.../storage/AbstractMvTableStorageTest.java | 4 +-
.../internal/storage/BaseMvStoragesTest.java | 42 +-
.../storage/impl/TestMvPartitionStorage.java | 10 +-
.../storage/index/AbstractIndexStorageTest.java | 3 +-
.../PersistentPageMemoryDataRegionTest.java | 3 +-
.../PageMemoryDataRegionValidatorImplTest.java | 3 +-
.../storage/pagememory/index/InlineUtilsTest.java | 3 +-
.../AbstractPageMemoryMvPartitionStorageTest.java | 11 +-
.../storage/pagememory/mv/BlobStorageTest.java | 3 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 3 +-
.../storage/rocksdb/PartitionDataHelper.java | 10 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 23 +-
.../instance/SharedRocksDbInstanceCreator.java | 12 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 3 +-
.../RocksDbDataRegionValidatorImplTest.java | 3 +-
modules/table/build.gradle | 1 -
.../ItAbstractInternalTableScanTest.java | 4 +-
.../ItInternalTableReadOnlyOperationsTest.java | 13 +-
.../ignite/distributed/ItTablePersistenceTest.java | 43 +-
.../distributed/ItTxDistributedTestSingleNode.java | 12 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 27 +-
.../ignite/internal/table/ItColocationTest.java | 16 +-
.../schema/marshaller/TupleMarshaller.java | 7 +-
.../schema/marshaller/TupleMarshallerImpl.java | 58 +-
.../internal/table/AbstractRowTupleAdapter.java | 35 +-
.../apache/ignite/internal/table/DataStreamer.java | 2 -
.../apache/ignite/internal/table/IndexWrapper.java | 12 +-
.../internal/table/KeyValueBinaryViewImpl.java | 91 ++-
.../ignite/internal/table/KeyValueViewImpl.java | 85 ++-
.../internal/table/MutableRowTupleAdapter.java | 33 +-
.../internal/table/RecordBinaryViewImpl.java | 77 +-
.../ignite/internal/table/RecordViewImpl.java | 63 +-
.../apache/ignite/internal/table/TableImpl.java | 8 +-
.../org/apache/ignite/internal/table/TableRow.java | 13 +-
.../table/distributed/HashIndexLocker.java | 20 +-
.../internal/table/distributed/IndexLocker.java | 18 +-
.../table/distributed/SortedIndexLocker.java | 21 +-
.../table/distributed/StorageUpdateHandler.java | 81 ++-
.../internal/table/distributed/TableManager.java | 38 +-
.../table/distributed/TableMessageGroup.java | 6 +
.../distributed/TableSchemaAwareIndexStorage.java | 21 +-
.../distributed/command/PartitionCommand.java | 5 +
.../distributed/command/UpdateAllCommand.java | 4 +-
.../table/distributed/command/UpdateCommand.java | 13 +-
.../distributed/index/IndexUpdateHandler.java | 4 +-
.../distributed/raft/PartitionDataStorage.java | 9 +
.../table/distributed/raft/PartitionListener.java | 31 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 7 +-
.../snapshot/message/SnapshotMvDataResponse.java | 4 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 24 +-
.../SnapshotAwarePartitionDataStorage.java | 8 +
...owReplicaRequest.java => BinaryRowMessage.java} | 26 +-
.../request/MultipleRowReplicaRequest.java | 15 +-
.../request/ReadWriteMultiRowReplicaRequest.java | 5 +
.../ReadWriteScanRetrieveBatchReplicaRequest.java | 4 +
.../request/ReadWriteSingleRowReplicaRequest.java | 5 +
.../request/ReadWriteSwapRowReplicaRequest.java | 5 +
.../request/SingleRowReplicaRequest.java | 6 +-
.../replication/request/SwapRowReplicaRequest.java | 10 +-
.../replicator/PartitionReplicaListener.java | 708 ++++++++++---------
.../distributed/schema/SchemaSyncService.java | 44 ++
.../distributed/schema/SchemaSyncServiceImpl.java | 54 ++
.../distributed/storage/InternalTableImpl.java | 274 ++++----
.../table/ColocationHashCalculationTest.java | 5 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 2 -
.../internal/table/KeyValueViewOperationsTest.java | 6 +-
.../internal/table/MutableRowTupleAdapterTest.java | 2 -
.../table/RecordBinaryViewOperationsTest.java | 2 -
.../internal/table/RecordViewOperationsTest.java | 3 -
.../RepeatedFinishReadWriteTransactionTest.java | 6 +-
.../apache/ignite/internal/table/TxLocalTest.java | 62 +-
.../distributed/ConfiguredTablesCacheTest.java | 3 +-
.../internal/table/distributed/IndexBaseTest.java | 84 ++-
.../table/distributed/LowWatermarkTest.java | 3 +-
.../table/distributed/PartitionMoverTest.java | 3 +-
.../distributed/StorageUpdateHandlerTest.java | 5 +-
.../table/distributed/TableManagerTest.java | 222 +++---
.../PartitionRaftCommandsSerializationTest.java | 41 +-
.../internal/table/distributed/gc/MvGcTest.java | 3 +-
.../gc/VolatilePageMemoryGcUpdateHandlerTest.java | 2 -
.../distributed/index/IndexUpdateHandlerTest.java | 3 +-
.../raft/PartitionCommandListenerTest.java | 53 +-
.../raft/snapshot/PartitionAccessImplTest.java | 3 +-
.../PartitionSnapshotStorageFactoryTest.java | 3 +-
.../snapshot/PartitionSnapshotStorageTest.java | 3 +-
.../incoming/IncomingSnapshotCopierTest.java | 14 +-
.../incoming/IncomingSnapshotReaderTest.java | 3 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 3 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 82 ++-
.../outgoing/OutgoingSnapshotReaderTest.java | 3 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 3 +-
.../outgoing/OutgoingSnapshotsManagerTest.java | 3 +-
.../SnapshotAwarePartitionDataStorageTest.java | 3 +-
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 3 +-
.../PartitionReplicaListenerIndexLockingTest.java | 99 ++-
.../replication/PartitionReplicaListenerTest.java | 249 ++++---
.../distributed/schema/FullTableSchemaTest.java | 3 -
.../schema/SchemaSyncServiceImplTest.java | 85 +++
.../distributed/storage/InternalTableImplTest.java | 3 +-
.../table/type/NumericTypesSerializerTest.java | 2 -
.../distributed/TestPartitionDataStorage.java | 5 +
.../ignite/internal/table/TxAbstractTest.java | 49 +-
.../table/impl/DummyInternalTableImpl.java | 82 +--
.../table/impl/DummySchemaManagerImpl.java | 18 +-
.../internal/table/impl/TestTupleBuilder.java | 32 +-
.../ignite/internal/tx/InternalTransaction.java | 4 +-
.../org/apache/ignite/internal/tx/Timestamp.java | 3 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 5 +-
.../tx/impl/IgniteAbstractTransactionImpl.java | 4 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 32 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 5 +-
.../tx/impl/ReadOnlyTransactionImplTest.java | 3 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 3 +-
packaging/common/bootstrap-functions.sh | 4 +-
packaging/docker/docker-entrypoint.sh | 4 +-
packaging/odbc/build.gradle | 4 +-
settings.gradle | 2 +
1082 files changed, 27687 insertions(+), 14445 deletions(-)
delete mode 100644 config/java.util.logging.properties
rename modules/{core =>
api}/src/main/java/org/apache/ignite/lang/ErrorGroup.java (100%)
rename modules/{core =>
api}/src/main/java/org/apache/ignite/lang/ErrorGroups.java (100%)
delete mode 100755
modules/api/src/main/java/org/apache/ignite/lang/IgniteExceptionUtils.java
rename modules/{core =>
api}/src/main/java/org/apache/ignite/lang/TraceableException.java (100%)
rename modules/{core/src/main/java/org/apache/ignite/internal =>
api/src/main/java/org/apache/ignite/lang}/util/IgniteNameUtils.java (91%)
copy modules/{core/src/main/java/org/apache/ignite/internal =>
api/src/main/java/org/apache/ignite/lang}/util/StringUtils.java (97%)
create mode 100755
modules/api/src/main/java/org/apache/ignite/lang/util/TraceIdUtils.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/CatalogParamsValidationUtils.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/CatalogValidationException.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/AbstractUpdateZoneCommandParams.java
copy
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/{DropZoneParams.java
=> DataStorageParams.java} (51%)
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogManagerValidationTest.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/commands/CatalogUtilsTest.java
create mode 100644
modules/catalog/src/testFixtures/java/org/apache/ignite/internal/catalog/BaseCatalogManagerTest.java
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/ItConnectionHeartbeatTest.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/connect/ConnectCallInput.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/connect/ConnectOptions.java
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/{AsyncSessionEventListener.java
=> ConnectEvent.java} (63%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/ConnectionHeartBeat.java
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/{AsyncSessionEventListener.java
=> ConnectionLostEvent.java} (74%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/{AsyncSessionEventListener.java
=> ConnectionRestoredEvent.java} (73%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/{AsyncSessionEventListener.java
=> DisconnectEvent.java} (74%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/EventListeningActivationPoint.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/event/ConnectionEventListener.java
copy modules/{platforms/dotnet/Apache.Ignite.Tests/Table/PocoStruct.cs =>
cli/src/main/java/org/apache/ignite/internal/cli/event/Event.java} (82%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/event/EventFactory.java
copy buildscripts/java-test-fixtures.gradle =>
modules/cli/src/main/java/org/apache/ignite/internal/cli/event/EventListener.java
(81%)
copy buildscripts/java-test-fixtures.gradle =>
modules/cli/src/main/java/org/apache/ignite/internal/cli/event/EventPublisher.java
(76%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/{core/repl/AsyncSessionEventListener.java
=> event/EventSubscriptionManager.java} (74%)
copy modules/{platforms/dotnet/Apache.Ignite.Tests/Table/PocoStruct.cs =>
cli/src/main/java/org/apache/ignite/internal/cli/event/EventType.java} (81%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/event/Events.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/core/exception/handler/IgniteCliApiExceptionHandlerTest.java
create mode 100644
modules/client-handler/src/test/java/org/apache/ignite/client/handler/requests/jdbc/JdbcQueryCursorSelfTest.java
copy modules/{api/src/main/java/org/apache/ignite/network/ClusterNode.java =>
client/src/main/java/org/apache/ignite/internal/client/ClientClusterNode.java}
(74%)
mode change 100644 => 100755
rename
modules/configuration-api/src/main/java/org/apache/ignite/configuration/annotation/{InternalConfiguration.java
=> ConfigurationExtension.java} (74%)
rename modules/{api/src/main/java/org/apache/ignite/lang =>
core/src/main/java/org/apache/ignite/internal/distributionzones}/DistributionZoneAlreadyExistsException.java
(92%)
rename modules/{api/src/main/java/org/apache/ignite/lang =>
core/src/main/java/org/apache/ignite/internal/distributionzones}/DistributionZoneBindTableException.java
(93%)
rename modules/{api/src/main/java/org/apache/ignite/lang =>
core/src/main/java/org/apache/ignite/internal/distributionzones}/DistributionZoneNotFoundException.java
(93%)
create mode 100755
modules/core/src/main/java/org/apache/ignite/internal/sql/AbstractSession.java
rename modules/{api/src/main/java/org/apache/ignite =>
core/src/main/java/org/apache/ignite/internal}/sql/SyncResultSetAdapter.java
(94%)
copy
modules/core/src/main/java/org/apache/ignite/internal/thread/{StripedThreadPoolExecutor.java
=> AbstractStripedThreadPoolExecutor.java} (63%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/thread/StripedScheduledThreadPoolExecutor.java
rename modules/{api =>
core}/src/main/java/org/apache/ignite/lang/IgniteExceptionMapper.java (100%)
rename modules/{api =>
core}/src/main/java/org/apache/ignite/lang/IgniteExceptionMapperUtil.java (100%)
rename modules/{api =>
core}/src/main/java/org/apache/ignite/lang/IgniteExceptionMappersProvider.java
(100%)
rename
modules/core/src/main/java/org/apache/ignite/lang/{IgniteFiveFunction.java =>
IgnitePentaFunction.java} (97%)
rename
modules/core/src/main/java/org/apache/ignite/lang/{IgniteTetraFunction.java =>
IgniteQuadFunction.java} (97%)
mode change 100755 => 100644
rename
modules/{api/src/test/java/org/apache/ignite/lang/IgniteExceptionUtilsTest.java
=> core/src/test/java/org/apache/ignite/lang/ExceptionUtilsTest.java} (96%)
rename modules/{api =>
core}/src/test/java/org/apache/ignite/lang/IgniteExceptionMapperUtilTest.java
(100%)
rename modules/{api =>
core}/src/test/java/org/apache/ignite/lang/IgniteExceptionTest.java (95%)
rename modules/{api =>
core}/src/test/java/org/apache/ignite/lang/TestIgniteExceptionMappersProvider.java
(100%)
rename modules/{api =>
core}/src/testFixtures/java/org/apache/ignite/internal/testframework/IntegrationTestBase.java
(100%)
rename modules/{api =>
core}/src/testFixtures/java/org/apache/ignite/internal/testframework/TestIgnitionManager.java
(100%)
create mode 100755
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/log4j2/LogInspector.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/matchers/PathMatcher.java
delete mode 100644
modules/core/src/testFixtures/resources/java.util.logging.properties
create mode 100755 modules/core/src/testFixtures/resources/log4j2-test.xml
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/utils/CatalogAlterZoneEventListener.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/utils/CatalogAlterZoneEventListenerTest.java
create mode 100644 modules/file-transfer/README.md
copy modules/{configuration => file-transfer}/build.gradle (62%)
create mode 100644
modules/file-transfer/src/integrationTest/java/org/apache/ignite/internal/network/file/ItFileTransferTest.java
create mode 100644
modules/file-transfer/src/integrationTest/java/org/apache/ignite/internal/network/file/TestCluster.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/PartitionCommand.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/Channel.java}
(70%)
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/ChunkedFileReader.java
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/ChunkedFileWriter.java
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/FileChunkMessagesStream.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/FileConsumer.java}
(53%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/FileProvider.java}
(65%)
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/FileReceiver.java
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/FileSender.java
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/FileTransferMessagesHandler.java
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/FileTransferService.java
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/FileTransferServiceImpl.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/TransferredFilesCollector.java}
(67%)
copy modules/{binary-tuple/build.gradle =>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/exception/ErrorCodes.java}
(66%)
copy
modules/{configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/internal/ErrorInternal1ConfigurationSchema.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/exception/FileTransferException.java}
(57%)
copy
modules/{configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/internal/ErrorInternal1ConfigurationSchema.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/exception/FileValidationException.java}
(63%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateCommand.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileChunkMessage.java}
(55%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateCommand.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileChunkResponse.java}
(66%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateCommand.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileDownloadRequest.java}
(60%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateCommand.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileDownloadResponse.java}
(59%)
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileHeader.java
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileTransferError.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateCommand.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileTransferErrorMessage.java}
(64%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/raft/commands/ClusterNodeMessage.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileTransferInitMessage.java}
(52%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateCommand.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileTransferInitResponse.java}
(65%)
create mode 100644
modules/file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/FileTransferMessageType.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateAllCommand.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/messages/Identifier.java}
(61%)
create mode 100644
modules/file-transfer/src/test/java/org/apache/ignite/internal/network/file/ChunkedFileReaderTest.java
create mode 100644
modules/file-transfer/src/test/java/org/apache/ignite/internal/network/file/ChunkedFileWriterTest.java
create mode 100644
modules/file-transfer/src/test/java/org/apache/ignite/internal/network/file/FileChunkMessagesStreamTest.java
create mode 100644
modules/file-transfer/src/test/java/org/apache/ignite/internal/network/file/FileReceiverTest.java
create mode 100644
modules/file-transfer/src/test/java/org/apache/ignite/internal/network/file/FileSenderTest.java
create mode 100644
modules/file-transfer/src/test/java/org/apache/ignite/internal/network/file/FileTransferServiceImplTest.java
create mode 100644
modules/file-transfer/src/test/java/org/apache/ignite/internal/network/file/TestMessagingService.java
create mode 100644
modules/file-transfer/src/test/java/org/apache/ignite/internal/network/file/TestTopologyService.java
copy
modules/{raft/src/test/java/org/apache/ignite/raft/jraft/storage/BaseStorageTest.java
=>
file-transfer/src/testFixtures/java/org/apache/ignite/internal/network/file/FileGenerator.java}
(55%)
create mode 100644
modules/file-transfer/src/testFixtures/java/org/apache/ignite/internal/network/file/PathAssertions.java
copy buildscripts/java-test-fixtures.gradle =>
modules/marshaller-common/src/main/java/org/apache/ignite/internal/marshaller/UnmappedColumnsException.java
(78%)
copy modules/{api/src/main/java/org/apache/ignite/network/ClusterNode.java =>
network-api/src/main/java/org/apache/ignite/network/ClusterNodeImpl.java} (77%)
mode change 100644 => 100755
copy
modules/{configuration/src/testFixtures/java/org/apache/ignite/internal/configuration/testframework/ExtendedConfigurationSchema.java
=>
network/src/main/java/org/apache/ignite/internal/network/configuration/FileTransferConfigurationSchema.java}
(55%)
create mode 100644
modules/placement-driver/src/integrationTest/java/org/apache/ignite/internal/placementdriver/BasePlacementDriverTest.java
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/core/repl/SessionInfo.java
=>
placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/Leases.java}
(52%)
copy
modules/{metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/TombstoneCondition.java
=> platforms/cpp/ignite/client/detail/connection_event_handler.h} (52%)
delete mode 100644 modules/platforms/cpp/ignite/odbc/protocol_version.cpp
delete mode 100644 modules/platforms/cpp/ignite/odbc/protocol_version.h
create mode 100644 modules/platforms/cpp/ignite/protocol/messages.cpp
create mode 100644 modules/platforms/cpp/ignite/protocol/messages.h
rename modules/platforms/cpp/ignite/{client/detail =>
protocol}/protocol_context.h (86%)
create mode 100644 modules/platforms/cpp/ignite/protocol/protocol_version.cpp
rename modules/platforms/cpp/ignite/{client/detail =>
protocol}/protocol_version.h (63%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/BinaryTupleIgniteTupleAdapterTests.cs
copy
modules/platforms/dotnet/Apache.Ignite.Tests/{Common/CollectionExtensions.cs =>
Table/KeyPoco.cs} (72%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/SchemaSynchronizationTest.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/SchemaValidationTest.cs
copy
modules/platforms/dotnet/Apache.Ignite.Tests/{Common/CollectionExtensions.cs =>
Table/ValPoco.cs} (68%)
copy modules/platforms/dotnet/Apache.Ignite/Internal/{Table/Column.cs =>
Common/CollectionExtensions.cs} (61%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Common/ExceptionExtensions.cs
copy modules/platforms/dotnet/Apache.Ignite/Internal/{Table/Column.cs =>
IClientSocketEventListener.cs} (64%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Proto/BinaryTuple/BinaryTupleIgniteTupleAdapter.cs
copy modules/platforms/dotnet/Apache.Ignite/Internal/{Table/Column.cs =>
Proto/ErrorExtensions.cs} (69%)
copy modules/platforms/dotnet/Apache.Ignite/Internal/Table/{Column.cs =>
IgniteTupleCommon.cs} (59%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/SerializerExceptionExtensions.cs
rename
modules/{core/src/main/java/org/apache/ignite/internal/util/StringUtils.java =>
raft/src/main/java/org/apache/ignite/raft/jraft/error/OverloadException.java}
(52%)
copy
modules/{configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/internal/ErrorInternal3ConfigurationSchema.java
=> raft/src/main/java/org/apache/ignite/raft/jraft/option/ApplyTaskMode.java}
(67%)
rename
modules/{platforms/dotnet/Apache.Ignite.Tests/Common/CollectionExtensions.cs =>
runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientMarshallingEmbeddedTest.java}
(71%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientMarshallingTest.java
delete mode 100644
modules/runner/src/integrationTest/sql/filter/test_constant_comparisons.test_ignore
delete mode 100644
modules/runner/src/integrationTest/sql/filter/test_obsolete_filters.test_ignore
rename
modules/runner/src/integrationTest/sql/insert/{test_insert_type.test_ignore =>
test_insert_type.test} (88%)
delete mode 100644
modules/runner/src/integrationTest/sql/sqlite/join/join1.test_ignore
rename
modules/runner/src/integrationTest/sql/sqlite/select2/{select2_erroneous_hash_res.test_ignored
=> select2_erroneous_hash_res.test} (100%)
rename
modules/runner/src/integrationTest/sql/sqlite/select2/{select2_erroneous_res.test_ignored
=> select2_erroneous_res.test} (100%)
rename
modules/runner/src/integrationTest/sql/sqlite/select3/{select3_erroneous_hash_res.test_ignore
=> select3_erroneous_hash_res.test} (100%)
rename
modules/runner/src/integrationTest/sql/sqlite/select3/{select3_erroneous_res.test_ignore
=> select3_erroneous_res.test} (100%)
delete mode 100644
modules/runner/src/integrationTest/sql/subquery/any_all/test_uncorrelated_all_subquery.test_ignore
rename
modules/runner/src/integrationTest/sql/subquery/any_all/{test_uncorrelated_any_subquery.test_ignored
=> test_uncorrelated_any_subquery.test} (97%)
delete mode 100644
modules/runner/src/integrationTest/sql/subquery/scalar/test_uncorrelated_scalar_subquery.test_ignore
rename
modules/runner/src/integrationTest/sql/subquery/table/{test_aliasing.test_ignore
=> test_aliasing.test} (86%)
delete mode 100644
modules/runner/src/integrationTest/sql/subquery/table/test_table_subquery.test_ignore
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/ByteBufferRow.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutableTable.java
=>
schema/src/main/java/org/apache/ignite/internal/schema/ColumnsExtractor.java}
(55%)
create mode 100644
modules/schema/src/testFixtures/java/org/apache/ignite/internal/schema/BinaryRowMatcher.java
rename
modules/{core/src/testFixtures/java/org/apache/ignite/internal/testframework/jul/NoOpHandler.java
=>
schema/src/testFixtures/java/org/apache/ignite/internal/schema/testobjects/TestBitmaskObject.java}
(62%)
copy
modules/{marshaller-common/src/test/java/org/apache/ignite/internal/marshaller/testobjects/TestObjectWithNoDefaultConstructor.java
=>
schema/src/testFixtures/java/org/apache/ignite/internal/schema/testobjects/TestSimpleObjectKey.java}
(59%)
copy
modules/{marshaller-common/src/test/java/org/apache/ignite/internal/marshaller/testobjects/TestObjectWithNoDefaultConstructor.java
=>
schema/src/testFixtures/java/org/apache/ignite/internal/schema/testobjects/TestSimpleObjectVal.java}
(57%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/DestinationFactory.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/AggregateRow.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/DecimalNativeType.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/BaseTypeSpec.java}
(53%)
copy
modules/{arch-test/src/test/java/org/apache/ignite/lang/IgniteTestImportOption.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/NullTypeSpec.java}
(57%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/RowSchema.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/RowSchemaTypes.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/DecimalNativeType.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/RowType.java}
(54%)
rename
modules/{arch-test/src/test/java/org/apache/ignite/lang/TestsWithFixturesImportOption.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/row/TypeSpec.java}
(50%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/MapReduceAggregates.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteMinusBase.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/IgniteCustomAssigmentsRules.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/SqlExceptionMapperProvider.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/AsyncSqlCursorImplTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ddl/DdlToCatalogCommandConverterTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/row/RowSchemaTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/row/RowSchemaTypesTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/CastResolutionTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/sql/SqlReservedWordsTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/CommonsTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/PlanUtilsTest.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/{ReadWriteMultiRowReplicaRequest.java
=> BinaryRowMessage.java} (66%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/SchemaSyncService.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/SchemaSyncServiceImpl.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/schema/SchemaSyncServiceImplTest.java
