You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sd...@apache.org on 2022/09/20 12:09:15 UTC
[ignite-3] branch ignite-17627 updated (d03e73780e -> 43ac664f4a)
This is an automated email from the ASF dual-hosted git repository.
sdanilov pushed a change to branch ignite-17627
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit d03e73780e IGNITE-17627 Second iteration of fixes
omit 4593dcaf1a IGNITE-17627 First iteration of fixes
omit 3ab38c76e2 IGNITE-17627 First iteration of fixes
omit a99b902c3a IGNITE-17627 First iteration of fixes
omit 2a536ead96 IGNITE-17627 Extend MvPartitionStorage read API with write intent resolution capabilities
omit 27c81472a8 IGNITE-17627 Extend MvPartitionStorage read API with write intent resolution capabilities
omit 45e228da7c IGNITE-17627 Extend MvPartitionStorage read API with write intent resolution capabilities
add 91f9cee9ab IGNITE-17297 Adopt BinaryTuple format in the client protocol (#1058)
add e5156a8caa IGNITE-17611 Local storage recovery code for TxStateRocksDbStorage (#1061)
add d9d230453b IGNITE-17444 Introduced MetricExporter interface and service loading. Fixes #1027
add eb4f324245 IGNITE-17090 Show user-friendly message in sql command. Fixes #1024
add 9f270fd2b4 IGNITE-17510 Fixed NullPointerException in cluster configuration REST calls. Fixes #1037
add 8fbbb62faf IGNITE-17664 Fix conflicting TX and CLIENT error group ids (#1069)
add 2049b5858c IGNITE-17628 Get rid of Statement#prepared in public API (#1068)
add bdf3eda031 IGNITE-17621 Fixed registration already completed future in InFlightFutures
add a4345bd523 IGNITE-17670 Implementing a sorted index B+Tree (#1075)
add 076ce8bff9 IGNITE-17676 Fixed race in AwaitTasksCompletionExecutor that causes tests to be flaky (#1077)
add 9afa9a66e5 IGNITE-17564 Use user flow for all REPL commands (#1060)
add 4426a372ed IGNITE-17652 Improve B+Tree implementation documentation (#1084)
add 5f9957f80a IGNITE-17689 Add UUID support for org.apache.ignite.configuration.annotation.Value (#1082)
add fa79ad532b IGNITE-17693 Unified copyrights - extra spaces removed (#1083)
add 2733f06e77 IGNITE-17697 Stop thread-pools when RocksDB components are stopped (#1087)
add 81de6658b6 IGNITE-17698 Fix UUID serialization in configuration (#1089)
add f29e70e9e9 IGNITE-17608: PMD and checkstyle for gradle build (#1065)
add 64ccd4597b IGNITE-17706 Remove directions in SortedIndexStorage (#1091)
add 04c159aefc IGNITE-17445 RocksDbKeyValueStorage recreates DB on start, so data can't be found until Raft log is replayed (#1066)
add 895502ecd1 IGNITE-17314 .NET: Implement unified exception handling (#1074)
add 818db99667 IGNITE-17712 Fix UUID serialization for hocon in configuration (#1093)
add 48abcbe3ff IGNITE-17701 Add common C++ utilities (#1090)
add d579f0a73c IGNITE-17715 Specify default path to the checkstyle header (#1096)
add fc959a42eb IGNITE-17632 Support decimal scale in client schema (#1097)
add 2fef41a481 IGNITE-17667 Divide long test into suitable parts - Fixes #1071.
add 50bab7859a IGNITE-17707 Unified annotation dependency. Fixes #1094
add 8d286cc799 IGNITE-17678 Added description for transaction changes. Fixes #1079
add dde690291b IGNITE-17627 Extend MvPartitionStorage read API with write intent resolution capabilities
add e606ca74d3 IGNITE-17627 Extend MvPartitionStorage read API with write intent resolution capabilities
add 574f58248e IGNITE-17627 Extend MvPartitionStorage read API with write intent resolution capabilities
add fd588fc414 IGNITE-17627 First iteration of fixes
add abf0fae9c4 IGNITE-17627 First iteration of fixes
add dcc6c3963c IGNITE-17627 First iteration of fixes
add 46e648859a IGNITE-17627 Second iteration of fixes
add 43ac664f4a IGNITE-17627 More of second iteration of fixes
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 (d03e73780e)
\
N -- N -- N refs/heads/ignite-17627 (43ac664f4a)
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:
build.gradle | 11 +-
buildscripts/java-core.gradle | 60 +-
buildscripts/java-integration-test.gradle | 6 +-
buildscripts/java-junit5.gradle | 6 +-
buildscripts/java-library.gradle | 18 -
buildscripts/java-test-fixtures.gradle | 7 +-
buildscripts/publishing-repos.gradle | 4 +-
buildscripts/publishing.gradle | 4 +-
buildscripts/sql-parser-generator.gradle | 93 +
check-rules/LICENSE.txt | 4 +-
check-rules/checkstyle-rules.xml | 8 +-
.../transactions/performing-transactions.adoc | 70 +-
docs/assets/css/docs.scss | 4 +-
docs/assets/css/styles.scss | 4 +-
examples/build.gradle | 13 +-
.../ignite/example/AbstractExamplesTest.java | 2 +-
.../apache/ignite/example/ExampleTestUtils.java | 2 +-
.../ignite/example/sql/ItSqlExamplesTest.java | 2 +-
.../storage/ItPageMemoryStorageExampleTest.java | 2 +-
.../storage/ItRocksdbStorageExampleTest.java | 2 +-
.../ignite/example/table/ItTableExamplesTest.java | 2 +-
.../example/tx/ItTransactionsExamplesTest.java | 2 +-
.../apache/ignite/example/sql/SqlApiExample.java | 2 +-
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 4 +-
.../PersistentPageMemoryStorageExample.java | 4 +-
.../example/storage/RocksDbStorageExample.java | 4 +-
.../example/storage/StorageEngineExample.java | 2 +-
.../storage/VolatilePageMemoryStorageExample.java | 4 +-
.../ignite/example/table/KeyValueViewExample.java | 4 +-
.../example/table/KeyValueViewPojoExample.java | 4 +-
.../ignite/example/table/RecordViewExample.java | 4 +-
.../example/table/RecordViewPojoExample.java | 4 +-
.../ignite/example/tx/TransactionsExample.java | 4 +-
gradle/libs.versions.toml | 120 +-
modules/affinity/build.gradle | 9 +-
.../ignite/internal/affinity/AffinityUtils.java | 4 +-
.../affinity/RendezvousAffinityFunction.java | 4 +-
.../internal/affinity/AffinityServiceTest.java | 4 +-
.../affinity/RendezvousAffinityFunctionTest.java | 4 +-
modules/api/build.gradle | 6 +-
.../src/main/java/org/apache/ignite/Ignite.java | 4 +-
.../src/main/java/org/apache/ignite/Ignition.java | 4 +-
.../java/org/apache/ignite/IgnitionManager.java | 4 +-
.../org/apache/ignite/binary/BinaryObject.java | 4 +-
.../org/apache/ignite/binary/package-info.java | 4 +-
.../java/org/apache/ignite/compute/ComputeJob.java | 4 +-
.../org/apache/ignite/compute/IgniteCompute.java | 4 +-
.../apache/ignite/compute/JobExecutionContext.java | 4 +-
.../ClientConnectorConfigurationSchema.java | 4 +-
.../schemas/clientconnector/package-info.java | 4 +-
.../compute/ComputeConfigurationSchema.java | 4 +-
.../ClusterMembershipConfigurationSchema.java | 4 +-
.../network/InboundConfigurationSchema.java | 4 +-
.../network/NetworkConfigurationSchema.java | 4 +-
.../network/NodeFinderConfigurationSchema.java | 4 +-
.../schemas/network/NodeFinderType.java | 4 +-
.../network/OutboundConfigurationSchema.java | 4 +-
.../network/ScaleCubeConfigurationSchema.java | 4 +-
.../schemas/network/package-info.java | 4 +-
.../schemas/rest/RestConfigurationSchema.java | 4 +-
.../configuration/schemas/rest/package-info.java | 4 +-
.../store/DataStorageConfigurationSchema.java | 4 +-
.../schemas/store/ExistingDataStorage.java | 4 +-
.../schemas/store/KnownDataStorage.java | 4 +-
.../UnknownDataStorageConfigurationSchema.java | 4 +-
.../schemas/table/ColumnConfigurationSchema.java | 4 +-
.../table/ColumnDefaultConfigurationSchema.java | 4 +-
.../table/ColumnTypeConfigurationSchema.java | 4 +-
.../schemas/table/ColumnTypeValidator.java | 4 +-
.../ConstantValueDefaultConfigurationSchema.java | 4 +-
.../table/EntryCountBudgetConfigurationSchema.java | 4 +-
.../FunctionCallDefaultConfigurationSchema.java | 4 +-
.../table/HashIndexConfigurationSchema.java | 2 +-
.../table/IndexColumnConfigurationSchema.java | 4 +-
.../table/LogStorageBudgetConfigurationSchema.java | 4 +-
.../table/NullValueDefaultConfigurationSchema.java | 4 +-
.../table/PrimaryKeyConfigurationSchema.java | 4 +-
.../table/SortedIndexConfigurationSchema.java | 2 +-
.../schemas/table/TableConfigurationSchema.java | 4 +-
.../table/TableIndexConfigurationSchema.java | 4 +-
.../schemas/table/TableValidator.java | 4 +-
.../schemas/table/TablesConfigurationSchema.java | 4 +-
.../table/UnlimitedBudgetConfigurationSchema.java | 4 +-
.../table/VolatileRaftConfigurationSchema.java | 4 +-
.../configuration/schemas/table/package-info.java | 4 +-
.../ignite/internal/lang/IgniteExceptionUtils.java | 4 +-
.../apache/ignite/internal/sql/ResultSetImpl.java | 4 +-
.../internal/sql/SqlColumnTypeConverter.java | 4 +-
.../ignite/lang/ColumnAlreadyExistsException.java | 4 +-
.../ignite/lang/ColumnNotFoundException.java | 4 +-
.../apache/ignite/lang/IgniteCheckedException.java | 4 +-
.../org/apache/ignite/lang/IgniteException.java | 4 +-
.../ignite/lang/IndexAlreadyExistsException.java | 4 +-
.../apache/ignite/lang/IndexNotFoundException.java | 4 +-
.../apache/ignite/lang/MarshallerException.java | 4 +-
.../java/org/apache/ignite/lang/NullableValue.java | 4 +-
.../ignite/lang/TableAlreadyExistsException.java | 4 +-
.../apache/ignite/lang/TableNotFoundException.java | 4 +-
.../ignite/lang/UnexpectedNullValueException.java | 4 +-
.../java/org/apache/ignite/lang/package-info.java | 4 +-
.../org/apache/ignite/network/ClusterNode.java | 4 +-
.../org/apache/ignite/network/NetworkAddress.java | 4 +-
.../ignite/network/TopologyEventHandler.java | 4 +-
.../org/apache/ignite/network/TopologyService.java | 4 +-
.../main/java/org/apache/ignite/package-info.java | 4 +-
.../ignite/schema/definition/ColumnDefinition.java | 4 +-
.../ignite/schema/definition/ColumnType.java | 4 +-
.../schema/definition/DefaultValueDefinition.java | 4 +-
.../schema/definition/DefaultValueGenerators.java | 4 +-
.../schema/definition/PrimaryKeyDefinition.java | 4 +-
.../ignite/schema/definition/SchemaObject.java | 4 +-
.../ignite/schema/definition/TableDefinition.java | 4 +-
.../definition/index/ColumnarIndexDefinition.java | 4 +-
.../definition/index/HashIndexDefinition.java | 4 +-
.../definition/index/IndexColumnDefinition.java | 4 +-
.../schema/definition/index/IndexDefinition.java | 4 +-
.../ignite/schema/definition/index/SortOrder.java | 4 +-
.../index/SortedIndexColumnDefinition.java | 4 +-
.../definition/index/SortedIndexDefinition.java | 4 +-
.../schema/definition/index/package-info.java | 4 +-
.../ignite/schema/definition/package-info.java | 4 +-
.../org/apache/ignite/sql/BatchedArguments.java | 4 +-
.../java/org/apache/ignite/sql/ColumnMetadata.java | 4 +-
.../apache/ignite/sql/CursorClosedException.java | 4 +-
.../main/java/org/apache/ignite/sql/IgniteSql.java | 4 +-
.../ignite/sql/NoRowSetExpectedException.java | 4 +-
.../main/java/org/apache/ignite/sql/ResultSet.java | 4 +-
.../org/apache/ignite/sql/ResultSetMetadata.java | 4 +-
.../main/java/org/apache/ignite/sql/Session.java | 4 +-
.../org/apache/ignite/sql/SqlBatchException.java | 4 +-
.../java/org/apache/ignite/sql/SqlColumnType.java | 4 +-
.../java/org/apache/ignite/sql/SqlException.java | 4 +-
.../main/java/org/apache/ignite/sql/SqlRow.java | 4 +-
.../main/java/org/apache/ignite/sql/Statement.java | 26 +-
.../apache/ignite/sql/async/AsyncResultSet.java | 4 +-
.../org/apache/ignite/sql/async/package-info.java | 4 +-
.../java/org/apache/ignite/sql/package-info.java | 4 +-
.../ignite/sql/reactive/ReactiveResultSet.java | 4 +-
.../apache/ignite/sql/reactive/package-info.java | 4 +-
.../org/apache/ignite/table/InvocationContext.java | 4 +-
.../org/apache/ignite/table/InvokeProcessor.java | 4 +-
.../ignite/table/InvokeProcessorException.java | 4 +-
.../java/org/apache/ignite/table/KeyValueView.java | 4 +-
.../java/org/apache/ignite/table/RecordView.java | 4 +-
.../main/java/org/apache/ignite/table/Table.java | 4 +-
.../main/java/org/apache/ignite/table/Tuple.java | 4 +-
.../java/org/apache/ignite/table/TupleImpl.java | 4 +-
.../apache/ignite/table/manager/IgniteTables.java | 4 +-
.../apache/ignite/table/manager/package-info.java | 4 +-
.../org/apache/ignite/table/mapper/Mapper.java | 4 +-
.../apache/ignite/table/mapper/MapperBuilder.java | 4 +-
.../ignite/table/mapper/OneColumnMapper.java | 4 +-
.../ignite/table/mapper/OneColumnMapperImpl.java | 4 +-
.../org/apache/ignite/table/mapper/PojoMapper.java | 4 +-
.../apache/ignite/table/mapper/PojoMapperImpl.java | 4 +-
.../apache/ignite/table/mapper/TypeConverter.java | 4 +-
.../apache/ignite/table/mapper/package-info.java | 4 +-
.../java/org/apache/ignite/table/package-info.java | 4 +-
.../org/apache/ignite/tx/IgniteTransactions.java | 4 +-
.../java/org/apache/ignite/tx/Transaction.java | 4 +-
.../org/apache/ignite/tx/TransactionException.java | 4 +-
.../java/org/apache/ignite/tx/package-info.java | 4 +-
.../ignite/lang/IgniteExceptionArchTest.java | 4 +-
.../apache/ignite/lang/IgniteExceptionTest.java | 4 +-
modules/baseline/build.gradle | 6 +-
.../ignite/internal/baseline/BaselineManager.java | 4 +-
modules/binary-tuple/build.gradle | 6 +-
modules/binary-tuple/pom.xml | 25 -
.../internal/binarytuple/BinaryTupleBuilder.java | 24 +-
.../internal/binarytuple/BinaryTupleCommon.java | 4 +-
.../binarytuple/BinaryTupleFormatException.java | 4 +-
.../internal/binarytuple/BinaryTupleParser.java | 4 +-
.../internal/binarytuple/BinaryTupleReader.java | 4 +-
.../internal/binarytuple/BinaryTupleTest.java | 24 +-
modules/bytecode/build.gradle | 12 +-
.../java/com/facebook/presto/bytecode/Access.java | 4 +-
.../bytecode/AddFakeLineNumberClassVisitor.java | 4 +-
.../presto/bytecode/AnnotationDefinition.java | 4 +-
.../com/facebook/presto/bytecode/ArrayOpCode.java | 4 +-
.../presto/bytecode/ByteCodeTooLargeException.java | 4 +-
.../facebook/presto/bytecode/BytecodeBlock.java | 4 +-
.../com/facebook/presto/bytecode/BytecodeNode.java | 4 +-
.../facebook/presto/bytecode/BytecodeUtils.java | 4 +-
.../facebook/presto/bytecode/BytecodeVisitor.java | 4 +-
.../facebook/presto/bytecode/ClassDefinition.java | 4 +-
.../facebook/presto/bytecode/ClassGenerator.java | 4 +-
.../java/com/facebook/presto/bytecode/Comment.java | 4 +-
.../presto/bytecode/CompilationException.java | 4 +-
.../presto/bytecode/DumpBytecodeVisitor.java | 4 +-
.../presto/bytecode/DynamicClassLoader.java | 4 +-
.../facebook/presto/bytecode/FieldDefinition.java | 4 +-
.../facebook/presto/bytecode/MethodDefinition.java | 4 +-
.../presto/bytecode/MethodGenerationContext.java | 4 +-
.../java/com/facebook/presto/bytecode/OpCode.java | 4 +-
.../com/facebook/presto/bytecode/Parameter.java | 4 +-
.../presto/bytecode/ParameterizedType.java | 4 +-
.../java/com/facebook/presto/bytecode/Scope.java | 4 +-
.../facebook/presto/bytecode/SmartClassWriter.java | 4 +-
.../com/facebook/presto/bytecode/Variable.java | 4 +-
.../presto/bytecode/control/CaseStatement.java | 4 +-
.../presto/bytecode/control/DoWhileLoop.java | 4 +-
.../presto/bytecode/control/FlowControl.java | 4 +-
.../facebook/presto/bytecode/control/ForLoop.java | 4 +-
.../presto/bytecode/control/IfStatement.java | 4 +-
.../presto/bytecode/control/SwitchStatement.java | 4 +-
.../facebook/presto/bytecode/control/TryCatch.java | 4 +-
.../presto/bytecode/control/WhileLoop.java | 4 +-
.../facebook/presto/bytecode/debug/DebugNode.java | 4 +-
.../presto/bytecode/debug/LineNumberNode.java | 4 +-
.../presto/bytecode/debug/LocalVariableNode.java | 4 +-
.../bytecode/expression/AndBytecodeExpression.java | 4 +-
.../expression/ArithmeticBytecodeExpression.java | 4 +-
.../expression/ArrayLengthBytecodeExpression.java | 4 +-
.../bytecode/expression/BytecodeExpression.java | 4 +-
.../bytecode/expression/BytecodeExpressions.java | 4 +-
.../expression/CastBytecodeExpression.java | 4 +-
.../expression/ComparisonBytecodeExpression.java | 4 +-
.../expression/ConstantBytecodeExpression.java | 4 +-
.../expression/GetElementBytecodeExpression.java | 4 +-
.../expression/GetFieldBytecodeExpression.java | 4 +-
.../expression/InlineIfBytecodeExpression.java | 4 +-
.../expression/InstanceOfBytecodeExpression.java | 4 +-
.../expression/InvokeBytecodeExpression.java | 4 +-
.../InvokeDynamicBytecodeExpression.java | 4 +-
.../expression/NegateBytecodeExpression.java | 4 +-
.../expression/NewArrayBytecodeExpression.java | 4 +-
.../expression/NewInstanceBytecodeExpression.java | 4 +-
.../bytecode/expression/NotBytecodeExpression.java | 4 +-
.../bytecode/expression/OrBytecodeExpression.java | 4 +-
.../bytecode/expression/PopBytecodeExpression.java | 4 +-
.../expression/ReturnBytecodeExpression.java | 4 +-
.../SetArrayElementBytecodeExpression.java | 4 +-
.../expression/SetFieldBytecodeExpression.java | 4 +-
.../presto/bytecode/instruction/Constant.java | 4 +-
.../bytecode/instruction/FieldInstruction.java | 4 +-
.../bytecode/instruction/InstructionNode.java | 4 +-
.../bytecode/instruction/InvokeInstruction.java | 4 +-
.../bytecode/instruction/JumpInstruction.java | 4 +-
.../presto/bytecode/instruction/LabelNode.java | 4 +-
.../bytecode/instruction/TypeInstruction.java | 4 +-
.../bytecode/instruction/VariableInstruction.java | 4 +-
.../presto/bytecode/TestBytecodeUtils.java | 4 +-
.../presto/bytecode/TestClassGenerator.java | 4 +-
.../expression/BytecodeExpressionAssertions.java | 4 +-
.../TestArithmeticBytecodeExpression.java | 4 +-
.../expression/TestArrayBytecodeExpressions.java | 4 +-
.../expression/TestCastBytecodeExpression.java | 4 +-
.../TestComparisonBytecodeExpression.java | 4 +-
.../expression/TestConstantBytecodeExpression.java | 4 +-
.../expression/TestGetFieldBytecodeExpression.java | 4 +-
.../expression/TestInlineIfBytecodeExpression.java | 4 +-
.../expression/TestInvokeBytecodeExpression.java | 4 +-
.../TestInvokeDynamicBytecodeExpression.java | 4 +-
.../expression/TestLogicalBytecodeExpression.java | 4 +-
.../TestNewInstanceBytecodeExpression.java | 4 +-
.../expression/TestPopBytecodeExpression.java | 4 +-
.../expression/TestSetFieldBytecodeExpression.java | 4 +-
.../TestSetVariableBytecodeExpression.java | 4 +-
modules/cli-common/build.gradle | 6 +-
.../apache/ignite/cli/common/IgniteCommand.java | 4 +-
.../org/apache/ignite/cli/common/package-info.java | 4 +-
modules/cli/build.gradle | 12 +-
.../org/apache/ignite/cli/IntegrationTestBase.java | 4 +-
.../call/CallInitializedIntegrationTestBase.java | 4 +-
.../configuration/ItShowConfigurationCallTest.java | 4 +-
.../ItUpdateConfigurationCallTest.java | 4 +-
.../CliCommandTestInitializedIntegrationBase.java | 4 +-
...liCommandTestNotInitializedIntegrationBase.java | 4 +-
.../ItClusterConfigCommandNotInitializedTest.java | 6 +-
.../ItClusterStatusCommandInitializedTest.java | 4 +-
.../ItClusterStatusCommandNotInitializedTest.java | 4 +-
.../ItTopologyCommandInitializedClusterTest.java | 4 +-
...ItTopologyCommandNotInitializedClusterTest.java | 8 +-
.../configuration/ItConfigCommandTest.java | 4 +-
.../cli/commands/connect/ItConnectCommandTest.java | 4 +-
.../commands/questions/ItConnectToClusterTest.java | 4 +-
.../ignite/cli/commands/sql/ItSqlCommandTest.java | 60 +-
.../cli/commands/version/ItVersionCommandTest.java | 4 +-
.../cli/deprecated/AbstractCliIntegrationTest.java | 4 +-
.../cli/deprecated/ItClusterCommandTest.java | 4 +-
.../ignite/cli/deprecated/ItConfigCommandTest.java | 4 +-
.../ignite/rest/ItGeneratedRestClientTest.java | 4 +-
.../java/org/apache/ignite/cli/CliVersionInfo.java | 4 +-
.../src/main/java/org/apache/ignite/cli/Main.java | 4 +-
.../org/apache/ignite/cli/VersionProvider.java | 4 +-
.../cli/call/cliconfig/CliConfigGetCall.java | 4 +-
.../cli/call/cliconfig/CliConfigGetCallInput.java | 4 +-
.../cli/call/cliconfig/CliConfigSetCall.java | 4 +-
.../cli/call/cliconfig/CliConfigSetCallInput.java | 4 +-
.../cli/call/cliconfig/CliConfigShowCall.java | 4 +-
.../profile/CliConfigProfileActivateCall.java | 4 +-
.../profile/CliConfigProfileCreateCall.java | 4 +-
.../profile/CliConfigProfileCreateCallInput.java | 4 +-
.../profile/CliConfigProfileListCall.java | 4 +-
.../profile/CliConfigProfileShowCall.java | 4 +-
.../cli/call/cliconfig/profile/ProfileList.java | 4 +-
.../ignite/cli/call/cluster/ClusterInitCall.java | 4 +-
.../cli/call/cluster/ClusterInitCallInput.java | 4 +-
.../cli/call/cluster/status/ClusterStatus.java | 4 +-
.../cli/call/cluster/status/ClusterStatusCall.java | 26 +-
.../call/cluster/topology/LogicalTopologyCall.java | 19 +-
.../cluster/topology/PhysicalTopologyCall.java | 19 +-
.../call/cluster/topology/TopologyCallInput.java | 67 -
.../call/cluster/topology/TopologyCallOutput.java | 4 +-
.../call/configuration/ClusterConfigShowCall.java | 4 +-
.../configuration/ClusterConfigShowCallInput.java | 4 +-
.../configuration/ClusterConfigUpdateCall.java | 4 +-
.../ClusterConfigUpdateCallInput.java | 4 +-
.../ignite/cli/call/configuration/JsonString.java | 4 +-
.../cli/call/configuration/NodeConfigShowCall.java | 4 +-
.../configuration/NodeConfigShowCallInput.java | 4 +-
.../call/configuration/NodeConfigUpdateCall.java | 4 +-
.../configuration/NodeConfigUpdateCallInput.java | 4 +-
.../ignite/cli/call/connect/ConnectCall.java | 4 +-
.../ignite/cli/call/connect/ConnectCallInput.java | 4 +-
.../ignite/cli/call/connect/DisconnectCall.java | 4 +-
.../ignite/cli/call/node/status/NodeStatus.java | 4 +-
.../cli/call/node/status/NodeStatusCall.java | 15 +-
.../apache/ignite/cli/call/node/status/State.java | 4 +-
.../apache/ignite/cli/call/sql/SqlQueryCall.java | 4 +-
.../apache/ignite/cli/commands/BaseCommand.java | 4 +-
.../ignite/cli/commands/OptionsConstants.java | 4 +-
.../apache/ignite/cli/commands/ProfileMixin.java | 4 +-
.../ignite/cli/commands/TopLevelCliCommand.java | 4 +-
.../cli/commands/TopLevelCliReplCommand.java | 4 +-
.../ignite/cli/commands/cliconfig/CliCommand.java | 4 +-
.../cli/commands/cliconfig/CliConfigCommand.java | 4 +-
.../commands/cliconfig/CliConfigGetCommand.java | 4 +-
.../cliconfig/CliConfigGetReplCommand.java | 4 +-
.../commands/cliconfig/CliConfigReplCommand.java | 4 +-
.../commands/cliconfig/CliConfigSetCommand.java | 4 +-
.../cliconfig/CliConfigSetReplCommand.java | 4 +-
.../commands/cliconfig/CliConfigShowCommand.java | 4 +-
.../cliconfig/CliConfigShowReplCommand.java | 4 +-
.../cli/commands/cliconfig/CliReplCommand.java | 4 +-
.../profile/CliConfigProfileActivateCommand.java | 4 +-
.../cliconfig/profile/CliConfigProfileCommand.java | 4 +-
.../profile/CliConfigProfileCreateCommand.java | 4 +-
.../profile/CliConfigProfileListCommand.java | 4 +-
.../profile/CliConfigProfileShowCommand.java | 4 +-
.../cli/commands/cluster/ClusterCommand.java | 4 +-
.../cli/commands/cluster/ClusterReplCommand.java | 4 +-
.../cli/commands/cluster/ClusterUrlMixin.java | 4 +-
.../commands/cluster/ClusterUrlProfileMixin.java | 4 +-
.../cluster/config/ClusterConfigCommand.java | 4 +-
.../cluster/config/ClusterConfigReplCommand.java | 4 +-
.../cluster/config/ClusterConfigShowCommand.java | 10 +-
.../config/ClusterConfigShowReplCommand.java | 14 +-
.../cluster/config/ClusterConfigUpdateCommand.java | 8 +-
.../config/ClusterConfigUpdateReplCommand.java | 12 +-
.../commands/cluster/init/ClusterInitCommand.java | 4 +-
.../commands/cluster/init/ClusterInitOptions.java | 4 +-
.../cluster/init/ClusterInitReplCommand.java | 41 +-
.../cluster/status/ClusterStatusCommand.java | 12 +-
.../cluster/status/ClusterStatusReplCommand.java | 40 +-
.../cli/commands/connect/ConnectCommand.java | 4 +-
.../cli/commands/connect/DisconnectCommand.java | 4 +-
.../ignite/cli/commands/node/NodeCommand.java | 4 +-
.../ignite/cli/commands/node/NodeReplCommand.java | 4 +-
.../ignite/cli/commands/node/NodeUrlMixin.java | 4 +-
.../cli/commands/node/NodeUrlProfileMixin.java | 4 +-
.../commands/node/config/NodeConfigCommand.java | 4 +-
.../node/config/NodeConfigReplCommand.java | 4 +-
.../node/config/NodeConfigShowCommand.java | 4 +-
.../node/config/NodeConfigShowReplCommand.java | 10 +-
.../node/config/NodeConfigUpdateCommand.java | 4 +-
.../node/config/NodeConfigUpdateReplCommand.java | 10 +-
.../commands/node/status/NodeStatusCommand.java | 12 +-
.../node/status/NodeStatusReplCommand.java | 45 +-
.../questions/ConnectToClusterQuestion.java | 11 +-
.../apache/ignite/cli/commands/sql/SqlCommand.java | 4 +-
.../ignite/cli/commands/sql/SqlCompleter.java | 4 +-
.../ignite/cli/commands/sql/SqlMetaData.java | 4 +-
.../ignite/cli/commands/sql/SqlReplCommand.java | 4 +-
.../commands/sql/SqlReplTopLevelCliCommand.java | 4 +-
.../commands/topology/LogicalTopologyCommand.java | 12 +-
.../topology/LogicalTopologyReplCommand.java | 45 +-
.../commands/topology/PhysicalTopologyCommand.java | 8 +-
.../topology/PhysicalTopologyReplCommand.java | 43 +-
.../cli/commands/topology/TopologyCommand.java | 4 +-
.../cli/commands/topology/TopologyReplCommand.java | 4 +-
.../cli/commands/version/VersionCommand.java | 4 +-
.../cli/config/CachedConfigManagerProvider.java | 4 +-
.../cli/config/CachedStateConfigProvider.java | 4 +-
.../java/org/apache/ignite/cli/config/Config.java | 4 +-
.../apache/ignite/cli/config/ConfigConstants.java | 4 +-
.../cli/config/ConfigDefaultValueProvider.java | 4 +-
.../cli/config/ConfigInitializationException.java | 4 +-
.../apache/ignite/cli/config/ConfigManager.java | 4 +-
.../ignite/cli/config/ConfigManagerProvider.java | 4 +-
.../ignite/cli/config/ConfigStoringException.java | 4 +-
.../java/org/apache/ignite/cli/config/Profile.java | 4 +-
.../cli/config/ProfileNotFoundException.java | 4 +-
.../org/apache/ignite/cli/config/StateConfig.java | 4 +-
.../ignite/cli/config/StateConfigProvider.java | 4 +-
.../ignite/cli/config/StateFolderProvider.java | 4 +-
.../apache/ignite/cli/config/ini/IniConfig.java | 4 +-
.../ignite/cli/config/ini/IniConfigManager.java | 4 +-
.../org/apache/ignite/cli/config/ini/IniFile.java | 4 +-
.../apache/ignite/cli/config/ini/IniParser.java | 4 +-
.../apache/ignite/cli/config/ini/IniProfile.java | 4 +-
.../apache/ignite/cli/config/ini/IniSection.java | 4 +-
.../config/ini/SectionAlreadyExistsException.java | 4 +-
.../cli/core/CallExecutionPipelineProvider.java | 4 +-
.../java/org/apache/ignite/cli/core/call/Call.java | 4 +-
.../cli/core/call/CallExecutionPipeline.java | 4 +-
.../org/apache/ignite/cli/core/call/CallInput.java | 4 +-
.../apache/ignite/cli/core/call/CallOutput.java | 4 +-
.../ignite/cli/core/call/CallOutputStatus.java | 4 +-
.../ignite/cli/core/call/DefaultCallOutput.java | 6 +-
.../ignite/cli/core/call/EmptyCallInput.java | 4 +-
.../ignite/cli/core/call/StatusCallInput.java | 34 -
.../ignite/cli/core/call/StringCallInput.java | 4 +-
.../apache/ignite/cli/core/call/UrlCallInput.java | 41 +
.../core/converters/NetworkAddressConverter.java | 4 +-
.../ignite/cli/core/converters/UrlConverter.java | 4 +-
.../ignite/cli/core/decorator/Decorator.java | 4 +-
.../cli/core/decorator/DecoratorRegistry.java | 4 +-
.../ignite/cli/core/decorator/TerminalOutput.java | 4 +-
.../core/exception/CommandExecutionException.java | 4 +-
.../core/exception/ConnectCommandException.java | 4 +-
.../cli/core/exception/ExceptionHandler.java | 4 +-
.../cli/core/exception/ExceptionHandlers.java | 4 +-
.../ignite/cli/core/exception/ExceptionWriter.java | 10 +-
.../cli/core/exception/IgniteCliApiException.java | 4 +-
.../cli/core/exception/WrappedException.java | 4 +-
.../ClusterNotInitializedExceptionHandler.java | 63 +
.../handler/ConfigStoringExceptionHandler.java | 4 +-
.../handler/DefaultExceptionHandlers.java | 4 +-
.../handler/EndOfFileExceptionHandler.java | 4 +-
.../handler/FlowInterruptExceptionHandler.java | 4 +-
.../handler/IgniteCliApiExceptionHandler.java | 17 +-
.../handler/IgniteCliExceptionHandler.java | 4 +-
.../handler/PicocliExecutionExceptionHandler.java | 4 +-
.../handler/ProfileNotFoundExceptionHandler.java | 4 +-
.../exception/handler/ReplExceptionHandlers.java | 4 +-
.../SectionAlreadyExistsExceptionHandler.java | 4 +-
.../handler/ShowConfigExceptionHandler.java | 49 -
.../exception/handler/SqlExceptionHandler.java | 81 +-
.../exception/handler/TimeoutExceptionHandler.java | 4 +-
.../handler/UnknownCommandExceptionHandler.java | 4 +-
.../handler/UserInterruptExceptionHandler.java | 4 +-
.../ignite/cli/core/flow/DefaultFlowable.java | 4 +-
.../java/org/apache/ignite/cli/core/flow/Flow.java | 4 +-
.../cli/core/flow/FlowInterruptException.java | 4 +-
.../org/apache/ignite/cli/core/flow/Flowable.java | 6 +-
.../ignite/cli/core/flow/builder/FlowBuilder.java | 82 +-
.../cli/core/flow/builder/FlowBuilderImpl.java | 106 +-
.../apache/ignite/cli/core/flow/builder/Flows.java | 8 +-
.../core/flow/question/AcceptedQuestionAnswer.java | 4 +-
.../flow/question/InterruptQuestionAnswer.java | 4 +-
.../flow/question/JlineQuestionWriterReader.java | 4 +-
.../cli/core/flow/question/QuestionAnswer.java | 4 +-
.../cli/core/flow/question/QuestionAsker.java | 4 +-
.../core/flow/question/QuestionAskerFactory.java | 4 +-
.../core/flow/question/QuestionWriterReader.java | 4 +-
.../java/org/apache/ignite/cli/core/repl/Repl.java | 4 +-
.../apache/ignite/cli/core/repl/ReplBuilder.java | 4 +-
.../org/apache/ignite/cli/core/repl/Session.java | 4 +-
.../cli/core/repl/SessionDefaultValueProvider.java | 4 +-
.../cli/core/repl/completer/CompleterFilter.java | 4 +-
.../cli/core/repl/completer/DynamicCompleter.java | 4 +-
.../completer/DynamicCompleterActivationPoint.java | 4 +-
.../repl/completer/DynamicCompleterFactory.java | 4 +-
.../repl/completer/DynamicCompleterFilter.java | 4 +-
.../repl/completer/DynamicCompleterRegistry.java | 4 +-
.../core/repl/completer/HoconDynamicCompleter.java | 4 +-
.../core/repl/completer/LazyDynamicCompleter.java | 4 +-
.../cli/core/repl/completer/NodeUrlProvider.java | 4 +-
.../core/repl/config/ClientConnectorConfig.java | 4 +-
.../ignite/cli/core/repl/config/RootConfig.java | 4 +-
.../cli/core/repl/context/CommandLineContext.java | 4 +-
.../repl/context/CommandLineContextProvider.java | 37 +-
.../core/repl/executor/IgnitePicocliCommands.java | 4 +-
.../repl/executor/RegistryCommandExecutor.java | 4 +-
.../cli/core/repl/executor/ReplExecutor.java | 4 +-
.../core/repl/executor/ReplExecutorProvider.java | 4 +-
.../cli/core/repl/expander/NoopExpander.java | 4 +-
.../cli/core/repl/prompt/PromptProvider.java | 4 +-
.../cli/core/repl/prompt/ReplPromptProvider.java | 4 +-
.../cli/core/repl/terminal/TerminalCustomizer.java | 4 +-
.../cli/core/repl/terminal/TerminalFactory.java | 4 +-
.../ignite/cli/core/style/AnsiStringSupport.java | 20 +-
.../cli/core/style/component/CommonMessages.java | 37 -
.../cli/core/style/component/ErrorUiComponent.java | 4 +-
.../core/style/component/MessageUiComponent.java | 4 +-
.../core/style/component/QuestionUiComponent.java | 4 +-
.../cli/core/style/component/UiComponent.java | 4 +-
.../cli/core/style/element/MarkedUiElement.java | 8 +-
.../ignite/cli/core/style/element/UiElement.java | 8 +-
.../ignite/cli/core/style/element/UiElements.java | 8 +-
.../ignite/cli/core/style/element/UiString.java | 8 +-
.../cli/decorators/ClusterStatusDecorator.java | 4 +-
.../ignite/cli/decorators/DefaultDecorator.java | 4 +-
.../cli/decorators/DefaultDecoratorRegistry.java | 5 +-
.../ignite/cli/decorators/JsonDecorator.java | 4 +-
.../ignite/cli/decorators/NodeStatusDecorator.java | 4 +-
.../ignite/cli/decorators/ProfileDecorator.java | 4 +-
.../cli/decorators/ProfileListDecorator.java | 4 +-
.../cli/decorators/SqlQueryResultDecorator.java | 4 +-
.../ignite/cli/decorators/TableDecorator.java | 4 +-
.../ignite/cli/decorators/TopologyDecorator.java | 4 +-
.../cli/deprecated/CliPathsConfigLoader.java | 4 +-
.../ignite/cli/deprecated/CommandFactory.java | 4 +-
.../ignite/cli/deprecated/IgniteCliException.java | 4 +-
.../apache/ignite/cli/deprecated/IgnitePaths.java | 4 +-
.../org/apache/ignite/cli/deprecated/Table.java | 4 +-
.../deprecated/builtins/SystemPathResolver.java | 4 +-
.../builtins/init/InitIgniteCommand.java | 4 +-
.../cli/deprecated/builtins/init/package-info.java | 4 +-
.../builtins/module/MavenArtifactResolver.java | 4 +-
.../builtins/module/MavenCoordinates.java | 4 +-
.../deprecated/builtins/module/ModuleManager.java | 4 +-
.../deprecated/builtins/module/ModuleRegistry.java | 4 +-
.../deprecated/builtins/module/ResolveResult.java | 4 +-
.../builtins/module/StandardModuleDefinition.java | 4 +-
.../deprecated/builtins/module/package-info.java | 4 +-
.../cli/deprecated/builtins/node/NodeManager.java | 4 +-
.../cli/deprecated/builtins/node/package-info.java | 4 +-
.../cli/deprecated/builtins/package-info.java | 4 +-
.../apache/ignite/cli/deprecated/package-info.java | 4 +-
.../spec/BootstrapIgniteCommandSpec.java | 4 +-
.../cli/deprecated/spec/NodeCommandSpec.java | 4 +-
.../cli/deprecated/spec/NodeEndpointOptions.java | 4 +-
.../ignite/cli/deprecated/spec/package-info.java | 4 +-
.../ignite/cli/deprecated/ui/ProgressBar.java | 4 +-
.../apache/ignite/cli/deprecated/ui/Spinner.java | 4 +-
.../apache/ignite/cli/sql/MetadataSupplier.java | 4 +-
.../org/apache/ignite/cli/sql/SchemaProvider.java | 4 +-
.../java/org/apache/ignite/cli/sql/SqlManager.java | 4 +-
.../org/apache/ignite/cli/sql/SqlQueryResult.java | 4 +-
.../java/org/apache/ignite/cli/sql/SqlSchema.java | 4 +-
.../org/apache/ignite/cli/sql/SqlSchemaLoader.java | 4 +-
.../apache/ignite/cli/sql/SqlSchemaProvider.java | 4 +-
.../org/apache/ignite/cli/sql/table/Table.java | 4 +-
.../org/apache/ignite/cli/sql/table/TableRow.java | 4 +-
.../cli/call/node/status/NodeStatusCallTest.java | 8 +-
.../ignite/cli/commands/CliCommandTestBase.java | 4 +-
.../apache/ignite/cli/commands/PicocliBugTest.java | 4 +-
.../ignite/cli/commands/ProfileMixinTest.java | 19 +-
.../cli/commands/UrlOptionsNegativeTest.java | 4 +-
.../cliconfig/CliConfigCommandTestBase.java | 4 +-
.../cliconfig/CliConfigGetCommandTest.java | 4 +-
.../CliConfigProfileActivateCommandTest.java | 4 +-
.../CliConfigProfileCreateCommandTest.java | 4 +-
.../cliconfig/CliConfigProfileListCommandTest.java | 4 +-
.../cliconfig/CliConfigProfileShowCommandTest.java | 4 +-
.../cliconfig/CliConfigSetCommandTest.java | 4 +-
.../cliconfig/CliConfigShowCommandTest.java | 4 +-
.../cli/commands/cliconfig/ConfigManagerTest.java | 4 +-
.../cliconfig/TestConfigManagerHelper.java | 4 +-
.../cliconfig/TestConfigManagerProvider.java | 4 +-
.../apache/ignite/cli/commands/flow/FlowTest.java | 188 +-
.../apache/ignite/cli/commands/flow/IntCall.java | 4 +-
.../ignite/cli/commands/flow/IntCallInput.java | 4 +-
.../apache/ignite/cli/commands/flow/StrCall.java | 4 +-
.../ignite/cli/commands/flow/StrCallInput.java | 4 +-
.../cli/commands/flow/TestExceptionHandler.java | 13 +-
.../ignite/cli/commands/flow/ThrowingStrCall.java | 4 +-
.../cli/commands/sql/SchemaProviderMock.java | 4 +-
.../ignite/cli/commands/sql/SqlCommandTest.java | 4 +-
.../ignite/cli/commands/sql/SqlCompleterTest.java | 4 +-
.../ignite/cli/config/TestStateConfigHelper.java | 4 +-
.../ignite/cli/config/TestStateConfigProvider.java | 4 +-
.../repl/completer/DynamicCompleterFilterTest.java | 4 +-
.../completer/DynamicCompleterRegistryTest.java | 4 +-
.../repl/completer/HoconDynamicCompleterTest.java | 4 +-
.../core/style/component/ErrorUiComponentTest.java | 4 +-
.../style/component/MessageUiComponentTest.java | 4 +-
.../ignite/cli/deprecated/AbstractCliTest.java | 4 +-
.../cli/deprecated/IgniteCliInterfaceTest.java | 4 +-
.../builtins/init/InitIgniteCommandTest.java | 4 +-
.../cli/deprecated/builtins/init/package-info.java | 4 +-
.../apache/ignite/cli/deprecated/package-info.java | 4 +-
.../ignite/cli/deprecated/ui/ProgressBarTest.java | 4 +-
.../ignite/cli/deprecated/ui/SpinnerTest.java | 4 +-
.../ignite/cli/deprecated/ui/package-info.java | 4 +-
.../ignite/cli/sql/SqlSchemaProviderTest.java | 4 +-
.../org/apache/ignite/cli/sql/table/TableTest.java | 4 +-
modules/client-common/build.gradle | 7 +-
modules/client-common/pom.xml | 4 +
.../client/proto/ClientBinaryTupleUtils.java | 120 +
.../internal/client/proto/ClientDataType.java | 4 +-
.../internal/client/proto/ClientMessageCommon.java | 4 +-
.../client/proto/ClientMessageDecoder.java | 4 +-
.../internal/client/proto/ClientMessagePacker.java | 36 +-
.../client/proto/ClientMessageUnpacker.java | 27 +-
.../internal/client/proto/ClientMsgPackType.java | 4 +-
.../ignite/internal/client/proto/ClientOp.java | 4 +-
.../client/proto/ClientSqlColumnTypeConverter.java | 4 +-
.../internal/client/proto/ProtocolVersion.java | 4 +-
.../internal/client/proto/ServerMessageType.java | 4 +-
.../ignite/internal/client/proto/TuplePart.java | 4 +-
.../ignite/internal/client/proto/package-info.java | 4 +-
.../ignite/internal/jdbc/proto/ClientMessage.java | 4 +-
.../internal/jdbc/proto/IgniteQueryErrorCode.java | 4 +-
.../jdbc/proto/JdbcQueryCursorHandler.java | 4 +-
.../internal/jdbc/proto/JdbcQueryEventHandler.java | 4 +-
.../internal/jdbc/proto/JdbcStatementType.java | 4 +-
.../ignite/internal/jdbc/proto/SqlStateCode.java | 4 +-
.../jdbc/proto/event/ClientMessageUtils.java | 4 +-
.../jdbc/proto/event/JdbcBatchExecuteRequest.java | 4 +-
.../jdbc/proto/event/JdbcBatchExecuteResult.java | 4 +-
.../proto/event/JdbcBatchPreparedStmntRequest.java | 4 +-
.../internal/jdbc/proto/event/JdbcColumnMeta.java | 4 +-
.../jdbc/proto/event/JdbcMetaColumnsRequest.java | 4 +-
.../jdbc/proto/event/JdbcMetaColumnsResult.java | 4 +-
.../proto/event/JdbcMetaPrimaryKeysRequest.java | 4 +-
.../proto/event/JdbcMetaPrimaryKeysResult.java | 4 +-
.../jdbc/proto/event/JdbcMetaSchemasRequest.java | 4 +-
.../jdbc/proto/event/JdbcMetaSchemasResult.java | 4 +-
.../jdbc/proto/event/JdbcMetaTablesRequest.java | 4 +-
.../jdbc/proto/event/JdbcMetaTablesResult.java | 4 +-
.../jdbc/proto/event/JdbcPrimaryKeyMeta.java | 4 +-
.../jdbc/proto/event/JdbcQueryCloseRequest.java | 4 +-
.../jdbc/proto/event/JdbcQueryCloseResult.java | 4 +-
.../jdbc/proto/event/JdbcQueryExecuteRequest.java | 4 +-
.../jdbc/proto/event/JdbcQueryExecuteResult.java | 4 +-
.../jdbc/proto/event/JdbcQueryFetchRequest.java | 4 +-
.../jdbc/proto/event/JdbcQueryFetchResult.java | 4 +-
.../jdbc/proto/event/JdbcQueryMetadataRequest.java | 4 +-
.../jdbc/proto/event/JdbcQuerySingleResult.java | 4 +-
.../internal/jdbc/proto/event/JdbcTableMeta.java | 4 +-
.../ignite/internal/jdbc/proto/event/Response.java | 4 +-
.../internal/jdbc/proto/event/package-info.java | 4 +-
.../ignite/internal/jdbc/proto/package-info.java | 4 +-
.../client/proto/ClientMessageDecoderTest.java | 4 +-
.../client/proto/ClientMessagePackerBenchmark.java | 4 +-
.../client/proto/ClientMessagePackerTest.java | 4 +-
.../proto/ClientMessagePackerUnpackerTest.java | 6 +-
.../client/proto/ClientMessageUnpackerTest.java | 4 +-
.../proto/ClientSqlColumnTypeConverterTest.java | 4 +-
modules/client-handler/build.gradle | 6 +-
.../ignite/client/handler/ItClientHandlerTest.java | 4 +-
.../ignite/client/handler/ClientContext.java | 4 +-
.../ignite/client/handler/ClientHandlerModule.java | 4 +-
.../handler/ClientInboundMessageHandler.java | 4 +-
.../ignite/client/handler/ClientResource.java | 4 +-
.../client/handler/ClientResourceRegistry.java | 4 +-
.../client/handler/JdbcQueryCursorHandlerImpl.java | 4 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 8 +-
.../apache/ignite/client/handler/package-info.java | 4 +-
.../cluster/ClientClusterGetNodesRequest.java | 4 +-
.../ClientComputeExecuteColocatedRequest.java | 4 +-
.../compute/ClientComputeExecuteRequest.java | 4 +-
.../requests/jdbc/ClientJdbcCloseRequest.java | 4 +-
.../jdbc/ClientJdbcColumnMetadataRequest.java | 4 +-
.../jdbc/ClientJdbcExecuteBatchRequest.java | 4 +-
.../requests/jdbc/ClientJdbcExecuteRequest.java | 4 +-
.../requests/jdbc/ClientJdbcFetchRequest.java | 4 +-
.../jdbc/ClientJdbcPreparedStmntBatchRequest.java | 4 +-
.../jdbc/ClientJdbcPrimaryKeyMetadataRequest.java | 4 +-
.../jdbc/ClientJdbcQueryMetadataRequest.java | 4 +-
.../jdbc/ClientJdbcSchemasMetadataRequest.java | 4 +-
.../jdbc/ClientJdbcTableMetadataRequest.java | 4 +-
.../handler/requests/jdbc/JdbcMetadataCatalog.java | 4 +-
.../handler/requests/jdbc/JdbcQueryCursor.java | 4 +-
.../client/handler/requests/jdbc/package-info.java | 4 +-
.../handler/requests/sql/ClientSqlCommon.java | 4 +-
.../requests/sql/ClientSqlCursorCloseRequest.java | 4 +-
.../sql/ClientSqlCursorNextPageRequest.java | 4 +-
.../requests/sql/ClientSqlExecuteRequest.java | 5 +-
.../handler/requests/sql/ClientSqlResultSet.java | 4 +-
.../requests/table/ClientSchemasGetRequest.java | 4 +-
.../handler/requests/table/ClientTableCommon.java | 159 +-
.../requests/table/ClientTableGetRequest.java | 4 +-
.../requests/table/ClientTablesGetRequest.java | 4 +-
.../table/ClientTupleContainsKeyRequest.java | 4 +-
.../table/ClientTupleDeleteAllExactRequest.java | 4 +-
.../table/ClientTupleDeleteAllRequest.java | 4 +-
.../table/ClientTupleDeleteExactRequest.java | 4 +-
.../requests/table/ClientTupleDeleteRequest.java | 4 +-
.../requests/table/ClientTupleGetAllRequest.java | 4 +-
.../table/ClientTupleGetAndDeleteRequest.java | 4 +-
.../table/ClientTupleGetAndReplaceRequest.java | 4 +-
.../table/ClientTupleGetAndUpsertRequest.java | 4 +-
.../requests/table/ClientTupleGetRequest.java | 4 +-
.../table/ClientTupleInsertAllRequest.java | 4 +-
.../requests/table/ClientTupleInsertRequest.java | 4 +-
.../table/ClientTupleReplaceExactRequest.java | 4 +-
.../requests/table/ClientTupleReplaceRequest.java | 4 +-
.../table/ClientTupleUpsertAllRequest.java | 4 +-
.../requests/table/ClientTupleUpsertRequest.java | 4 +-
.../handler/requests/table/package-info.java | 4 +-
.../requests/tx/ClientTransactionBeginRequest.java | 4 +-
.../tx/ClientTransactionCommitRequest.java | 4 +-
.../tx/ClientTransactionRollbackRequest.java | 4 +-
.../src/test/java/ClientResourceRegistryTest.java | 4 +-
modules/client/build.gradle | 7 +-
modules/client/pom.xml | 5 +
.../apache/ignite/client/ClientOperationType.java | 4 +-
.../org/apache/ignite/client/IgniteClient.java | 4 +-
.../ignite/client/IgniteClientAddressFinder.java | 4 +-
.../IgniteClientAuthenticationException.java | 4 +-
.../ignite/client/IgniteClientConfiguration.java | 4 +-
.../client/IgniteClientConnectionException.java | 4 +-
...ClientFeatureNotSupportedByServerException.java | 4 +-
.../org/apache/ignite/client/RetryLimitPolicy.java | 4 +-
.../java/org/apache/ignite/client/RetryPolicy.java | 4 +-
.../apache/ignite/client/RetryPolicyContext.java | 4 +-
.../org/apache/ignite/client/RetryReadPolicy.java | 4 +-
.../org/apache/ignite/client/package-info.java | 4 +-
.../ignite/internal/client/ClientChannel.java | 4 +-
.../client/ClientChannelConfiguration.java | 4 +-
.../apache/ignite/internal/client/ClientUtils.java | 4 +-
.../ignite/internal/client/HostAndPortRange.java | 4 +-
.../client/IgniteClientConfigurationImpl.java | 4 +-
.../internal/client/PayloadInputChannel.java | 4 +-
.../internal/client/PayloadOutputChannel.java | 4 +-
.../ignite/internal/client/PayloadReader.java | 4 +-
.../ignite/internal/client/PayloadWriter.java | 4 +-
.../internal/client/ProtocolBitmaskFeature.java | 4 +-
.../ignite/internal/client/ProtocolContext.java | 4 +-
.../ignite/internal/client/ReliableChannel.java | 4 +-
.../internal/client/RetryPolicyContextImpl.java | 4 +-
.../ignite/internal/client/TcpClientChannel.java | 4 +-
.../ignite/internal/client/TcpIgniteClient.java | 4 +-
.../internal/client/compute/ClientCompute.java | 4 +-
.../internal/client/io/ClientConnection.java | 4 +-
.../client/io/ClientConnectionMultiplexer.java | 4 +-
.../client/io/ClientConnectionStateHandler.java | 4 +-
.../internal/client/io/ClientMessageHandler.java | 4 +-
.../client/io/netty/NettyClientConnection.java | 4 +-
.../io/netty/NettyClientConnectionMultiplexer.java | 4 +-
.../client/io/netty/NettyClientMessageHandler.java | 4 +-
.../internal/client/sql/ClientAsyncResultSet.java | 4 +-
.../internal/client/sql/ClientColumnMetadata.java | 4 +-
.../internal/client/sql/ClientColumnOrigin.java | 4 +-
.../client/sql/ClientResultSetMetadata.java | 4 +-
.../ignite/internal/client/sql/ClientSession.java | 7 +-
.../internal/client/sql/ClientSessionBuilder.java | 4 +-
.../ignite/internal/client/sql/ClientSql.java | 6 +-
.../ignite/internal/client/sql/ClientSqlRow.java | 4 +-
.../internal/client/sql/ClientStatement.java | 19 +-
.../client/sql/ClientStatementBuilder.java | 22 +-
.../ignite/internal/client/table/ClientColumn.java | 31 +-
.../client/table/ClientKeyValueBinaryView.java | 4 +-
.../internal/client/table/ClientKeyValueView.java | 53 +-
.../client/table/ClientRecordBinaryView.java | 4 +-
.../client/table/ClientRecordSerializer.java | 73 +-
.../internal/client/table/ClientRecordView.java | 4 +-
.../ignite/internal/client/table/ClientSchema.java | 13 +-
.../ignite/internal/client/table/ClientTable.java | 11 +-
.../ignite/internal/client/table/ClientTables.java | 4 +-
.../ignite/internal/client/table/ClientTuple.java | 4 +-
.../client/table/ClientTupleSerializer.java | 152 +-
.../internal/client/tx/ClientTransaction.java | 4 +-
.../internal/client/tx/ClientTransactions.java | 4 +-
.../ignite/internal/jdbc/ConnectionProperties.java | 4 +-
.../internal/jdbc/ConnectionPropertiesImpl.java | 4 +-
.../jdbc/JdbcClientQueryCursorHandler.java | 4 +-
.../internal/jdbc/JdbcClientQueryEventHandler.java | 4 +-
.../ignite/internal/jdbc/JdbcConnection.java | 4 +-
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 4 +-
.../internal/jdbc/JdbcPreparedStatement.java | 4 +-
.../internal/jdbc/JdbcQueryExecuteResponse.java | 4 +-
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 4 +-
.../internal/jdbc/JdbcResultSetMetadata.java | 4 +-
.../apache/ignite/internal/jdbc/JdbcStatement.java | 17 +-
.../apache/ignite/internal/jdbc/package-info.java | 4 +-
.../marshaller/ClientMarshallerReader.java | 76 +-
.../marshaller/ClientMarshallerWriter.java | 53 +-
.../org/apache/ignite/jdbc/IgniteJdbcDriver.java | 4 +-
.../java/org/apache/ignite/jdbc/package-info.java | 4 +-
.../ignite/client/AbstractClientTableTest.java | 6 +-
.../apache/ignite/client/AbstractClientTest.java | 4 +-
.../org/apache/ignite/client/ClientArchTest.java | 4 +-
.../apache/ignite/client/ClientComputeTest.java | 4 +-
.../client/ClientKeyValueBinaryViewTest.java | 4 +-
.../ignite/client/ClientKeyValueViewTest.java | 16 +-
.../apache/ignite/client/ClientLoggingTest.java | 4 +-
.../apache/ignite/client/ClientRecordViewTest.java | 16 +-
.../org/apache/ignite/client/ClientSqlTest.java | 4 +-
.../org/apache/ignite/client/ClientTableTest.java | 7 +-
.../org/apache/ignite/client/ClientTablesTest.java | 4 +-
.../org/apache/ignite/client/ClientTupleTest.java | 4 +-
.../apache/ignite/client/ConfigurationTest.java | 4 +-
.../org/apache/ignite/client/ConnectionTest.java | 4 +-
.../java/org/apache/ignite/client/CustomTuple.java | 4 +-
.../org/apache/ignite/client/HeartbeatTest.java | 4 +-
.../org/apache/ignite/client/ReconnectTest.java | 4 +-
.../org/apache/ignite/client/RetryPolicyTest.java | 16 +-
.../ignite/client/TestClientHandlerModule.java | 4 +-
.../org/apache/ignite/client/TestRetryPolicy.java | 4 +-
.../java/org/apache/ignite/client/TestServer.java | 4 +-
.../ignite/client/fakes/FakeAsyncResultSet.java | 4 +-
.../ignite/client/fakes/FakeColumnMetadata.java | 4 +-
.../org/apache/ignite/client/fakes/FakeCursor.java | 4 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 4 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 4 +-
.../apache/ignite/client/fakes/FakeIgniteSql.java | 4 +-
.../ignite/client/fakes/FakeIgniteTables.java | 8 +-
.../ignite/client/fakes/FakeInternalTable.java | 4 +-
.../ignite/client/fakes/FakeSchemaRegistry.java | 4 +-
.../apache/ignite/client/fakes/FakeSession.java | 4 +-
.../ignite/client/fakes/FakeSessionBuilder.java | 4 +-
.../internal/client/HostAndPortRangeTest.java | 4 +-
modules/cluster-management/build.gradle | 7 +-
.../cluster/management/ItClusterManagerTest.java | 2 +-
.../internal/cluster/management/MockNode.java | 2 +-
.../management/raft/ItCmgRaftServiceTest.java | 2 +-
.../rest/ItClusterManagementControllerTest.java | 4 +-
.../cluster/management/rest/RestTestBase.java | 4 +-
.../cluster/management/ClusterInitializer.java | 2 +-
.../management/ClusterManagementGroupManager.java | 2 +-
.../internal/cluster/management/ClusterState.java | 2 +-
.../internal/cluster/management/ClusterTag.java | 2 +-
.../internal/cluster/management/InitException.java | 2 +-
.../cluster/management/InternalInitException.java | 2 +-
.../cluster/management/LocalStateStorage.java | 2 +-
.../network/CmgMessageHandlerFactory.java | 2 +-
.../network/messages/CancelInitMessage.java | 2 +-
.../network/messages/ClusterStateMessage.java | 2 +-
.../network/messages/CmgInitMessage.java | 2 +-
.../network/messages/CmgMessageGroup.java | 2 +-
.../network/messages/InitCompleteMessage.java | 2 +-
.../network/messages/InitErrorMessage.java | 2 +-
.../network/messages/SuccessResponseMessage.java | 2 +-
.../management/raft/ClusterStateStorage.java | 2 +-
.../management/raft/CmgRaftGroupListener.java | 2 +-
.../cluster/management/raft/CmgRaftService.java | 2 +-
.../raft/IllegalInitArgumentException.java | 2 +-
.../management/raft/JoinDeniedException.java | 2 +-
.../management/raft/RaftStorageManager.java | 2 +-
.../raft/RocksDbClusterStateStorage.java | 2 +-
.../cluster/management/raft/ValidationManager.java | 2 +-
.../cluster/management/raft/ValidationResult.java | 2 +-
.../raft/commands/InitCmgStateCommand.java | 2 +-
.../management/raft/commands/JoinReadyCommand.java | 2 +-
.../raft/commands/JoinRequestCommand.java | 2 +-
.../raft/commands/NodesLeaveCommand.java | 2 +-
.../raft/commands/ReadLogicalTopologyCommand.java | 2 +-
.../management/raft/commands/ReadStateCommand.java | 2 +-
.../raft/responses/LogicalTopologyResponse.java | 2 +-
.../raft/responses/ValidationErrorResponse.java | 2 +-
.../rest/ClusterManagementController.java | 6 +-
.../rest/ClusterManagementRestFactory.java | 4 +-
.../management/rest/TopologyController.java | 6 +-
.../exception/ClusterNotInitializedException.java | 27 -
...alidArgumentClusterInitializationException.java | 4 +-
.../ClusterNotInitializedExceptionHandler.java | 45 -
.../IgniteInternalCheckedExceptionHandler.java | 4 +-
.../handler/IgniteInternalExceptionHandler.java | 4 +-
...umentClusterInitializationExceptionHandler.java | 4 +-
.../cluster/management/ClusterInitializerTest.java | 2 +-
.../AbstractClusterStateStorageManagerTest.java | 2 +-
.../raft/AbstractClusterStateStorageTest.java | 2 +-
.../management/raft/CmgRaftGroupListenerTest.java | 2 +-
...oncurrentMapClusterStateStorageManagerTest.java | 2 +-
.../raft/ConcurrentMapClusterStateStorageTest.java | 2 +-
.../RocksDbClusterStateStorageManagerTest.java | 2 +-
.../raft/RocksDbClusterStateStorageTest.java | 2 +-
.../raft/ConcurrentMapClusterStateStorage.java | 2 +-
modules/compute/build.gradle | 6 +-
.../ignite/internal/compute/ComputeComponent.java | 4 +-
.../internal/compute/ComputeComponentImpl.java | 4 +-
.../internal/compute/ComputeMessageTypes.java | 4 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 4 +-
.../internal/compute/JobExecutionContextImpl.java | 4 +-
.../internal/compute/message/ExecuteRequest.java | 4 +-
.../internal/compute/message/ExecuteResponse.java | 4 +-
.../internal/compute/ComputeComponentImplTest.java | 4 +-
.../internal/compute/IgniteComputeImplTest.java | 4 +-
.../compute/JobExecutionContextImplTest.java | 4 +-
.../build.gradle | 11 +-
.../processor/AbstractProcessorTest.java | 4 +-
.../configuration/processor/ConfigSet.java | 4 +-
.../configuration/processor/HasFieldMatcher.java | 4 +-
.../configuration/processor/HasMethodMatcher.java | 4 +-
.../processor/ItConfigurationProcessorTest.java | 4 +-
.../configuration/processor/ParsedClass.java | 4 +-
.../ConfigurationSchemaWithWrongPostfix.java | 4 +-
.../processor/TestConfigurationSchema.java | 11 +-
.../AbstractConfigConfigurationSchema.java | 4 +-
...tConfigWithInjectedNameConfigurationSchema.java | 4 +-
...actConfigWithInternalIdConfigurationSchema.java | 4 +-
.../AbstractRootConfigConfigurationSchema.java | 4 +-
.../SimpleConfigConfigurationSchema.java | 4 +-
.../SimpleConfigRootConfigurationSchema.java | 4 +-
...lyAbstractConfigurationConfigurationSchema.java | 4 +-
...NamesWithAbstractConfigConfigurationSchema.java | 4 +-
...dNameWithAbstractConfigConfigurationSchema.java | 4 +-
...nalIdWithAbstractConfigConfigurationSchema.java | 4 +-
...lyAbstractConfigurationConfigurationSchema.java | 4 +-
...NamesWithAbstractConfigConfigurationSchema.java | 4 +-
...tedNameInAbstractConfigConfigurationSchema.java | 4 +-
...ernalIdInAbstractConfigConfigurationSchema.java | 4 +-
...tConfigMustContainsNameConfigurationSchema.java | 4 +-
...tibleSchemaAnnotations0ConfigurationSchema.java | 4 +-
...tibleSchemaAnnotations1ConfigurationSchema.java | 4 +-
...tibleSchemaAnnotations2ConfigurationSchema.java | 4 +-
...tibleSchemaAnnotations3ConfigurationSchema.java | 4 +-
...tibleSchemaAnnotations4ConfigurationSchema.java | 4 +-
.../MustNotBeSuperClassConfigurationSchema.java | 4 +-
...NotContainPolymorphicIdConfigurationSchema.java | 4 +-
.../ErrorInjectedName0ConfigurationSchema.java | 4 +-
.../ErrorInjectedName1ConfigurationSchema.java | 4 +-
.../ErrorInjectedName2ConfigurationSchema.java | 4 +-
.../ErrorInjectedName3ConfigurationSchema.java | 4 +-
.../ErrorInjectedName4ConfigurationSchema.java | 4 +-
.../ErrorInjectedName5ConfigurationSchema.java | 4 +-
.../ErrorName0ConfigurationSchema.java | 4 +-
.../ErrorName1ConfigurationSchema.java | 4 +-
.../injectedname/NameConfigurationSchema.java | 4 +-
.../injectedname/PolyConfigurationSchema.java | 4 +-
.../injectedname/SimpleConfigurationSchema.java | 4 +-
.../ErrorInternal0ConfigurationSchema.java | 4 +-
.../ErrorInternal1ConfigurationSchema.java | 4 +-
.../ErrorInternal2ConfigurationSchema.java | 4 +-
.../ErrorInternal3ConfigurationSchema.java | 4 +-
.../ErrorInternal4ConfigurationSchema.java | 4 +-
.../ErrorInternal5ConfigurationSchema.java | 4 +-
.../ExtendedSimpleConfigurationSchema.java | 4 +-
.../ExtendedSimpleRootConfigurationSchema.java | 4 +-
.../internal/SimpleConfigurationSchema.java | 4 +-
.../internal/SimpleRootConfigurationSchema.java | 4 +-
.../StaticConstantsConfigurationSchema.java | 4 +-
.../ErrorInternalId0ConfigurationSchema.java | 4 +-
.../SimpleInternalId0ConfigurationSchema.java | 4 +-
.../ErrorPolymorphic0ConfigurationSchema.java | 4 +-
.../ErrorPolymorphic1ConfigurationSchema.java | 4 +-
.../ErrorPolymorphic2ConfigurationSchema.java | 4 +-
.../ErrorPolymorphic3ConfigurationSchema.java | 4 +-
.../ErrorPolymorphic4ConfigurationSchema.java | 4 +-
.../ErrorPolymorphic5ConfigurationSchema.java | 4 +-
.../ErrorPolymorphic6ConfigurationSchema.java | 4 +-
.../ErrorPolymorphic7ConfigurationSchema.java | 4 +-
.../ErrorPolymorphic8ConfigurationSchema.java | 4 +-
...rorPolymorphicInstance0ConfigurationSchema.java | 4 +-
...rorPolymorphicInstance1ConfigurationSchema.java | 4 +-
...rorPolymorphicInstance2ConfigurationSchema.java | 4 +-
...rorPolymorphicInstance3ConfigurationSchema.java | 4 +-
...rorPolymorphicInstance4ConfigurationSchema.java | 4 +-
...rorPolymorphicInstance5ConfigurationSchema.java | 4 +-
...rorPolymorphicInstance6ConfigurationSchema.java | 4 +-
.../polymorphic/SimpleConfigurationSchema.java | 4 +-
.../SimplePolymorphicConfigurationSchema.java | 4 +-
...mplePolymorphicInstanceConfigurationSchema.java | 4 +-
.../polymorphic/SimpleRootConfigurationSchema.java | 4 +-
.../processor/ConfigurationProcessor.java | 38 +-
.../processor/ConfigurationProcessorException.java | 4 +-
.../processor/ConfigurationProcessorUtils.java | 4 +-
.../processor/ConfigurationProcessorUtilsTest.java | 4 +-
modules/configuration-api/build.gradle | 6 +-
.../ConfigurationChangeException.java | 4 +-
.../ConfigurationListenOnlyException.java | 4 +-
.../configuration/ConfigurationProperty.java | 4 +-
.../ConfigurationReadOnlyException.java | 4 +-
.../ignite/configuration/ConfigurationTree.java | 4 +-
.../ignite/configuration/ConfigurationValue.java | 4 +-
...nfigurationWrongPolymorphicTypeIdException.java | 4 +-
.../configuration/NamedConfigurationTree.java | 4 +-
.../ignite/configuration/NamedListChange.java | 4 +-
.../apache/ignite/configuration/NamedListView.java | 4 +-
.../ignite/configuration/PolymorphicChange.java | 4 +-
.../org/apache/ignite/configuration/RootKey.java | 4 +-
.../annotation/AbstractConfiguration.java | 4 +-
.../ignite/configuration/annotation/Config.java | 4 +-
.../configuration/annotation/ConfigValue.java | 4 +-
.../annotation/ConfigurationRoot.java | 4 +-
.../annotation/ConfigurationType.java | 4 +-
.../configuration/annotation/InjectedName.java | 4 +-
.../annotation/InternalConfiguration.java | 4 +-
.../configuration/annotation/InternalId.java | 2 +-
.../ignite/configuration/annotation/Name.java | 4 +-
.../configuration/annotation/NamedConfigValue.java | 4 +-
.../annotation/PolymorphicConfig.java | 4 +-
.../annotation/PolymorphicConfigInstance.java | 4 +-
.../configuration/annotation/PolymorphicId.java | 4 +-
.../ignite/configuration/annotation/Value.java | 6 +-
.../configuration/annotation/package-info.java | 4 +-
.../notifications/ConfigurationListener.java | 4 +-
.../ConfigurationNamedListListener.java | 4 +-
.../ConfigurationNotificationEvent.java | 4 +-
.../configuration/notifications/package-info.java | 4 +-
.../apache/ignite/configuration/package-info.java | 4 +-
.../ConfigurationValidationException.java | 4 +-
.../configuration/validation/ExceptKeys.java | 4 +-
.../ignite/configuration/validation/Immutable.java | 4 +-
.../ignite/configuration/validation/OneOf.java | 4 +-
.../configuration/validation/PowerOfTwo.java | 4 +-
.../ignite/configuration/validation/Range.java | 4 +-
.../validation/ValidationContext.java | 4 +-
.../configuration/validation/ValidationIssue.java | 4 +-
.../ignite/configuration/validation/Validator.java | 4 +-
.../configuration/validation/package-info.java | 4 +-
modules/configuration/build.gradle | 7 +-
.../ComponentNotStartedException.java | 30 +
.../configuration/ConfigurationChanger.java | 33 +-
.../configuration/ConfigurationListenerHolder.java | 4 +-
.../configuration/ConfigurationManager.java | 4 +-
.../configuration/ConfigurationModule.java | 4 +-
.../internal/configuration/ConfigurationNode.java | 4 +-
.../configuration/ConfigurationRegistry.java | 4 +-
.../configuration/ConfigurationTreeWrapper.java | 4 +-
.../configuration/DynamicConfiguration.java | 4 +-
.../configuration/DynamicConfigurationChanger.java | 4 +-
.../internal/configuration/DynamicProperty.java | 4 +-
.../configuration/NamedListConfiguration.java | 4 +-
.../internal/configuration/RootInnerNode.java | 4 +-
.../ignite/internal/configuration/SuperRoot.java | 4 +-
.../ignite/internal/configuration/TypeUtils.java | 4 +-
.../asm/ConfigurationAsmGenerator.java | 4 +-
.../configuration/asm/DirectProxyAsmGenerator.java | 4 +-
.../configuration/asm/SchemaClassesInfo.java | 4 +-
.../configuration/asm/StringSwitchBuilder.java | 4 +-
.../direct/DirectConfigurationProxy.java | 4 +-
.../configuration/direct/DirectNamedListProxy.java | 4 +-
.../configuration/direct/DirectPropertyProxy.java | 4 +-
.../configuration/direct/DirectValueProxy.java | 4 +-
.../internal/configuration/direct/KeyPathNode.java | 4 +-
.../configuration/hocon/HoconConverter.java | 4 +-
.../hocon/HoconListConfigurationSource.java | 4 +-
.../hocon/HoconObjectConfigurationSource.java | 4 +-
.../hocon/HoconPrimitiveConfigurationSource.java | 11 +-
.../notifications/ConfigurationContainer.java | 4 +-
.../ConfigurationNotificationContext.java | 4 +-
.../ConfigurationNotificationEventImpl.java | 4 +-
.../ConfigurationNotificationUtils.java | 4 +-
.../notifications/ConfigurationNotifier.java | 4 +-
.../ConfigurationStorageRevisionListener.java | 4 +-
...ConfigurationStorageRevisionListenerHolder.java | 4 +-
.../notifications/NamedListChanges.java | 4 +-
.../presentation/ConfigurationPresentation.java | 4 +-
.../rest/presentation/hocon/HoconPresentation.java | 4 +-
.../rest/presentation/hocon/package-info.java | 4 +-
.../rest/presentation/package-info.java | 4 +-
.../storage/ConfigurationStorage.java | 4 +-
.../storage/ConfigurationStorageListener.java | 4 +-
.../internal/configuration/storage/Data.java | 4 +-
.../configuration/storage/StorageException.java | 4 +-
.../configuration/tree/ConfigurationSource.java | 4 +-
.../configuration/tree/ConfigurationVisitor.java | 4 +-
.../configuration/tree/ConstructableTreeNode.java | 4 +-
.../configuration/tree/ConverterToMapVisitor.java | 9 +-
.../internal/configuration/tree/InnerNode.java | 4 +-
.../internal/configuration/tree/NamedListNode.java | 4 +-
.../internal/configuration/tree/OrderedMap.java | 4 +-
.../configuration/tree/TraversableTreeNode.java | 4 +-
.../util/AnyNodeConfigurationVisitor.java | 4 +-
.../configuration/util/ConfigurationFlattener.java | 10 +-
.../util/ConfigurationSerializationUtil.java | 48 +-
.../configuration/util/ConfigurationUtil.java | 4 +-
.../configuration/util/KeyNotFoundException.java | 4 +-
.../util/KeysTrackingConfigurationVisitor.java | 4 +-
.../util/WrongPolymorphicTypeIdException.java | 4 +-
.../validation/ExceptKeysValidator.java | 4 +-
.../validation/ImmutableValidator.java | 4 +-
.../configuration/validation/MemberKey.java | 4 +-
.../configuration/validation/OneOfValidator.java | 4 +-
.../validation/PowerOfTwoValidator.java | 4 +-
.../configuration/validation/RangeValidator.java | 4 +-
.../validation/ValidationContextImpl.java | 4 +-
.../configuration/validation/ValidationUtil.java | 4 +-
.../AbstractConfigurationController.java | 6 +-
.../ClusterConfigurationController.java | 25 +-
.../configuration/NodeConfigurationController.java | 4 +-
.../rest/configuration/PresentationsFactory.java | 4 +-
.../configuration/ConfigurationChangerTest.java | 4 +-
.../ConfigurationListenerHolderTest.java | 4 +-
.../configuration/ConfigurationRegistryTest.java | 4 +-
.../configuration/ConfigurationTestUtils.java | 4 +-
.../asm/ConfigurationAsmGeneratorTest.java | 37 +-
.../configuration/direct/DirectPropertiesTest.java | 4 +-
.../configuration/hocon/HoconConverterTest.java | 59 +-
.../ConfigurationAnyListenerTest.java | 4 +-
.../notifications/ConfigurationListenerTest.java | 4 +-
.../ConfigurationListenerTestUtils.java | 4 +-
.../ConfigurationPresentationTest.java | 4 +-
.../sample/AutoAdjustConfigurationSchema.java | 4 +-
.../sample/BaselineConfigurationSchema.java | 4 +-
.../sample/CacheConfigurationSchema.java | 4 +-
.../sample/ClusterWideConfigurationSchema.java | 4 +-
.../sample/DiscoveryConfigurationSchema.java | 4 +-
.../ExtendedDiscoveryConfigurationSchema.java | 4 +-
.../sample/LocalConfigurationSchema.java | 4 +-
.../sample/NetworkConfigurationSchema.java | 4 +-
.../sample/NodeConfigurationSchema.java | 4 +-
.../internal/configuration/sample/UsageTest.java | 4 +-
.../testframework/ConfigurationExtensionTest.java | 4 +-
.../configuration/tree/ConfigurationArrayTest.java | 16 +-
.../tree/ConstructableTreeNodeTest.java | 4 +-
.../configuration/tree/InternalIdTest.java | 4 +-
.../configuration/tree/NamedListNodeTest.java | 27 +-
.../configuration/tree/OrderedMapTest.java | 4 +-
.../tree/TraversableTreeNodeTest.java | 4 +-
.../util/ConfigurationSerializationUtilTest.java | 9 +-
.../configuration/util/ConfigurationUtilTest.java | 4 +-
.../validation/OneOfValidatorTest.java | 4 +-
.../validation/PowerOfTwoValidatorTest.java | 4 +-
.../validation/RangeValidatorTest.java | 4 +-
.../validation/ValidationUtilTest.java | 4 +-
.../ClusterConfigurationControllerTest.java | 4 +-
.../ConfigurationControllerBaseTest.java | 4 +-
.../NodeConfigurationControllerTest.java | 4 +-
.../internal/rest/configuration/TestFactory.java | 4 +-
.../configuration/TestRootConfigurationSchema.java | 4 +-
.../configuration/TestSubConfigurationSchema.java | 4 +-
.../configuration/TestConfigurationChanger.java | 4 +-
.../storage/TestConfigurationStorage.java | 4 +-
.../testframework/BasicConfigurationSchema.java | 4 +-
.../testframework/ConfigurationExtension.java | 4 +-
.../testframework/ExtendedConfigurationSchema.java | 4 +-
.../testframework/InjectConfiguration.java | 4 +-
.../InjectRevisionListenerHolder.java | 4 +-
.../validation/TestValidationUtil.java | 4 +-
modules/core/build.gradle | 6 +-
.../java/org/apache/ignite/hlc/HybridClock.java | 4 +-
.../org/apache/ignite/hlc/HybridTimestamp.java | 2 +-
.../internal/causality/OutdatedTokenException.java | 4 +-
.../ignite/internal/causality/VersionedValue.java | 4 +-
.../internal/components/LongJvmPauseDetector.java | 4 +-
.../ignite/internal/future/InFlightFutures.java | 8 +-
.../ignite/internal/logger/IgniteLogger.java | 4 +-
.../org/apache/ignite/internal/logger/Loggers.java | 4 +-
.../apache/ignite/internal/logger/VoidLogger.java | 4 +-
.../org/apache/ignite/internal/manager/Event.java | 4 +-
.../ignite/internal/manager/EventListener.java | 4 +-
.../ignite/internal/manager/EventParameters.java | 4 +-
.../ignite/internal/manager/IgniteComponent.java | 4 +-
.../internal/manager/ListenerRemovedException.java | 4 +-
.../apache/ignite/internal/manager/Producer.java | 4 +-
.../internal/properties/IgniteProductVersion.java | 2 +-
.../internal/properties/IgniteProperties.java | 2 +-
.../ignite/internal/thread/IgniteThread.java | 4 +-
.../thread/LogUncaughtExceptionHandler.java | 6 +-
.../ignite/internal/thread/NamedThreadFactory.java | 6 +-
.../internal/thread/StripedThreadPoolExecutor.java | 4 +-
.../internal/tostring/CircularStringBuilder.java | 4 +-
.../ignite/internal/tostring/ClassDescriptor.java | 4 +-
.../ignite/internal/tostring/FieldDescriptor.java | 4 +-
.../internal/tostring/IgniteToStringBuilder.java | 4 +-
.../internal/tostring/IgniteToStringExclude.java | 4 +-
.../internal/tostring/IgniteToStringInclude.java | 4 +-
.../internal/tostring/IgniteToStringOrder.java | 4 +-
.../org/apache/ignite/internal/tostring/S.java | 4 +-
.../tostring/SensitiveDataLoggingPolicy.java | 4 +-
.../tostring/StringBuilderLimitedLength.java | 4 +-
.../apache/ignite/internal/util/ArrayFactory.java | 4 +-
.../apache/ignite/internal/util/ArrayUtils.java | 4 +-
.../org/apache/ignite/internal/util/ByteUtils.java | 48 +-
.../apache/ignite/internal/util/Cancellable.java | 4 +-
.../ignite/internal/util/CollectionUtils.java | 4 +-
.../org/apache/ignite/internal/util/Constants.java | 4 +-
.../org/apache/ignite/internal/util/Cursor.java | 4 +-
.../ignite/internal/util/ExceptionUtils.java | 2 +-
.../ignite/internal/util/FastTimestamps.java | 4 +-
.../ignite/internal/util/FeatureChecker.java | 4 +-
.../ignite/internal/util/FilteringIterator.java | 4 +-
.../apache/ignite/internal/util/GridUnsafe.java | 4 +-
.../ignite/internal/util/HashCalculator.java | 4 +-
.../org/apache/ignite/internal/util/HashUtils.java | 4 +-
.../util/IgniteConcurrentMultiPairQueue.java | 4 +-
.../apache/ignite/internal/util/IgniteCursor.java | 4 +-
.../ignite/internal/util/IgniteIntIterator.java | 4 +-
.../apache/ignite/internal/util/IgniteIntList.java | 4 +-
.../ignite/internal/util/IgniteObjectName.java | 4 +-
.../ignite/internal/util/IgniteSpinBusyLock.java | 4 +-
.../internal/util/IgniteSpinReadWriteLock.java | 4 +-
.../ignite/internal/util/IgniteStripedLock.java | 4 +-
.../apache/ignite/internal/util/IgniteUtils.java | 4 +-
.../ignite/internal/util/OffheapReadWriteLock.java | 4 +-
.../ignite/internal/util/ReverseIterator.java | 2 +-
.../ignite/internal/util/StringIntrospection.java | 4 +-
.../apache/ignite/internal/util/StringUtils.java | 2 +-
.../ignite/internal/util/TransformingIterator.java | 4 +-
.../ignite/internal/util/io/IgniteDataInput.java | 4 +-
.../ignite/internal/util/io/IgniteDataOutput.java | 4 +-
.../internal/util/io/IgniteUnsafeDataInput.java | 4 +-
.../internal/util/io/IgniteUnsafeDataOutput.java | 4 +-
.../apache/ignite/internal/util/io/VarInts.java | 4 +-
.../ignite/internal/util/worker/IgniteWorker.java | 4 +-
.../internal/util/worker/IgniteWorkerListener.java | 4 +-
.../util/worker/WorkProgressDispatcher.java | 4 +-
.../java/org/apache/ignite/lang/ByteArray.java | 4 +-
.../java/org/apache/ignite/lang/ErrorGroup.java | 8 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 18 +-
.../java/org/apache/ignite/lang/IgniteBiTuple.java | 4 +-
.../lang/IgniteInternalCheckedException.java | 4 +-
.../ignite/lang/IgniteInternalException.java | 4 +-
.../apache/ignite/lang/IgniteStringBuilder.java | 4 +-
.../apache/ignite/lang/IgniteStringFormatter.java | 4 +-
.../apache/ignite/lang/IgniteSystemProperties.java | 4 +-
.../apache/ignite/lang/IgniteTetraFunction.java | 4 +-
.../org/apache/ignite/lang/IgniteTriConsumer.java | 4 +-
.../org/apache/ignite/lang/IgniteTriFunction.java | 4 +-
.../java/org/apache/ignite/lang/IgniteTuple3.java | 4 +-
.../java/org/apache/ignite/lang/IgniteUuid.java | 4 +-
.../apache/ignite/lang/IgniteUuidGenerator.java | 4 +-
.../apache/ignite/lang/JavaLoggerFormatter.java | 4 +-
.../java/org/apache/ignite/lang/LoggerFactory.java | 4 +-
.../apache/ignite/lang/NodeStoppingException.java | 4 +-
.../java/org/apache/ignite/lang/package-info.java | 4 +-
.../communication/MessageCollectionItemType.java | 4 +-
.../extensions/communication/package-info.java | 4 +-
.../org/apache/ignite/hlc/HybridClockTest.java | 4 +-
.../apache/ignite/hlc/HybridClockTestUtils.java | 4 +-
.../org/apache/ignite/hlc/HybridTimestampTest.java | 4 +-
.../internal/causality/VersionedValueTest.java | 4 +-
.../internal/future/InFlightFuturesTest.java | 14 +-
.../ignite/internal/manager/ProducerTest.java | 4 +-
.../properties/IgniteProductVersionTest.java | 2 +-
.../internal/testframework/VariableSourceTest.java | 2 +-
.../testframework/WorkDirectoryExtensionTest.java | 2 +-
.../tostring/CircularStringBuilderSelfTest.java | 4 +-
.../tostring/IgniteToStringBuilderSelfTest.java | 4 +-
.../tostring/SensitiveDataToStringTest.java | 4 +-
.../ignite/internal/util/ArrayUtilsSelfTest.java | 4 +-
.../ignite/internal/util/CollectionUtilsTest.java | 4 +-
.../apache/ignite/internal/util/HashUtilsTest.java | 4 +-
.../util/IgniteConcurrentMultiPairQueueTest.java | 4 +-
.../internal/util/IgniteIntListSelfTest.java | 4 +-
.../util/IgniteOffheapReadWriteLockSelfTest.java | 4 +-
.../apache/ignite/internal/util/IgniteRandom.java | 60 -
.../ignite/internal/util/IgniteRandomSelfTest.java | 4 +-
.../internal/util/IgniteSpinReadWriteLockTest.java | 4 +-
.../internal/util/IgniteStripedLockSelfTest.java | 4 +-
.../ignite/internal/util/IgniteUtilsTest.java | 4 +-
.../internal/util/StringIntrospectionTest.java | 8 +-
.../ignite/internal/util/io/IgniteTestIoUtils.java | 4 +-
.../IgniteUnsafeDataInputOutputByteOrderTest.java | 4 +-
.../util/io/IgniteUnsafeDataInputTest.java | 4 +-
.../io/IgniteUnsafeDataOutputArraySizingTest.java | 4 +-
.../ignite/internal/util/io/VarIntsTest.java | 4 +-
.../internal/util/worker/IgniteWorkerTest.java | 4 +-
.../org/apache/ignite/lang/ErrorGroupTest.java | 56 +-
.../org/apache/ignite/lang/LoggerHelperTest.java | 4 +-
.../testframework/BaseIgniteAbstractTest.java | 4 +-
.../internal/testframework/IgniteAbstractTest.java | 4 +-
.../internal/testframework/IgniteTestUtils.java | 4 +-
.../testframework/JunitExtensionTestUtils.java | 2 +-
.../testframework/SystemPropertiesExtension.java | 4 +-
.../testframework/SystemPropertiesList.java | 4 +-
.../testframework/VariableArgumentsProvider.java | 2 +-
.../internal/testframework/VariableSource.java | 2 +-
.../internal/testframework/WithSystemProperty.java | 4 +-
.../internal/testframework/WorkDirectory.java | 4 +-
.../testframework/WorkDirectoryExtension.java | 4 +-
.../internal/testframework/jul/NoOpHandler.java | 4 +-
.../matchers/CompletableFutureMatcher.java | 4 +-
.../testframework/util/DirectExecutor.java | 4 +-
.../apache/ignite/internal/util/IgniteRandom.java | 60 +
modules/extended-api/build.gradle | 6 +-
.../schema/ExtendedTableConfigurationSchema.java | 4 +-
.../schema/SchemaConfigurationSchema.java | 4 +-
modules/file-io/build.gradle | 6 +-
.../ignite/internal/fileio/AbstractFileIo.java | 4 +-
.../apache/ignite/internal/fileio/AsyncFileIo.java | 4 +-
.../ignite/internal/fileio/AsyncFileIoFactory.java | 4 +-
.../org/apache/ignite/internal/fileio/FileIo.java | 4 +-
.../ignite/internal/fileio/FileIoDecorator.java | 4 +-
.../ignite/internal/fileio/FileIoFactory.java | 4 +-
.../ignite/internal/fileio/RandomAccessFileIo.java | 4 +-
.../internal/fileio/RandomAccessFileIoFactory.java | 4 +-
.../ignite/internal/fileio/AbstractFileIoTest.java | 4 +-
.../ignite/internal/fileio/AsyncFileIoTest.java | 4 +-
.../internal/fileio/FileIoDecoratorTest.java | 4 +-
.../internal/fileio/RandomAccessFileIoTest.java | 4 +-
modules/index/build.gradle | 6 +-
.../ignite/internal/index/ColumnCollation.java | 4 +-
.../apache/ignite/internal/index/HashIndex.java | 4 +-
.../org/apache/ignite/internal/index/Index.java | 4 +-
.../ignite/internal/index/IndexDescriptor.java | 4 +-
.../apache/ignite/internal/index/IndexManager.java | 4 +-
.../apache/ignite/internal/index/SortedIndex.java | 4 +-
.../internal/index/SortedIndexDescriptor.java | 4 +-
.../ignite/internal/index/SortedIndexImpl.java | 4 +-
.../ignite/internal/index/event/IndexEvent.java | 4 +-
.../internal/index/event/IndexEventParameters.java | 4 +-
.../ignite/internal/index/IndexManagerTest.java | 4 +-
modules/jacoco-report/build.gradle | 6 +-
modules/marshaller-common/build.gradle | 6 +-
.../ignite/internal/marshaller/BinaryMode.java | 4 +-
.../ignite/internal/marshaller/FieldAccessor.java | 45 +-
.../ignite/internal/marshaller/Marshaller.java | 4 +-
.../internal/marshaller/MarshallerColumn.java | 18 +-
.../internal/marshaller/MarshallerException.java | 4 +-
.../internal/marshaller/MarshallerReader.java | 6 +-
.../ignite/internal/marshaller/MarshallerUtil.java | 4 +-
.../internal/marshaller/MarshallerWriter.java | 8 +-
.../org/apache/ignite/internal/util/Factory.java | 4 +-
.../apache/ignite/internal/util/ObjectFactory.java | 4 +-
.../java/org/apache/ignite/internal/util/Pair.java | 4 +-
.../internal/marshaller/FieldAccessorTest.java | 8 +-
.../testobjects/TestObjectWithAllTypes.java | 4 +-
.../TestObjectWithNoDefaultConstructor.java | 4 +-
.../TestObjectWithPrivateConstructor.java | 4 +-
.../marshaller/testobjects/TestSimpleObject.java | 4 +-
modules/metastorage-client/build.gradle | 19 +-
.../client/ItMetaStorageRaftGroupTest.java | 4 +-
.../ItMetaStorageServicePersistenceTest.java | 4 +-
.../client/ItMetaStorageServiceTest.java | 4 +-
.../metastorage/client/CompactedException.java | 4 +-
.../metastorage/client/CompoundCondition.java | 2 +-
.../internal/metastorage/client/Condition.java | 4 +-
.../internal/metastorage/client/Conditions.java | 4 +-
.../internal/metastorage/client/CursorImpl.java | 4 +-
.../ignite/internal/metastorage/client/Entry.java | 4 +-
.../internal/metastorage/client/EntryEvent.java | 4 +-
.../internal/metastorage/client/EntryImpl.java | 4 +-
.../ignite/internal/metastorage/client/If.java | 2 +-
.../metastorage/client/MetaStorageService.java | 4 +-
.../metastorage/client/MetaStorageServiceImpl.java | 4 +-
.../internal/metastorage/client/Operation.java | 4 +-
.../client/OperationTimeoutException.java | 4 +-
.../internal/metastorage/client/Operations.java | 4 +-
.../metastorage/client/SimpleCondition.java | 2 +-
.../internal/metastorage/client/Statement.java | 2 +-
.../metastorage/client/StatementResult.java | 2 +-
.../ignite/internal/metastorage/client/Update.java | 2 +-
.../internal/metastorage/client/WatchEvent.java | 4 +-
.../internal/metastorage/client/WatchListener.java | 4 +-
.../internal/metastorage/client/package-info.java | 4 +-
modules/metastorage-common/build.gradle | 6 +-
.../internal/metastorage/common/ConditionType.java | 4 +-
.../metastorage/common/MetaStorageException.java | 4 +-
.../internal/metastorage/common/OperationType.java | 4 +-
.../internal/metastorage/common/StatementInfo.java | 2 +-
.../metastorage/common/StatementResultInfo.java | 2 +-
.../internal/metastorage/common/UpdateInfo.java | 2 +-
.../common/command/CompoundConditionInfo.java | 2 +-
.../common/command/CompoundConditionType.java | 2 +-
.../metastorage/common/command/ConditionInfo.java | 4 +-
.../metastorage/common/command/ErrorResponse.java | 4 +-
.../metastorage/common/command/GetAllCommand.java | 4 +-
.../common/command/GetAndPutAllCommand.java | 4 +-
.../common/command/GetAndPutCommand.java | 4 +-
.../common/command/GetAndRemoveAllCommand.java | 4 +-
.../common/command/GetAndRemoveCommand.java | 4 +-
.../metastorage/common/command/GetCommand.java | 4 +-
.../metastorage/common/command/IfInfo.java | 2 +-
.../metastorage/common/command/InvokeCommand.java | 4 +-
.../common/command/MultiInvokeCommand.java | 2 +-
.../common/command/MultipleEntryResponse.java | 4 +-
.../metastorage/common/command/OperationInfo.java | 4 +-
.../metastorage/common/command/PutAllCommand.java | 4 +-
.../metastorage/common/command/PutCommand.java | 4 +-
.../metastorage/common/command/RangeCommand.java | 4 +-
.../common/command/RemoveAllCommand.java | 4 +-
.../metastorage/common/command/RemoveCommand.java | 4 +-
.../common/command/SimpleConditionInfo.java | 2 +-
.../common/command/SingleEntryResponse.java | 4 +-
.../common/command/WatchExactKeysCommand.java | 4 +-
.../common/command/WatchRangeKeysCommand.java | 4 +-
.../common/command/cursor/CursorCloseCommand.java | 4 +-
.../command/cursor/CursorHasNextCommand.java | 4 +-
.../common/command/cursor/CursorNextCommand.java | 4 +-
.../common/command/cursor/CursorsCloseCommand.java | 4 +-
.../internal/metastorage/common/package-info.java | 4 +-
modules/metastorage-server/build.gradle | 6 +-
.../server/AbstractCompoundCondition.java | 2 +-
.../server/AbstractSimpleCondition.java | 4 +-
.../internal/metastorage/server/AndCondition.java | 2 +-
.../metastorage/server/CompactedException.java | 4 +-
.../internal/metastorage/server/Condition.java | 4 +-
.../ignite/internal/metastorage/server/Entry.java | 4 +-
.../internal/metastorage/server/EntryEvent.java | 4 +-
.../metastorage/server/ExistenceCondition.java | 4 +-
.../ignite/internal/metastorage/server/If.java | 2 +-
.../metastorage/server/KeyValueStorage.java | 4 +-
.../internal/metastorage/server/Operation.java | 4 +-
.../internal/metastorage/server/OrCondition.java | 2 +-
.../metastorage/server/RevisionCondition.java | 4 +-
.../internal/metastorage/server/Statement.java | 2 +-
.../metastorage/server/StatementResult.java | 2 +-
.../metastorage/server/TombstoneCondition.java | 4 +-
.../ignite/internal/metastorage/server/Update.java | 2 +-
.../ignite/internal/metastorage/server/Value.java | 4 +-
.../metastorage/server/ValueCondition.java | 4 +-
.../internal/metastorage/server/WatchEvent.java | 4 +-
.../server/persistence/RangeCursor.java | 4 +-
.../server/persistence/RocksDbKeyValueStorage.java | 4 +-
.../server/persistence/RocksStorageUtils.java | 4 +-
.../persistence/StorageColumnFamilyType.java | 4 +-
.../server/persistence/WatchCursor.java | 4 +-
.../server/raft/MetaStorageListener.java | 4 +-
.../server/AbstractKeyValueStorageTest.java | 4 +-
.../metastorage/server/AndConditionTest.java | 2 +-
.../metastorage/server/ExistenceConditionTest.java | 4 +-
.../metastorage/server/OrConditionTest.java | 2 +-
.../metastorage/server/RevisionConditionTest.java | 4 +-
.../server/RocksDbKeyValueStorageTest.java | 4 +-
.../server/SimpleInMemoryKeyValueStorageTest.java | 4 +-
.../metastorage/server/TombstoneConditionTest.java | 4 +-
.../metastorage/server/ValueConditionTest.java | 4 +-
.../server/SimpleInMemoryKeyValueStorage.java | 4 +-
modules/metastorage/build.gradle | 6 +-
.../internal/metastorage/MetaStorageManager.java | 4 +-
.../metastorage/watch/AggregatedWatch.java | 4 +-
.../internal/metastorage/watch/KeyCriterion.java | 4 +-
.../metastorage/watch/WatchAggregator.java | 4 +-
.../metastorage/MetaStorageRangeCursorTest.java | 4 +-
.../internal/metastorage/WatchAggregatorTest.java | 4 +-
modules/metrics/build.gradle | 9 +-
.../exporters/MetricExportersLoadingTest.java | 74 +
.../metrics/exporters/TestMetricsSource.java | 61 +
.../metrics/exporters/TestPullMetricExporter.java | 98 +
.../metrics/exporters/TestPushMetricExporter.java | 69 +
...gnite.internal.metrics.exporters.MetricExporter | 17 +
.../ignite/internal/metrics/AbstractMetric.java | 4 +-
.../internal/metrics/AbstractMetricSource.java | 4 +-
.../internal/metrics/AtomicDoubleMetric.java | 4 +-
.../ignite/internal/metrics/AtomicIntMetric.java | 4 +-
.../ignite/internal/metrics/AtomicLongMetric.java | 4 +-
.../internal/metrics/CompositeAwareIterator.java | 4 +-
.../ignite/internal/metrics/CompositeMetric.java | 4 +-
.../internal/metrics/DistributionMetric.java | 4 +-
.../ignite/internal/metrics/DoubleAdderMetric.java | 4 +-
.../ignite/internal/metrics/DoubleGauge.java | 4 +-
.../ignite/internal/metrics/DoubleMetric.java | 4 +-
.../ignite/internal/metrics/HitRateMetric.java | 4 +-
.../apache/ignite/internal/metrics/IntGauge.java | 4 +-
.../apache/ignite/internal/metrics/IntMetric.java | 4 +-
.../ignite/internal/metrics/LongAdderMetric.java | 4 +-
.../apache/ignite/internal/metrics/LongGauge.java | 4 +-
.../apache/ignite/internal/metrics/LongMetric.java | 4 +-
.../org/apache/ignite/internal/metrics/Metric.java | 4 +-
.../ignite/internal/metrics/MetricManager.java | 44 +-
.../ignite/internal/metrics/MetricProvider.java | 47 +
.../ignite/internal/metrics/MetricRegistry.java | 4 +-
.../apache/ignite/internal/metrics/MetricSet.java | 4 +-
.../ignite/internal/metrics/MetricSetBuilder.java | 4 +-
.../ignite/internal/metrics/MetricSource.java | 4 +-
.../metrics/exporters/BasicMetricExporter.java | 52 +
.../internal/metrics/exporters/MetricExporter.java | 56 +
.../metrics/exporters/PushMetricExporter.java | 107 +
.../internal/metrics/AbstractDoubleMetricTest.java | 4 +-
.../internal/metrics/AbstractIntMetricTest.java | 4 +-
.../internal/metrics/AbstractLongMetricTest.java | 4 +-
.../metrics/AbstractScalarMetricsTest.java | 4 +-
.../internal/metrics/AtomicDoubleMetricTest.java | 4 +-
.../internal/metrics/AtomicIntMetricTest.java | 4 +-
.../internal/metrics/AtomicLongMetricTest.java | 4 +-
.../internal/metrics/DistributionMetricTest.java | 4 +-
.../internal/metrics/DoubleAdderMetricTest.java | 4 +-
.../ignite/internal/metrics/DoubleGaugeTest.java | 4 +-
.../ignite/internal/metrics/HitRateMetricTest.java | 4 +-
.../ignite/internal/metrics/IntGaugeTest.java | 4 +-
.../internal/metrics/LongAdderMetricTest.java | 4 +-
.../internal/metrics/LongGaugeMetricTest.java | 4 +-
.../internal/metrics/MetricEntitiesTest.java | 4 +-
.../internal/metrics/ThreadPoolMetricSource.java | 4 +-
.../internal/metrics/ThreadPoolMetricTest.java | 4 +-
modules/network-annotation-processor/build.gradle | 6 +-
.../processor/IncrementalCompilationConfig.java | 4 +-
.../internal/network/processor/MessageClass.java | 4 +-
.../network/processor/MessageGroupWrapper.java | 4 +-
.../network/processor/ProcessingException.java | 4 +-
.../processor/TransferableObjectProcessor.java | 4 +-
.../internal/network/processor/TypeUtils.java | 4 +-
.../messages/MessageBuilderGenerator.java | 4 +-
.../messages/MessageFactoryGenerator.java | 4 +-
.../processor/messages/MessageImplGenerator.java | 4 +-
.../serialization/BaseMethodNameResolver.java | 4 +-
.../MessageCollectionItemTypeConverter.java | 4 +-
.../MessageDeserializerGenerator.java | 4 +-
.../serialization/MessageReaderMethodResolver.java | 4 +-
.../serialization/MessageSerializerGenerator.java | 4 +-
.../serialization/MessageWriterMethodResolver.java | 4 +-
.../RegistryInitializerGenerator.java | 4 +-
.../SerializationFactoryGenerator.java | 4 +-
modules/network-api/build.gradle | 6 +-
.../ignite/network/AbstractClusterService.java | 4 +-
.../ignite/network/AbstractMessagingService.java | 4 +-
.../ignite/network/AbstractTopologyService.java | 4 +-
.../ignite/network/ClusterLocalConfiguration.java | 4 +-
.../org/apache/ignite/network/ClusterService.java | 4 +-
.../apache/ignite/network/MessagingService.java | 4 +-
.../network/NetworkConfigurationException.java | 4 +-
.../org/apache/ignite/network/NetworkMessage.java | 6 +-
.../ignite/network/NetworkMessageHandler.java | 4 +-
.../java/org/apache/ignite/network/NodeFinder.java | 4 +-
.../ignite/network/annotations/Marshallable.java | 4 +-
.../ignite/network/annotations/MessageGroup.java | 4 +-
.../ignite/network/annotations/Transferable.java | 4 +-
.../ignite/network/annotations/package-info.java | 4 +-
.../org/apache/ignite/network/package-info.java | 4 +-
.../network/serialization/MessageDeserializer.java | 4 +-
.../serialization/MessageMappingException.java | 4 +-
.../network/serialization/MessageReader.java | 4 +-
.../serialization/MessageSerializationFactory.java | 4 +-
.../MessageSerializationRegistry.java | 4 +-
.../MessageSerializationRegistryInitializer.java | 4 +-
.../network/serialization/MessageSerializer.java | 4 +-
.../network/serialization/MessageWriter.java | 4 +-
.../ignite/network/serialization/package-info.java | 4 +-
.../ignite/network/util/ClusterServiceUtils.java | 2 +-
.../apache/ignite/network/NetworkAddressTest.java | 4 +-
modules/network/build.gradle | 6 +-
.../network/netty/ItConnectionManagerTest.java | 4 +-
.../network/processor/InMemoryJavaFileManager.java | 4 +-
...TransferableObjectProcessorIncrementalTest.java | 4 +-
.../ItTransferableObjectProcessorTest.java | 4 +-
.../network/scalecube/ItClusterServiceTest.java | 2 +-
.../network/scalecube/ItNodeRestartsTest.java | 4 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 4 +-
.../ignite/network/scalecube/package-info.java | 4 +-
.../network/processor/AllTypesMessage.java | 4 +-
.../network/processor/ConflictingTypeMessage.java | 4 +-
.../network/processor/InheritedMessageClash.java | 4 +-
.../processor/InvalidAnnotatedTypeMessage.java | 4 +-
.../processor/InvalidParameterGetterMessage.java | 4 +-
.../processor/InvalidReturnTypeGetterMessage.java | 4 +-
.../network/processor/ItTestMessageGroup.java | 4 +-
.../internal/network/processor/SecondGroup.java | 4 +-
.../network/processor/TransitiveMessage.java | 4 +-
.../processor/UnmarshallableTypeMessage.java | 4 +-
.../UnmarshallableTypeNonSerializableMessage.java | 4 +-
.../internal/network/NetworkMessageTypes.java | 4 +-
.../network/direct/DirectMarshallingUtils.java | 4 +-
.../network/direct/DirectMessageReader.java | 4 +-
.../network/direct/DirectMessageWriter.java | 4 +-
.../network/direct/state/DirectMessageState.java | 4 +-
.../direct/state/DirectMessageStateItem.java | 4 +-
.../direct/stream/DirectByteBufferStream.java | 4 +-
.../stream/DirectByteBufferStreamImplV1.java | 4 +-
.../network/handshake/HandshakeAction.java | 4 +-
.../network/handshake/HandshakeException.java | 4 +-
.../network/handshake/HandshakeManager.java | 4 +-
.../network/handshake/HandshakeResult.java | 4 +-
.../message/ClassDescriptorListMessage.java | 4 +-
.../network/message/ClassDescriptorMessage.java | 4 +-
.../network/message/FieldDescriptorMessage.java | 4 +-
.../internal/network/message/InvokeRequest.java | 4 +-
.../internal/network/message/InvokeResponse.java | 4 +-
.../internal/network/message/ScaleCubeMessage.java | 4 +-
.../internal/network/netty/ConnectionManager.java | 4 +-
.../netty/DefaultRecoveryDescriptorProvider.java | 4 +-
.../internal/network/netty/HandshakeHandler.java | 4 +-
.../internal/network/netty/InNetworkObject.java | 4 +-
.../internal/network/netty/InboundDecoder.java | 4 +-
.../network/netty/InboundRecoveryHandler.java | 4 +-
.../netty/IoExceptionSuppressingHandler.java | 4 +-
.../internal/network/netty/MessageHandler.java | 4 +-
.../network/netty/NamedNioEventLoopGroup.java | 4 +-
.../ignite/internal/network/netty/NettyClient.java | 4 +-
.../ignite/internal/network/netty/NettySender.java | 4 +-
.../ignite/internal/network/netty/NettyServer.java | 4 +-
.../ignite/internal/network/netty/NettyUtils.java | 4 +-
.../internal/network/netty/OutboundEncoder.java | 4 +-
.../network/netty/OutboundRecoveryHandler.java | 4 +-
.../internal/network/netty/PipelineUtils.java | 4 +-
.../recovery/RecoveryClientHandshakeManager.java | 4 +-
.../network/recovery/RecoveryDescriptor.java | 4 +-
.../recovery/RecoveryDescriptorProvider.java | 4 +-
.../recovery/RecoveryServerHandshakeManager.java | 4 +-
.../recovery/message/AcknowledgementMessage.java | 4 +-
.../recovery/message/HandshakeFinishMessage.java | 4 +-
.../recovery/message/HandshakeStartMessage.java | 4 +-
.../message/HandshakeStartResponseMessage.java | 4 +-
.../network/recovery/message/InternalMessage.java | 4 +-
.../network/serialization/BrokenFieldAccessor.java | 4 +-
.../serialization/BrokenSerializationMethods.java | 4 +-
.../network/serialization/BuiltInType.java | 6 +-
.../network/serialization/BuiltInTypeIds.java | 4 +-
.../network/serialization/ClassDescriptor.java | 4 +-
.../serialization/ClassDescriptorFactory.java | 4 +-
.../serialization/ClassDescriptorMerger.java | 4 +-
.../serialization/ClassDescriptorRegistry.java | 4 +-
.../serialization/ClassIndexedDescriptors.java | 4 +-
.../ClassNameMapBackedClassIndexedDescriptors.java | 4 +-
.../internal/network/serialization/Classes.java | 4 +-
.../serialization/CompositeDescriptorRegistry.java | 4 +-
.../network/serialization/DeclaredType.java | 4 +-
.../network/serialization/DescriptorRegistry.java | 4 +-
.../network/serialization/FieldAccessor.java | 4 +-
.../network/serialization/FieldDescriptor.java | 4 +-
.../serialization/IdIndexedDescriptors.java | 4 +-
.../MapBackedIdIndexedDescriptors.java | 4 +-
.../network/serialization/MergedField.java | 4 +-
.../network/serialization/MergedLayer.java | 4 +-
.../internal/network/serialization/Null.java | 4 +-
.../PerSessionSerializationService.java | 4 +-
.../internal/network/serialization/Primitives.java | 4 +-
.../network/serialization/ReflectionException.java | 4 +-
.../network/serialization/Serialization.java | 4 +-
.../serialization/SerializationException.java | 4 +-
.../network/serialization/SerializationResult.java | 4 +-
.../serialization/SerializationService.java | 4 +-
.../network/serialization/SerializationType.java | 4 +-
.../SpecialMethodInvocationException.java | 4 +-
.../serialization/SpecialSerializationMethods.java | 4 +-
.../SpecialSerializationMethodsImpl.java | 4 +-
.../network/serialization/UnsafeFieldAccessor.java | 4 +-
.../UserObjectSerializationContext.java | 4 +-
.../UserObjectSerializationException.java | 4 +-
.../marshal/BestEffortInstantiation.java | 4 +-
.../marshal/BuiltInContainerMarshallers.java | 4 +-
.../serialization/marshal/BuiltInMarshalling.java | 4 +-
.../marshal/BuiltInNonContainerMarshallers.java | 4 +-
.../marshal/DefaultFieldsReaderWriter.java | 4 +-
.../marshal/DefaultNullsBitsetWriter.java | 4 +-
.../marshal/DefaultSchemaMismatchHandler.java | 4 +-
.../marshal/DefaultUserObjectMarshaller.java | 4 +-
.../serialization/marshal/DescribedObject.java | 4 +-
.../marshal/ExternalizableMarshaller.java | 4 +-
.../serialization/marshal/FlaggedObjectIds.java | 4 +-
.../serialization/marshal/Instantiation.java | 4 +-
.../marshal/InstantiationException.java | 4 +-
.../serialization/marshal/LittleEndianBits.java | 4 +-
.../serialization/marshal/LocalDescriptors.java | 4 +-
.../serialization/marshal/MarshalException.java | 4 +-
.../serialization/marshal/MarshalledObject.java | 4 +-
.../serialization/marshal/MarshallingContext.java | 4 +-
.../marshal/MarshallingNotSupportedException.java | 4 +-
.../marshal/MarshallingValidations.java | 4 +-
.../marshal/NoArgConstructorInstantiation.java | 4 +-
.../serialization/marshal/NullsBitsetReader.java | 4 +-
.../serialization/marshal/NullsBitsetWriter.java | 4 +-
.../network/serialization/marshal/ObjectClass.java | 4 +-
.../serialization/marshal/ProtocolMarshalling.java | 4 +-
.../serialization/marshal/ProxyMarshaller.java | 4 +-
.../serialization/marshal/ReadResolver.java | 4 +-
.../marshal/SchemaMismatchEventSource.java | 4 +-
.../marshal/SchemaMismatchException.java | 4 +-
.../marshal/SchemaMismatchHandler.java | 4 +-
.../marshal/SchemaMismatchHandlers.java | 4 +-
.../marshal/SerializableInstantiation.java | 4 +-
.../marshal/StructuredObjectMarshaller.java | 4 +-
.../serialization/marshal/TypedValueReader.java | 4 +-
.../serialization/marshal/TypedValueWriter.java | 4 +-
.../marshal/UncheckedMarshalException.java | 4 +-
.../marshal/UncheckedUnmarshalException.java | 4 +-
.../serialization/marshal/UnmarshalException.java | 4 +-
.../marshal/UnmarshallingContext.java | 4 +-
.../serialization/marshal/UnsafeInstantiation.java | 4 +-
.../marshal/UosIgniteOutputStream.java | 4 +-
.../marshal/UosObjectInputStream.java | 4 +-
.../marshal/UosObjectOutputStream.java | 4 +-
.../marshal/UserObjectMarshaller.java | 4 +-
.../network/serialization/marshal/ValueReader.java | 4 +-
.../network/serialization/marshal/ValueWriter.java | 4 +-
.../serialization/marshal/WriteReplacer.java | 4 +-
.../ignite/network/DefaultMessagingService.java | 4 +-
.../network/MessageSerializationRegistryImpl.java | 4 +-
.../ignite/network/NettyBootstrapFactory.java | 4 +-
.../apache/ignite/network/NodeFinderFactory.java | 4 +-
.../apache/ignite/network/OutNetworkObject.java | 4 +-
.../apache/ignite/network/StaticNodeFinder.java | 4 +-
.../org/apache/ignite/network/package-info.java | 4 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 4 +-
.../ScaleCubeDirectMarshallerTransport.java | 4 +-
.../scalecube/ScaleCubeTopologyService.java | 4 +-
.../ignite/network/scalecube/package-info.java | 4 +-
.../ignite/internal/network/AllTypesMessage.java | 4 +-
.../internal/network/AllTypesMessageGenerator.java | 4 +-
.../internal/network/AllTypesMessageTest.java | 4 +-
.../internal/network/NestedMessageMessage.java | 4 +-
.../network/SerializationMicroBenchmark.java | 4 +-
.../ignite/internal/network/UosProfilerTarget.java | 4 +-
.../internal/network/netty/InboundDecoderTest.java | 4 +-
.../netty/IoExceptionSuppressingHandlerTest.java | 4 +-
.../internal/network/netty/NettyClientTest.java | 4 +-
.../internal/network/netty/NettyServerTest.java | 4 +-
.../network/netty/RecoveryHandshakeTest.java | 4 +-
.../internal/network/processor/EmptyMessage.java | 4 +-
.../network/processor/EmptyMessageTest.java | 4 +-
.../network/processor/InheritedMessage.java | 4 +-
.../network/processor/InheritedMessageTest.java | 4 +-
.../network/processor/NetworkMessage1.java | 4 +-
.../network/processor/NetworkMessage2.java | 4 +-
.../processor/SerializationOrderMessage.java | 4 +-
.../network/processor/SerializationOrderTest.java | 4 +-
.../serialization/BuiltInDescriptorsTest.java | 4 +-
.../network/serialization/BuiltInTypeTest.java | 4 +-
.../serialization/ClassDescriptorFactoryTest.java | 4 +-
.../serialization/ClassDescriptorMergerTest.java | 4 +-
...ssNameMapBackedClassIndexedDescriptorsTest.java | 4 +-
.../network/serialization/ClassesTest.java | 4 +-
.../MapBackedIdIndexedDescriptorsTest.java | 4 +-
.../network/serialization/MarshallableTest.java | 4 +-
.../serialization/MessageWithMarshallable.java | 4 +-
.../network/serialization/PrimitivesTest.java | 4 +-
.../serialization/SimpleSerializableObject.java | 4 +-
.../marshal/BestEffortInstantiationTest.java | 4 +-
.../marshal/BuiltInMarshallingTest.java | 4 +-
.../marshal/ContextBasedIdIndexedDescriptors.java | 4 +-
.../marshal/DefaultSchemaMismatchHandlerTest.java | 4 +-
.../DefaultUserObjectMarshallerCommonTest.java | 4 +-
...rConcreteTypesKnownUpfrontOptimizationTest.java | 4 +-
...erObjectMarshallerWithArbitraryObjectsTest.java | 4 +-
...efaultUserObjectMarshallerWithBuiltinsTest.java | 4 +-
...UserObjectMarshallerWithExternalizableTest.java | 4 +-
...ltUserObjectMarshallerWithSchemaChangeTest.java | 4 +-
...shallerWithSerializableOverrideStreamsTest.java | 4 +-
...ltUserObjectMarshallerWithSerializableTest.java | 4 +-
.../marshal/EnumWithAnonClassesForMembers.java | 4 +-
.../marshal/FlaggedObjectIdsTest.java | 4 +-
.../network/serialization/marshal/IntHolder.java | 4 +-
.../marshal/MarshallingContextTest.java | 4 +-
.../marshal/NoArgConstructorInstantiationTest.java | 4 +-
.../NonSerializableWithoutNoArgConstructor.java | 4 +-
.../marshal/ProtocolMarshallingTest.java | 4 +-
.../marshal/SerializableInstantiationTest.java | 4 +-
.../network/serialization/marshal/SimpleEnum.java | 4 +-
.../serialization/marshal/TestDescriptors.java | 4 +-
.../network/serialization/marshal/Throwables.java | 4 +-
.../marshal/UnsafeInstantiationTest.java | 4 +-
.../marshal/WithAccessibleNoArgConstructor.java | 4 +-
.../marshal/WithPrivateNoArgConstructor.java | 4 +-
.../network/AbstractMessagingServiceTest.java | 4 +-
.../MessageSerializationRegistryImplTest.java | 4 +-
.../org/apache/ignite/network/TestMessage.java | 4 +-
.../TestMessageSerializationRegistryImpl.java | 4 +-
.../apache/ignite/network/TestMessageTypes.java | 4 +-
.../TestScaleCubeClusterServiceFactory.java | 4 +-
.../ignite/utils/ClusterServiceTestUtils.java | 4 +-
modules/page-memory/build.gradle | 10 +-
.../tree/AbstractBplusTreePageMemoryTest.java | 6 +-
.../tree/AbstractBplusTreeReusePageMemoryTest.java | 4 +-
.../tree/ItBplusTreeReplaceRemoveRaceTest.java | 4 +-
...ItBplusTreeFakeReuseVolatilePageMemoryTest.java | 4 +-
...ItBplusTreeReuseListVolatilePageMemoryTest.java | 4 +-
.../ItBplusTreeVolatilePageMemoryTest.java | 4 +-
.../ItBplusTreePersistentPageMemoryTest.java | 4 +-
...BplusTreeReuseListPersistentPageMemoryTest.java | 4 +-
.../CorruptedDataStructureException.java | 4 +-
.../ignite/internal/pagememory/DataRegion.java | 4 +-
.../ignite/internal/pagememory/FullPageId.java | 4 +-
.../internal/pagememory/PageIdAllocator.java | 4 +-
.../ignite/internal/pagememory/PageMemory.java | 4 +-
.../internal/pagememory/PageMemoryIoModule.java | 4 +-
.../ignite/internal/pagememory/PageSupport.java | 4 +-
.../ignite/internal/pagememory/Storable.java | 4 +-
...asePageMemoryDataRegionConfigurationSchema.java | 4 +-
.../schema/MemoryAllocatorConfigurationSchema.java | 4 +-
.../PageMemoryCheckpointConfigurationSchema.java | 4 +-
...entPageMemoryDataRegionConfigurationSchema.java | 4 +-
.../UnsafeMemoryAllocatorConfigurationSchema.java | 4 +-
...ilePageMemoryDataRegionConfigurationSchema.java | 4 +-
.../pagememory/datapage/DataPageReader.java | 4 +-
.../datapage/NonFragmentableDataPageReader.java | 4 +-
.../pagememory/datapage/PageMemoryTraversal.java | 4 +-
.../datapage/ReadPageMemoryRowValue.java | 4 +-
.../pagememory/datastructure/DataStructure.java | 4 +-
.../pagememory/evict/PageEvictionTracker.java | 4 +-
.../pagememory/evict/PageEvictionTrackerNoOp.java | 4 +-
.../pagememory/freelist/AbstractFreeList.java | 4 +-
.../freelist/CorruptedFreeListException.java | 4 +-
.../internal/pagememory/freelist/FreeList.java | 4 +-
.../internal/pagememory/freelist/PagesList.java | 4 +-
.../pagememory/freelist/io/PagesListMetaIo.java | 4 +-
.../pagememory/freelist/io/PagesListNodeIo.java | 4 +-
.../pagememory/inmemory/VolatilePageMemory.java | 4 +-
.../internal/pagememory/io/AbstractDataPageIo.java | 4 +-
.../internal/pagememory/io/DataPagePayload.java | 4 +-
.../ignite/internal/pagememory/io/IoVersions.java | 4 +-
.../ignite/internal/pagememory/io/PageIo.java | 4 +-
.../internal/pagememory/io/PageIoModule.java | 4 +-
.../internal/pagememory/io/PageIoRegistry.java | 4 +-
.../pagememory/mem/DirectMemoryProvider.java | 4 +-
.../pagememory/mem/DirectMemoryRegion.java | 4 +-
.../pagememory/mem/IgniteOutOfMemoryException.java | 4 +-
.../internal/pagememory/mem/MemoryAllocator.java | 4 +-
.../pagememory/mem/unsafe/UnsafeChunk.java | 4 +-
.../mem/unsafe/UnsafeMemoryAllocator.java | 4 +-
.../mem/unsafe/UnsafeMemoryProvider.java | 4 +-
.../pagememory/metric/IoStatisticsHolder.java | 5 +-
.../pagememory/metric/IoStatisticsHolderNoOp.java | 4 +-
.../internal/pagememory/persistence/FastCrc.java | 4 +-
.../pagememory/persistence/GroupPartitionId.java | 4 +-
...iteInternalDataIntegrityViolationException.java | 4 +-
.../pagememory/persistence/LoadedPagesMap.java | 4 +-
.../pagememory/persistence/PageHeader.java | 4 +-
.../internal/pagememory/persistence/PagePool.java | 4 +-
.../persistence/PageReadWriteManager.java | 4 +-
.../pagememory/persistence/PageStoreWriter.java | 4 +-
.../pagememory/persistence/PartitionMeta.java | 4 +-
.../persistence/PartitionMetaManager.java | 4 +-
.../persistence/PersistentPageMemory.java | 4 +-
.../pagememory/persistence/ReplaceCandidate.java | 4 +-
.../persistence/RobinHoodBackwardShiftHashMap.java | 4 +-
.../pagememory/persistence/WriteDirtyPage.java | 4 +-
.../checkpoint/AwaitTasksCompletionExecutor.java | 8 +-
.../persistence/checkpoint/Checkpoint.java | 4 +-
.../checkpoint/CheckpointDirtyPages.java | 4 +-
.../persistence/checkpoint/CheckpointListener.java | 4 +-
.../persistence/checkpoint/CheckpointManager.java | 4 +-
.../checkpoint/CheckpointMetricsTracker.java | 4 +-
.../persistence/checkpoint/CheckpointPages.java | 4 +-
.../checkpoint/CheckpointPagesWriter.java | 4 +-
.../checkpoint/CheckpointPagesWriterFactory.java | 4 +-
.../persistence/checkpoint/CheckpointProgress.java | 4 +-
.../checkpoint/CheckpointProgressImpl.java | 4 +-
.../CheckpointReadLockTimeoutException.java | 4 +-
.../checkpoint/CheckpointReadWriteLock.java | 4 +-
.../persistence/checkpoint/CheckpointState.java | 4 +-
.../checkpoint/CheckpointTimeoutLock.java | 4 +-
.../persistence/checkpoint/CheckpointWorkflow.java | 4 +-
.../persistence/checkpoint/Checkpointer.java | 4 +-
.../checkpoint/DataRegionDirtyPages.java | 4 +-
.../checkpoint/DataRegionsDirtyPages.java | 4 +-
.../ReentrantReadWriteLockWithTracking.java | 4 +-
.../persistence/compaction/Compactor.java | 4 +-
.../pagememory/persistence/io/PartitionMetaIo.java | 4 +-
.../replacement/ClockPageReplacementFlags.java | 4 +-
.../replacement/ClockPageReplacementPolicy.java | 4 +-
.../ClockPageReplacementPolicyFactory.java | 4 +-
.../replacement/DelayedDirtyPageWrite.java | 4 +-
.../replacement/DelayedPageReplacementTracker.java | 4 +-
.../replacement/PageReplacementPolicy.java | 4 +-
.../replacement/PageReplacementPolicyFactory.java | 4 +-
.../RandomLruPageReplacementPolicy.java | 4 +-
.../RandomLruPageReplacementPolicyFactory.java | 4 +-
.../replacement/SegmentedLruPageList.java | 4 +-
.../SegmentedLruPageReplacementPolicy.java | 4 +-
.../SegmentedLruPageReplacementPolicyFactory.java | 4 +-
.../persistence/store/AbstractFilePageStoreIo.java | 4 +-
.../persistence/store/DeltaFilePageStoreIo.java | 4 +-
.../store/DeltaFilePageStoreIoHeader.java | 4 +-
.../persistence/store/FilePageStore.java | 4 +-
.../persistence/store/FilePageStoreFactory.java | 4 +-
.../persistence/store/FilePageStoreHeader.java | 4 +-
.../persistence/store/FilePageStoreIo.java | 4 +-
.../persistence/store/FilePageStoreManager.java | 4 +-
.../persistence/store/GroupPageStoresMap.java | 4 +-
.../store/LongOperationAsyncExecutor.java | 4 +-
.../persistence/store/PageAllocationListener.java | 4 +-
.../pagememory/persistence/store/PageStore.java | 4 +-
.../persistence/store/PageStoreUtils.java | 4 +-
.../pagememory/reuse/LongListReuseBag.java | 4 +-
.../ignite/internal/pagememory/reuse/ReuseBag.java | 4 +-
.../internal/pagememory/reuse/ReuseList.java | 4 +-
.../internal/pagememory/reuse/ReuseListImpl.java | 4 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 79 +-
.../pagememory/tree/BplusTreeRuntimeException.java | 4 +-
.../pagememory/tree/CorruptedTreeException.java | 4 +-
.../internal/pagememory/tree/IgniteTree.java | 4 +-
.../pagememory/tree/IgniteTreePrinter.java | 4 +-
.../internal/pagememory/tree/io/BplusInnerIo.java | 4 +-
.../internal/pagememory/tree/io/BplusIo.java | 6 +-
.../internal/pagememory/tree/io/BplusLeafIo.java | 4 +-
.../internal/pagememory/tree/io/BplusMetaIo.java | 4 +-
.../internal/pagememory/util/PageHandler.java | 4 +-
.../internal/pagememory/util/PageIdUtils.java | 4 +-
.../internal/pagememory/util/PageLockListener.java | 4 +-
.../pagememory/util/PageLockListenerNoOp.java | 4 +-
.../ignite/internal/pagememory/util/PageUtils.java | 4 +-
.../pagememory/util/PartitionlessLinks.java | 4 +-
.../AbstractPageMemoryNoLoadSelfTest.java | 4 +-
.../internal/pagememory/PageIoRegistryTest.java | 4 +-
.../internal/pagememory/TestPageIoModule.java | 4 +-
.../internal/pagememory/TestPageIoRegistry.java | 4 +-
.../pagememory/freelist/AbstractFreeListTest.java | 4 +-
.../pagememory/freelist/TestDataPageIo.java | 4 +-
.../internal/pagememory/freelist/TestDataRow.java | 4 +-
.../inmemory/VolatilePageMemoryNoLoadSelfTest.java | 4 +-
.../pagememory/persistence/FastCrcTest.java | 4 +-
.../persistence/PartitionMetaManagerTest.java | 4 +-
.../pagememory/persistence/PartitionMetaTest.java | 4 +-
.../PersistentPageMemoryNoLoadTest.java | 4 +-
.../persistence/TestPageReadWriteManager.java | 4 +-
.../AwaitTasksCompletionExecutorTest.java | 4 +-
.../checkpoint/CheckpointDirtyPagesTest.java | 4 +-
.../checkpoint/CheckpointManagerTest.java | 4 +-
.../checkpoint/CheckpointMetricsTrackerTest.java | 4 +-
.../checkpoint/CheckpointPagesTest.java | 4 +-
.../checkpoint/CheckpointPagesWriterTest.java | 4 +-
.../checkpoint/CheckpointProgressImplTest.java | 4 +-
.../checkpoint/CheckpointReadWriteLockTest.java | 4 +-
.../persistence/checkpoint/CheckpointTest.java | 4 +-
.../checkpoint/CheckpointTestUtils.java | 4 +-
.../checkpoint/CheckpointTimeoutLockTest.java | 4 +-
.../checkpoint/CheckpointWorkflowTest.java | 4 +-
.../persistence/checkpoint/CheckpointerTest.java | 4 +-
.../ReentrantReadWriteLockWithTrackingTest.java | 4 +-
.../persistence/compaction/CompactorTest.java | 4 +-
.../store/AbstractFilePageStoreIoTest.java | 4 +-
.../store/DeltaFilePageStoreIoHeaderTest.java | 4 +-
.../store/DeltaFilePageStoreIoTest.java | 4 +-
.../store/FilePageStoreFactoryTest.java | 4 +-
.../persistence/store/FilePageStoreHeaderTest.java | 4 +-
.../persistence/store/FilePageStoreIoTest.java | 4 +-
.../store/FilePageStoreManagerTest.java | 4 +-
.../persistence/store/FilePageStoreTest.java | 4 +-
.../persistence/store/GroupPageStoresMapTest.java | 4 +-
.../store/LongOperationAsyncExecutorTest.java | 4 +-
.../persistence/store/PageStoreUtilsTest.java | 4 +-
.../persistence/store/TestPageStoreUtils.java | 4 +-
.../internal/pagememory/util/PageIdUtilsTest.java | 4 +-
.../internal/pagememory/util/PageUtilsTest.java | 4 +-
modules/platforms/build.gradle | 4 +-
modules/platforms/cpp/CMakeLists.txt | 13 +-
modules/platforms/cpp/common/Bits.h | 169 ++
modules/platforms/cpp/common/Bytes.h | 406 +++
modules/platforms/cpp/common/CMakeLists.txt | 6 +-
modules/platforms/cpp/common/Config.h | 51 +
modules/platforms/cpp/common/Types.h | 4 +-
modules/platforms/cpp/common/Uuid.h | 248 ++
.../platforms/cpp/schema/BinaryTupleBuilder.cpp | 4 +-
modules/platforms/cpp/schema/BinaryTupleBuilder.h | 4 +-
modules/platforms/cpp/schema/BinaryTupleHeader.h | 4 +-
modules/platforms/cpp/schema/BinaryTupleParser.cpp | 4 +-
modules/platforms/cpp/schema/BinaryTupleParser.h | 4 +-
modules/platforms/cpp/schema/BinaryTupleSchema.h | 4 +-
modules/platforms/cpp/schema/CMakeLists.txt | 4 +-
modules/platforms/cpp/schema/ColumnInfo.h | 4 +-
modules/platforms/cpp/schema/DataType.cpp | 4 +-
modules/platforms/cpp/schema/DataType.h | 4 +-
modules/platforms/cpp/tests/CMakeLists.txt | 49 +
modules/platforms/cpp/tests/testBits.cpp | 434 ++++
modules/platforms/cpp/tests/testBytes.cpp | 363 +++
modules/platforms/cpp/tests/testUuid.cpp | 66 +
.../SerializerHandlerBenchmarksBase.cs | 4 +-
.../SerializerHandlerReadBenchmarks.cs | 40 +-
.../SerializerHandlerWriteBenchmarks.cs | 13 +-
.../Apache.Ignite.Internal.Generators.csproj | 41 +
.../ErrorGroupsGenerator.cs | 153 ++
.../ExceptionTemplate.cs | 60 +
.../ExceptionsGenerator.cs | 177 ++
.../GeneratorUtils.cs | 37 +
.../platforms/dotnet/Apache.Ignite.Tests.ruleset | 3 +
.../Apache.Ignite.Tests/ClientSocketTests.cs | 2 +-
.../Compute/ComputeClusterAwarenessTests.cs | 2 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 19 +-
.../dotnet/Apache.Ignite.Tests/ErrorGroupTests.cs | 196 ++
.../dotnet/Apache.Ignite.Tests/ExceptionsTests.cs | 101 +
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 5 +-
.../dotnet/Apache.Ignite.Tests/FakeServerTests.cs | 8 +-
.../Apache.Ignite.Tests/ProjectFilesTests.cs | 1 +
.../Proto/BinaryTuple/BinaryTupleTests.cs | 86 +-
.../dotnet/Apache.Ignite.Tests/RetryPolicyTests.cs | 16 +-
.../Apache.Ignite.Tests/Sql/SqlStatementTests.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 45 +-
.../dotnet/Apache.Ignite.Tests/StringExtensions.cs | 30 +
.../Table/CustomTestIgniteTuple.cs | 2 +-
.../Apache.Ignite.Tests/Table/IgniteTupleTests.cs | 10 +-
.../dotnet/Apache.Ignite.Tests/Table/Poco2.cs | 44 +
.../Table/RecordViewBinaryTests.cs | 2 +-
.../Table/RecordViewPocoTests.cs | 47 +-
.../Serialization/ObjectSerializerHandlerTests.cs | 51 +-
modules/platforms/dotnet/Apache.Ignite.sln | 6 +
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 7 +
.../platforms/dotnet/Apache.Ignite/ErrorGroups.cs | 68 +
.../IgniteClientConnectionException.cs | 70 +
.../dotnet/Apache.Ignite/IgniteClientException.cs | 80 +-
.../dotnet/Apache.Ignite/IgniteException.cs | 97 +
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 11 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 28 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 5 +-
.../dotnet/Apache.Ignite/Internal/Endpoint.cs | 7 +-
.../Proto/BinaryTuple/BinaryTupleBuilder.cs | 104 +-
.../Proto/BinaryTuple/BinaryTupleCommon.cs | 15 +-
.../Proto/BinaryTuple/BinaryTupleReader.cs | 43 +-
.../Internal/Proto/MessagePackReaderExtensions.cs | 18 +-
.../Internal/Proto/MessagePackWriterExtensions.cs | 22 +-
.../dotnet/Apache.Ignite/Internal/Sql/ResultSet.cs | 10 +-
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 1 -
.../Serialization/BinaryTupleBuilderExtensions.cs | 39 +
.../Table/Serialization/BinaryTupleMethods.cs | 99 +
.../Table/Serialization/ByteSpanExtensions.cs | 34 +
.../Table/Serialization/MessagePackMethods.cs | 131 -
.../Table/Serialization/ObjectSerializerHandler.cs | 125 +-
.../Table/Serialization/TupleSerializerHandler.cs | 50 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 2 +-
.../dotnet/Apache.Ignite/Sql/SqlStatement.cs | 12 +-
.../dotnet/Apache.Ignite/Table/IgniteTuple.cs | 12 +-
modules/platforms/dotnet/DEVNOTES.md | 3 +-
modules/platforms/dotnet/Directory.Build.props | 2 +-
modules/raft-client/build.gradle | 12 +-
.../org/apache/ignite/raft/client/Command.java | 6 +-
.../ignite/raft/client/ElectionPriority.java | 6 +-
.../java/org/apache/ignite/raft/client/Peer.java | 6 +-
.../org/apache/ignite/raft/client/ReadCommand.java | 6 +-
.../apache/ignite/raft/client/WriteCommand.java | 6 +-
.../ignite/raft/client/service/CommandClosure.java | 6 +-
.../raft/client/service/RaftGroupListener.java | 4 +-
.../raft/client/service/RaftGroupService.java | 4 +-
modules/raft/build.gradle | 10 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 4 +-
.../internal/raft/ItRaftGroupServiceTest.java | 2 +-
.../service/ItAbstractListenerSnapshotTest.java | 443 ----
.../ignite/raft/jraft/core/ItCliServiceTest.java | 6 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 6 +-
.../apache/ignite/raft/server/CounterListener.java | 131 -
.../ignite/raft/server/CounterSnapshotFile.java | 85 -
.../apache/ignite/raft/server/GetValueCommand.java | 26 -
.../ignite/raft/server/IncrementAndGetCommand.java | 46 -
.../raft/server/ItJraftCounterServerTest.java | 147 +-
.../raft/server/ItSimpleCounterServerTest.java | 7 +-
.../ignite/raft/server/RaftServerAbstractTest.java | 4 +-
.../raft/server/counter/CounterListener.java | 131 +
.../raft/server/counter/CounterSnapshotFile.java | 85 +
.../raft/server/counter/GetValueCommand.java | 26 +
.../server/counter/IncrementAndGetCommand.java | 46 +
.../snasphot/SnapshotInMemoryStorageFactory.java | 194 ++
.../raft/server/snasphot/TestWriteCommand.java | 26 +
.../server/snasphot/UpdateCountRaftListener.java | 104 +
.../internal/raft/CoreLogStorageBudgetsModule.java | 4 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 4 +-
.../raft/server/RaftGroupEventsListener.java | 6 +-
.../internal/raft/server/RaftGroupOptions.java | 6 +-
.../ignite/internal/raft/server/RaftServer.java | 6 +-
.../internal/raft/server/impl/JraftServerImpl.java | 6 +-
.../internal/raft/storage/LogStorageFactory.java | 2 +-
.../raft/storage/RaftMetaStorageFactory.java | 2 +-
.../raft/storage/SnapshotStorageFactory.java | 2 +-
.../storage/impl/DefaultLogStorageFactory.java | 2 +-
.../storage/impl/IgniteJraftServiceFactory.java | 2 +-
.../raft/storage/impl/LocalLogStorageFactory.java | 6 +-
.../storage/impl/LogStorageFactoryCreator.java | 6 +-
.../raft/storage/impl/RocksDbSharedLogStorage.java | 2 +-
.../storage/impl/VolatileLogStorageFactory.java | 2 +-
.../impl/VolatileLogStorageFactoryCreator.java | 6 +-
.../org/apache/ignite/raft/jraft/CliService.java | 6 +-
.../java/org/apache/ignite/raft/jraft/Closure.java | 6 +-
.../org/apache/ignite/raft/jraft/FSMCaller.java | 11 +-
.../org/apache/ignite/raft/jraft/Iterator.java | 6 +-
.../ignite/raft/jraft/JRaftServiceFactory.java | 6 +-
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 6 +-
.../org/apache/ignite/raft/jraft/Lifecycle.java | 6 +-
.../java/org/apache/ignite/raft/jraft/Node.java | 6 +-
.../org/apache/ignite/raft/jraft/NodeManager.java | 6 +-
.../apache/ignite/raft/jraft/RaftGroupService.java | 6 +-
.../apache/ignite/raft/jraft/RaftMessageGroup.java | 4 +-
.../apache/ignite/raft/jraft/ReadOnlyService.java | 6 +-
.../apache/ignite/raft/jraft/ReplicatorGroup.java | 6 +-
.../org/apache/ignite/raft/jraft/StateMachine.java | 6 +-
.../java/org/apache/ignite/raft/jraft/Status.java | 6 +-
.../raft/jraft/ThreadPoolMetricsSignalHandler.java | 6 +-
.../ignite/raft/jraft/closure/CatchUpClosure.java | 6 +-
.../ignite/raft/jraft/closure/ClosureQueue.java | 6 +-
.../raft/jraft/closure/ClosureQueueImpl.java | 6 +-
.../ignite/raft/jraft/closure/JoinableClosure.java | 6 +-
.../raft/jraft/closure/LoadSnapshotClosure.java | 6 +-
.../raft/jraft/closure/ReadIndexClosure.java | 6 +-
.../raft/jraft/closure/SaveSnapshotClosure.java | 6 +-
.../raft/jraft/closure/SynchronizedClosure.java | 6 +-
.../ignite/raft/jraft/closure/TaskClosure.java | 6 +-
.../ignite/raft/jraft/conf/Configuration.java | 6 +-
.../ignite/raft/jraft/conf/ConfigurationEntry.java | 6 +-
.../raft/jraft/conf/ConfigurationManager.java | 6 +-
.../apache/ignite/raft/jraft/core/BallotBox.java | 8 +-
.../ignite/raft/jraft/core/CliServiceImpl.java | 6 +-
.../jraft/core/DefaultJRaftServiceFactory.java | 6 +-
.../ignite/raft/jraft/core/ElectionPriority.java | 6 +-
.../ignite/raft/jraft/core/FSMCallerImpl.java | 11 +-
.../ignite/raft/jraft/core/IteratorImpl.java | 6 +-
.../ignite/raft/jraft/core/IteratorWrapper.java | 6 +-
.../raft/jraft/core/LogStorageBudgetFactory.java | 4 +-
.../raft/jraft/core/LogStorageBudgetsModule.java | 4 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 34 +-
.../apache/ignite/raft/jraft/core/NodeMetrics.java | 6 +-
.../raft/jraft/core/ReadOnlyServiceImpl.java | 6 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 6 +-
.../raft/jraft/core/ReplicatorGroupImpl.java | 6 +-
.../ignite/raft/jraft/core/ReplicatorType.java | 6 +-
.../apache/ignite/raft/jraft/core/Scheduler.java | 6 +-
.../org/apache/ignite/raft/jraft/core/State.java | 6 +-
.../raft/jraft/core/StateMachineAdapter.java | 6 +-
.../ignite/raft/jraft/core/TimerManager.java | 6 +-
.../raft/jraft/disruptor/DisruptorBuilder.java | 6 +-
.../ignite/raft/jraft/disruptor/GroupAware.java | 4 +-
.../raft/jraft/disruptor/StripedDisruptor.java | 4 +-
.../apache/ignite/raft/jraft/entity/Ballot.java | 6 +-
.../apache/ignite/raft/jraft/entity/Checksum.java | 6 +-
.../ignite/raft/jraft/entity/EnumOutter.java | 6 +-
.../raft/jraft/entity/LeaderChangeContext.java | 6 +-
.../raft/jraft/entity/LocalFileMetaOutter.java | 6 +-
.../raft/jraft/entity/LocalStorageOutter.java | 6 +-
.../apache/ignite/raft/jraft/entity/LogEntry.java | 6 +-
.../org/apache/ignite/raft/jraft/entity/LogId.java | 6 +-
.../apache/ignite/raft/jraft/entity/NodeId.java | 6 +-
.../apache/ignite/raft/jraft/entity/PeerId.java | 6 +-
.../ignite/raft/jraft/entity/RaftOutter.java | 6 +-
.../ignite/raft/jraft/entity/ReadIndexState.java | 6 +-
.../ignite/raft/jraft/entity/ReadIndexStatus.java | 6 +-
.../org/apache/ignite/raft/jraft/entity/Task.java | 6 +-
.../apache/ignite/raft/jraft/entity/UserLog.java | 6 +-
.../raft/jraft/entity/codec/AutoDetectDecoder.java | 6 +-
.../entity/codec/DefaultLogEntryCodecFactory.java | 6 +-
.../jraft/entity/codec/LogEntryCodecFactory.java | 6 +-
.../raft/jraft/entity/codec/LogEntryDecoder.java | 6 +-
.../raft/jraft/entity/codec/LogEntryEncoder.java | 6 +-
.../entity/codec/v1/LogEntryV1CodecFactory.java | 6 +-
.../raft/jraft/entity/codec/v1/V1Decoder.java | 6 +-
.../raft/jraft/entity/codec/v1/V1Encoder.java | 6 +-
.../raft/jraft/error/InvokeTimeoutException.java | 6 +-
.../ignite/raft/jraft/error/JRaftException.java | 6 +-
.../jraft/error/LogEntryCorruptedException.java | 6 +-
.../jraft/error/LogIndexOutOfBoundsException.java | 6 +-
.../raft/jraft/error/LogNotFoundException.java | 6 +-
.../jraft/error/MessageClassNotFoundException.java | 6 +-
.../apache/ignite/raft/jraft/error/RaftError.java | 6 +-
.../ignite/raft/jraft/error/RaftException.java | 6 +-
.../ignite/raft/jraft/error/RemotingException.java | 6 +-
.../raft/jraft/error/RetryAgainException.java | 6 +-
.../ignite/raft/jraft/option/BallotBoxOptions.java | 6 +-
.../ignite/raft/jraft/option/BootstrapOptions.java | 6 +-
.../ignite/raft/jraft/option/CliOptions.java | 6 +-
.../ignite/raft/jraft/option/CopyOptions.java | 6 +-
.../ignite/raft/jraft/option/FSMCallerOptions.java | 6 +-
.../raft/jraft/option/LogManagerOptions.java | 6 +-
.../raft/jraft/option/LogStorageOptions.java | 6 +-
.../ignite/raft/jraft/option/NodeOptions.java | 6 +-
.../raft/jraft/option/RaftMetaStorageOptions.java | 6 +-
.../ignite/raft/jraft/option/RaftOptions.java | 6 +-
.../ignite/raft/jraft/option/ReadOnlyOption.java | 6 +-
.../raft/jraft/option/ReadOnlyServiceOptions.java | 6 +-
.../raft/jraft/option/ReplicatorGroupOptions.java | 6 +-
.../raft/jraft/option/ReplicatorOptions.java | 6 +-
.../ignite/raft/jraft/option/RpcOptions.java | 6 +-
.../raft/jraft/option/SnapshotCopierOptions.java | 6 +-
.../raft/jraft/option/SnapshotExecutorOptions.java | 6 +-
.../ignite/raft/jraft/rpc/ActionRequest.java | 6 +-
.../ignite/raft/jraft/rpc/ActionResponse.java | 6 +-
.../ignite/raft/jraft/rpc/CliClientService.java | 6 +-
.../apache/ignite/raft/jraft/rpc/CliRequests.java | 6 +-
.../ignite/raft/jraft/rpc/ClientService.java | 6 +-
.../ignite/raft/jraft/rpc/InvokeCallback.java | 6 +-
.../ignite/raft/jraft/rpc/InvokeContext.java | 6 +-
.../org/apache/ignite/raft/jraft/rpc/Message.java | 6 +-
.../ignite/raft/jraft/rpc/RaftClientService.java | 6 +-
.../ignite/raft/jraft/rpc/RaftRpcFactory.java | 6 +-
.../ignite/raft/jraft/rpc/RaftServerService.java | 6 +-
.../apache/ignite/raft/jraft/rpc/RpcClient.java | 6 +-
.../apache/ignite/raft/jraft/rpc/RpcClientEx.java | 6 +-
.../apache/ignite/raft/jraft/rpc/RpcContext.java | 6 +-
.../apache/ignite/raft/jraft/rpc/RpcProcessor.java | 6 +-
.../ignite/raft/jraft/rpc/RpcRequestClosure.java | 6 +-
.../ignite/raft/jraft/rpc/RpcRequestProcessor.java | 6 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 6 +-
.../ignite/raft/jraft/rpc/RpcResponseClosure.java | 6 +-
.../raft/jraft/rpc/RpcResponseClosureAdapter.java | 6 +-
.../ignite/raft/jraft/rpc/RpcResponseFactory.java | 6 +-
.../apache/ignite/raft/jraft/rpc/RpcServer.java | 6 +-
.../raft/jraft/rpc/impl/AbstractClientService.java | 6 +-
.../jraft/rpc/impl/ActionRequestProcessor.java | 6 +-
.../rpc/impl/ConnectionClosedEventListener.java | 6 +-
.../ignite/raft/jraft/rpc/impl/FutureImpl.java | 6 +-
.../raft/jraft/rpc/impl/IgniteRpcClient.java | 6 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 6 +-
.../raft/jraft/rpc/impl/PingRequestProcessor.java | 6 +-
.../ignite/raft/jraft/rpc/impl/RaftException.java | 6 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 4 +-
.../raft/jraft/rpc/impl/SMCompactedThrowable.java | 6 +-
.../raft/jraft/rpc/impl/SMFullThrowable.java | 6 +-
.../ignite/raft/jraft/rpc/impl/SMThrowable.java | 6 +-
.../rpc/impl/cli/AddLearnersRequestProcessor.java | 6 +-
.../rpc/impl/cli/AddPeerRequestProcessor.java | 6 +-
.../rpc/impl/cli/BaseCliRequestProcessor.java | 6 +-
.../impl/cli/ChangePeersAsyncRequestProcessor.java | 6 +-
.../rpc/impl/cli/ChangePeersRequestProcessor.java | 6 +-
.../jraft/rpc/impl/cli/CliClientServiceImpl.java | 6 +-
.../rpc/impl/cli/GetLeaderRequestProcessor.java | 6 +-
.../rpc/impl/cli/GetPeersRequestProcessor.java | 6 +-
.../rpc/impl/cli/IgniteCliRpcRequestClosure.java | 4 +-
.../impl/cli/RemoveLearnersRequestProcessor.java | 6 +-
.../rpc/impl/cli/RemovePeerRequestProcessor.java | 6 +-
.../impl/cli/ResetLearnersRequestProcessor.java | 6 +-
.../rpc/impl/cli/ResetPeerRequestProcessor.java | 6 +-
.../rpc/impl/cli/SnapshotRequestProcessor.java | 6 +-
.../impl/cli/TransferLeaderRequestProcessor.java | 6 +-
.../impl/core/AppendEntriesRequestProcessor.java | 6 +-
.../rpc/impl/core/DefaultRaftClientService.java | 6 +-
.../rpc/impl/core/GetFileRequestProcessor.java | 6 +-
.../impl/core/InstallSnapshotRequestProcessor.java | 6 +-
.../jraft/rpc/impl/core/NodeRequestProcessor.java | 6 +-
.../rpc/impl/core/ReadIndexRequestProcessor.java | 6 +-
.../rpc/impl/core/RequestVoteRequestProcessor.java | 6 +-
.../rpc/impl/core/TimeoutNowRequestProcessor.java | 6 +-
.../ignite/raft/jraft/storage/FileService.java | 6 +-
.../ignite/raft/jraft/storage/LogManager.java | 6 +-
.../ignite/raft/jraft/storage/LogStorage.java | 6 +-
.../ignite/raft/jraft/storage/RaftMetaStorage.java | 6 +-
.../raft/jraft/storage/SnapshotExecutor.java | 6 +-
.../ignite/raft/jraft/storage/SnapshotStorage.java | 6 +-
.../raft/jraft/storage/SnapshotThrottle.java | 6 +-
.../apache/ignite/raft/jraft/storage/Storage.java | 6 +-
.../ignite/raft/jraft/storage/VolatileStorage.java | 6 +-
.../raft/jraft/storage/impl/EntryCountBudget.java | 6 +-
.../raft/jraft/storage/impl/LocalLogStorage.java | 6 +-
.../jraft/storage/impl/LocalRaftMetaStorage.java | 6 +-
.../raft/jraft/storage/impl/LogManagerImpl.java | 6 +-
.../raft/jraft/storage/impl/LogStorageBudget.java | 6 +-
.../jraft/storage/impl/LogStorageException.java | 6 +-
.../ignite/raft/jraft/storage/impl/Logs.java | 6 +-
.../ignite/raft/jraft/storage/impl/OnHeapLogs.java | 6 +-
.../raft/jraft/storage/impl/RocksDBLogStorage.java | 6 +-
.../raft/jraft/storage/impl/RocksDbSpillout.java | 2 +-
.../raft/jraft/storage/impl/UnlimitedBudget.java | 6 +-
.../jraft/storage/impl/VolatileLogStorage.java | 6 +-
.../storage/impl/VolatileRaftMetaStorage.java | 6 +-
.../ignite/raft/jraft/storage/io/FileReader.java | 6 +-
.../raft/jraft/storage/io/LocalDirReader.java | 6 +-
.../ignite/raft/jraft/storage/io/MessageFile.java | 6 +-
.../raft/jraft/storage/snapshot/Snapshot.java | 6 +-
.../jraft/storage/snapshot/SnapshotCopier.java | 6 +-
.../storage/snapshot/SnapshotExecutorImpl.java | 6 +-
.../jraft/storage/snapshot/SnapshotReader.java | 6 +-
.../jraft/storage/snapshot/SnapshotWriter.java | 6 +-
.../snapshot/ThroughputSnapshotThrottle.java | 6 +-
.../storage/snapshot/local/LocalSnapshot.java | 6 +-
.../snapshot/local/LocalSnapshotCopier.java | 6 +-
.../snapshot/local/LocalSnapshotMetaTable.java | 6 +-
.../snapshot/local/LocalSnapshotReader.java | 6 +-
.../snapshot/local/LocalSnapshotStorage.java | 6 +-
.../snapshot/local/LocalSnapshotWriter.java | 6 +-
.../storage/snapshot/local/SnapshotFileReader.java | 6 +-
.../jraft/storage/snapshot/remote/CopySession.java | 6 +-
.../storage/snapshot/remote/RemoteFileCopier.java | 6 +-
.../jraft/storage/snapshot/remote/Session.java | 6 +-
.../raft/jraft/util/AdaptiveBufAllocator.java | 6 +-
.../apache/ignite/raft/jraft/util/ArrayDeque.java | 6 +-
.../ignite/raft/jraft/util/AsciiStringUtil.java | 6 +-
.../org/apache/ignite/raft/jraft/util/Bits.java | 6 +-
.../raft/jraft/util/ByteBufferCollector.java | 6 +-
.../apache/ignite/raft/jraft/util/ByteString.java | 6 +-
.../org/apache/ignite/raft/jraft/util/Bytes.java | 6 +-
.../apache/ignite/raft/jraft/util/BytesUtil.java | 6 +-
.../org/apache/ignite/raft/jraft/util/CRC64.java | 6 +-
.../apache/ignite/raft/jraft/util/Copiable.java | 6 +-
.../ignite/raft/jraft/util/CountDownEvent.java | 6 +-
.../org/apache/ignite/raft/jraft/util/CrcUtil.java | 6 +-
.../ignite/raft/jraft/util/DebugStatistics.java | 6 +-
.../apache/ignite/raft/jraft/util/Describer.java | 6 +-
.../ignite/raft/jraft/util/DirectExecutor.java | 6 +-
.../ignite/raft/jraft/util/DisruptorMetricSet.java | 6 +-
.../apache/ignite/raft/jraft/util/Endpoint.java | 6 +-
.../raft/jraft/util/ExecutorServiceHelper.java | 6 +-
.../util/ExponentialBackoffTimeoutStrategy.java | 4 +-
.../raft/jraft/util/FileOutputSignalHandler.java | 6 +-
.../org/apache/ignite/raft/jraft/util/Ints.java | 6 +-
.../ignite/raft/jraft/util/JDKMarshaller.java | 6 +-
.../ignite/raft/jraft/util/JRaftSignalHandler.java | 6 +-
.../jraft/util/LogScheduledThreadPoolExecutor.java | 6 +-
.../raft/jraft/util/LogThreadPoolExecutor.java | 6 +-
.../apache/ignite/raft/jraft/util/Marshaller.java | 6 +-
.../ignite/raft/jraft/util/MetricReporter.java | 6 +-
.../util/MetricScheduledThreadPoolExecutor.java | 6 +-
.../raft/jraft/util/MetricThreadPoolExecutor.java | 6 +-
.../org/apache/ignite/raft/jraft/util/Mpsc.java | 6 +-
.../ignite/raft/jraft/util/NonReentrantLock.java | 2 +-
.../raft/jraft/util/NoopTimeoutStrategy.java | 4 +-
.../apache/ignite/raft/jraft/util/OnlyForTest.java | 6 +-
.../apache/ignite/raft/jraft/util/Platform.java | 6 +-
.../apache/ignite/raft/jraft/util/Recyclable.java | 6 +-
.../raft/jraft/util/RecyclableByteBufferList.java | 6 +-
.../apache/ignite/raft/jraft/util/RecycleUtil.java | 6 +-
.../apache/ignite/raft/jraft/util/Recyclers.java | 2 +-
.../ignite/raft/jraft/util/RepeatedTimer.java | 6 +-
.../apache/ignite/raft/jraft/util/Requires.java | 6 +-
.../apache/ignite/raft/jraft/util/SegmentList.java | 6 +-
.../raft/jraft/util/StorageOptionsFactory.java | 6 +-
.../apache/ignite/raft/jraft/util/StringUtils.java | 6 +-
.../ignite/raft/jraft/util/SystemPropertyUtil.java | 6 +-
.../ignite/raft/jraft/util/ThreadHelper.java | 6 +-
.../apache/ignite/raft/jraft/util/ThreadId.java | 6 +-
.../raft/jraft/util/ThreadPoolMetricRegistry.java | 6 +-
.../raft/jraft/util/ThreadPoolMetricSet.java | 6 +-
.../ignite/raft/jraft/util/ThreadPoolUtil.java | 6 +-
.../ignite/raft/jraft/util/TimeoutStrategy.java | 4 +-
.../org/apache/ignite/raft/jraft/util/Utils.java | 6 +-
.../jraft/util/concurrent/AdjustableSemaphore.java | 6 +-
.../jraft/util/concurrent/ConcurrentHashSet.java | 6 +-
.../concurrent/DefaultExecutorChooserFactory.java | 6 +-
.../DefaultFixedThreadsExecutorGroup.java | 6 +-
.../DefaultFixedThreadsExecutorGroupFactory.java | 6 +-
.../concurrent/DefaultSingleThreadExecutor.java | 6 +-
.../util/concurrent/ExecutorChooserFactory.java | 6 +-
.../util/concurrent/FixedThreadsExecutorGroup.java | 6 +-
.../FixedThreadsExecutorGroupFactory.java | 6 +-
.../concurrent/LongHeldDetectingReadWriteLock.java | 6 +-
.../util/concurrent/MpscSingleThreadExecutor.java | 6 +-
.../util/concurrent/RejectedExecutionHandler.java | 6 +-
.../util/concurrent/RejectedExecutionHandlers.java | 6 +-
.../util/concurrent/SingleThreadExecutor.java | 6 +-
.../jraft/util/internal/IntegerFieldUpdater.java | 6 +-
.../raft/jraft/util/internal/LongFieldUpdater.java | 6 +-
.../jraft/util/internal/ReferenceFieldUpdater.java | 6 +-
.../internal/ReflectionIntegerFieldUpdater.java | 6 +-
.../util/internal/ReflectionLongFieldUpdater.java | 6 +-
.../internal/ReflectionReferenceFieldUpdater.java | 6 +-
.../ignite/raft/jraft/util/internal/ThrowUtil.java | 6 +-
.../raft/jraft/util/internal/UnsafeUtil.java | 6 +-
.../ignite/raft/jraft/util/internal/Updaters.java | 6 +-
.../jraft/util/timer/DefaultRaftTimerFactory.java | 6 +-
.../ignite/raft/jraft/util/timer/DefaultTimer.java | 6 +-
.../raft/jraft/util/timer/HashedWheelTimer.java | 6 +-
.../raft/jraft/util/timer/RaftTimerFactory.java | 6 +-
.../ignite/raft/jraft/util/timer/Timeout.java | 2 +-
.../apache/ignite/raft/jraft/util/timer/Timer.java | 6 +-
.../ignite/raft/jraft/util/timer/TimerTask.java | 2 +-
.../ignite/disruptor/StripedDisruptorTest.java | 6 +-
.../raft/CoreLogStorageBudgetsModuleTest.java | 4 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 6 +-
.../internal/raft/server/impl/RaftServerImpl.java | 319 ---
.../impl/RocksDbSharedLogStorageAdvancedTest.java | 2 +-
.../storage/impl/RocksDbSharedLogStorageTest.java | 2 +-
.../impl/SharedVsNonSharedLogStorageBenchmark.java | 2 +-
.../org/apache/ignite/raft/jraft/StatusTest.java | 6 +-
.../raft/jraft/closure/ClosureQueueTest.java | 6 +-
.../jraft/closure/SynchronizedClosureTest.java | 6 +-
.../raft/jraft/conf/ConfigurationEntryTest.java | 6 +-
.../raft/jraft/conf/ConfigurationManagerTest.java | 6 +-
.../ignite/raft/jraft/conf/ConfigurationTest.java | 6 +-
.../ignite/raft/jraft/core/BallotBoxTest.java | 6 +-
.../ignite/raft/jraft/core/ExpectClosure.java | 6 +-
.../ignite/raft/jraft/core/FSMCallerTest.java | 6 +-
.../ignite/raft/jraft/core/IteratorImplTest.java | 6 +-
.../ignite/raft/jraft/core/IteratorTest.java | 6 +-
.../apache/ignite/raft/jraft/core/MockClosure.java | 6 +-
.../ignite/raft/jraft/core/MockStateMachine.java | 6 +-
.../raft/jraft/core/RaftGroupServiceTest.java | 4 +-
.../raft/jraft/core/ReadOnlyServiceTest.java | 6 +-
.../raft/jraft/core/ReplicatorGroupTest.java | 6 +-
.../ignite/raft/jraft/core/ReplicatorTest.java | 6 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 6 +-
.../raft/jraft/core/TestJRaftServiceFactory.java | 6 +-
.../ignite/raft/jraft/entity/BallotTest.java | 6 +-
.../ignite/raft/jraft/entity/LogEntryTest.java | 6 +-
.../apache/ignite/raft/jraft/entity/LogIdTest.java | 6 +-
.../ignite/raft/jraft/entity/PeerIdTest.java | 6 +-
.../entity/codec/BaseLogEntryCodecFactoryTest.java | 6 +-
.../jraft/entity/codec/LogEntryCodecPerfTest.java | 6 +-
.../codec/v1/LogEntryV1CodecFactoryTest.java | 6 +-
.../raft/jraft/rpc/AbstractClientServiceTest.java | 6 +-
.../ignite/raft/jraft/rpc/AbstractRpcTest.java | 6 +-
.../raft/jraft/rpc/AppendEntriesBenchmark.java | 6 +-
.../ignite/raft/jraft/rpc/IgniteRpcTest.java | 6 +-
.../raft/jraft/rpc/RpcResponseFactoryTest.java | 6 +-
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 6 +-
.../ignite/raft/jraft/rpc/TestMessageGroup.java | 4 +-
.../ignite/raft/jraft/rpc/impl/FutureTest.java | 6 +-
.../jraft/rpc/impl/PingRequestProcessorTest.java | 6 +-
.../impl/cli/AbstractCliRequestProcessorTest.java | 6 +-
.../impl/cli/AddLearnersRequestProcessorTest.java | 6 +-
.../rpc/impl/cli/AddPeerRequestProcessorTest.java | 6 +-
.../rpc/impl/cli/BaseCliRequestProcessorTest.java | 6 +-
.../cli/ChangePeersAsyncRequestProcessorTest.java | 6 +-
.../impl/cli/ChangePeersRequestProcessorTest.java | 6 +-
.../rpc/impl/cli/GetPeersRequestProcessorTest.java | 6 +-
.../cli/RemoveLearnersRequestProcessorTest.java | 6 +-
.../impl/cli/RemovePeerRequestProcessorTest.java | 6 +-
.../cli/ResetLearnersRequestProcessorTest.java | 6 +-
.../impl/cli/ResetPeersRequestProcessorTest.java | 6 +-
.../rpc/impl/cli/SnapshotRequestProcessorTest.java | 6 +-
.../TransferLeadershipRequestProcessorTest.java | 6 +-
.../core/AppendEntriesRequestProcessorTest.java | 6 +-
.../impl/core/BaseNodeRequestProcessorTest.java | 6 +-
.../core/InstallSnapshotRequestProcessorTest.java | 6 +-
.../rpc/impl/core/NodeRequestProcessorTest.java | 6 +-
.../rpc/impl/core/PreVoteRequestProcessorTest.java | 6 +-
.../impl/core/ReadIndexRequestProcessorTest.java | 6 +-
.../impl/core/RequestVoteRequestProcessorTest.java | 6 +-
.../impl/core/TimeoutNowRequestProcessorTest.java | 6 +-
.../ignite/raft/jraft/storage/BaseStorageTest.java | 6 +-
.../ignite/raft/jraft/storage/FileServiceTest.java | 6 +-
.../raft/jraft/storage/SnapshotExecutorTest.java | 6 +-
.../jraft/storage/impl/BaseLogStorageTest.java | 6 +-
.../jraft/storage/impl/EntryCountBudgetTest.java | 6 +-
.../jraft/storage/impl/LocalLogStorageTest.java | 6 +-
.../storage/impl/LocalRaftMetaStorageTest.java | 6 +-
.../raft/jraft/storage/impl/LogManagerTest.java | 6 +-
.../jraft/storage/impl/LogStorageBenchmark.java | 6 +-
.../jraft/storage/impl/RocksDBLogManagerTest.java | 6 +-
.../jraft/storage/impl/RocksDBLogStorageTest.java | 6 +-
.../jraft/storage/impl/UnlimitedBudgetTest.java | 6 +-
.../impl/VolatileLogStorageBudgetingTest.java | 6 +-
.../impl/VolatileLogStorageSpecificsTest.java | 6 +-
.../jraft/storage/impl/VolatileLogStorageTest.java | 6 +-
.../storage/impl/VolatileRaftMetaStorageTest.java | 6 +-
.../raft/jraft/storage/io/LocalFileReaderTest.java | 6 +-
.../raft/jraft/storage/io/MessageFileTest.java | 6 +-
.../snapshot/ThroughputSnapshotThrottleTest.java | 6 +-
.../snapshot/local/LocalSnapshotCopierTest.java | 6 +-
.../snapshot/local/LocalSnapshotMetaTableTest.java | 6 +-
.../snapshot/local/LocalSnapshotReaderTest.java | 6 +-
.../snapshot/local/LocalSnapshotStorageTest.java | 6 +-
.../snapshot/local/LocalSnapshotWriterTest.java | 6 +-
.../snapshot/local/SnapshotFileReaderTest.java | 6 +-
.../storage/snapshot/remote/CopySessionTest.java | 6 +-
.../snapshot/remote/RemoteFileCopierTest.java | 6 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 6 +-
.../raft/jraft/util/AdaptiveBufAllocatorTest.java | 6 +-
.../ignite/raft/jraft/util/ArrayDequeTest.java | 6 +-
.../raft/jraft/util/AsciiCodecBenchmark.java | 6 +-
.../raft/jraft/util/AsciiStringUtilTest.java | 6 +-
.../apache/ignite/raft/jraft/util/BitsTest.java | 6 +-
.../raft/jraft/util/ByteBufferCollectorTest.java | 6 +-
.../ignite/raft/jraft/util/BytesUtilTest.java | 6 +-
.../ignite/raft/jraft/util/CountDownEventTest.java | 6 +-
.../apache/ignite/raft/jraft/util/CrcUtilTest.java | 6 +-
.../ignite/raft/jraft/util/EndpointTest.java | 6 +-
.../ExponentialBackoffTimeoutStrategyTest.java | 6 +-
.../jraft/util/FileOutputSignalHandlerTest.java | 6 +-
.../jraft/util/RecyclableByteBufferListTest.java | 6 +-
.../ignite/raft/jraft/util/RecyclersTest.java | 6 +-
.../ignite/raft/jraft/util/RepeatedTimerTest.java | 6 +-
.../ignite/raft/jraft/util/SegmentListTest.java | 6 +-
.../ignite/raft/jraft/util/ThreadIdTest.java | 6 +-
.../ignite/raft/jraft/util/Utf8CodecBenchmark.java | 6 +-
.../apache/ignite/raft/jraft/util/UtilsTest.java | 6 +-
.../util/concurrent/AdjustableSemaphoreTest.java | 6 +-
.../LongHeldDetectingReadWriteLockTest.java | 6 +-
.../concurrent/MpscSingleThreadExecutorTest.java | 6 +-
.../concurrent/SingleThreadExecutorBenchmark.java | 6 +-
.../internal/raft/server/impl/RaftServerImpl.java | 319 +++
.../service/ItAbstractListenerSnapshotTest.java | 443 ++++
.../apache/ignite/raft/jraft/test/TestUtils.java | 6 +-
modules/rest-api/build.gradle | 6 +-
.../apache/ignite/internal/rest/RestFactory.java | 4 +-
.../ignite/internal/rest/api/InvalidParam.java | 4 +-
.../apache/ignite/internal/rest/api/Problem.java | 15 +-
.../rest/api/cluster/ClusterManagementApi.java | 11 +-
.../internal/rest/api/cluster/ClusterNodeDto.java | 4 +-
.../internal/rest/api/cluster/ClusterStateDto.java | 4 +-
.../internal/rest/api/cluster/ClusterTagDto.java | 4 +-
.../rest/api/cluster/IgniteProductVersionDto.java | 4 +-
.../internal/rest/api/cluster/InitCommand.java | 4 +-
.../rest/api/cluster/NetworkAddressDto.java | 4 +-
.../internal/rest/api/cluster/TopologyApi.java | 7 +-
.../api/configuration/ClusterConfigurationApi.java | 11 +-
.../api/configuration/NodeConfigurationApi.java | 4 +-
.../internal/rest/api/node/NodeManagementApi.java | 4 +-
.../ignite/internal/rest/api/node/NodeState.java | 4 +-
.../ignite/internal/rest/api/node/State.java | 4 +-
.../ignite/internal/rest/api/package-info.java | 4 +-
.../ignite/internal/rest/constants/HttpCode.java | 4 +-
.../ignite/internal/rest/constants/MediaType.java | 4 +-
.../exception/ClusterNotInitializedException.java | 27 +
.../ClusterNotInitializedExceptionHandler.java | 45 +
.../exception/handler/IgniteExceptionHandler.java | 4 +-
.../exception/handler/JavaExceptionHandler.java | 48 +
.../ignite/internal/rest/problem/Builder.java | 4 +-
.../internal/rest/problem/HttpProblemResponse.java | 4 +-
.../handler/IgniteExceptionHandlerTest.java | 4 +-
modules/rest/build.gradle | 6 +-
modules/rest/openapi/openapi.yaml | 37 +-
.../apache/ignite/internal/rest/RestComponent.java | 4 +-
.../apache/ignite/internal/rest/package-info.java | 4 +-
modules/rocksdb-common/build.gradle | 6 +-
.../internal/rocksdb/BusyRocksIteratorAdapter.java | 91 +
.../ignite/internal/rocksdb/ColumnFamily.java | 4 +-
.../ignite/internal/rocksdb/RocksBiConsumer.java | 4 +-
.../ignite/internal/rocksdb/RocksBiPredicate.java | 4 +-
.../internal/rocksdb/RocksIteratorAdapter.java | 6 +-
.../apache/ignite/internal/rocksdb/RocksUtils.java | 4 +-
.../rocksdb/flush/RocksDbFlushListener.java | 79 +
.../internal/rocksdb/flush/RocksDbFlusher.java | 238 ++
.../rocksdb/snapshot/ColumnFamilyRange.java | 2 +-
.../rocksdb/snapshot/RocksSnapshotManager.java | 2 +-
modules/runner/build.gradle | 12 +-
.../internal/AbstractClusterIntegrationTest.java | 4 +-
.../ignite/internal/ItNoSyncMetadataTest.java | 4 +-
.../cluster/management/ItClusterInitTest.java | 2 +-
.../ignite/internal/compute/ItComputeTest.java | 4 +-
.../ItDistributedConfigurationPropertiesTest.java | 2 +-
.../ItDistributedConfigurationStorageTest.java | 4 +-
.../storage/ItRebalanceDistributedTest.java | 4 +-
.../ignite/internal/index/ItIndexManagerTest.java | 2 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 6 +-
.../ignite/internal/rest/AbstractRestTestBase.java | 4 +-
.../rest/ItInitializedClusterRestTest.java | 4 +-
.../rest/ItNotInitializedClusterRestTest.java | 54 +-
.../runner/app/AbstractSchemaChangeTest.java | 4 +-
.../internal/runner/app/IgniteCliRunnerTest.java | 4 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 4 +-
.../runner/app/ItDynamicTableCreationTest.java | 4 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 4 +-
.../ignite/internal/runner/app/ItIgnitionTest.java | 4 +-
.../internal/runner/app/ItNoThreadsLeftTest.java | 4 +-
.../runner/app/ItSchemaChangeKvViewTest.java | 4 +-
.../runner/app/ItSchemaChangeTableViewTest.java | 4 +-
.../runner/app/ItTableApiContractTest.java | 4 +-
.../internal/runner/app/ItTableCreationTest.java | 4 +-
.../internal/runner/app/ItTablesApiTest.java | 4 +-
.../runner/app/PlatformTestNodeRunner.java | 4 +-
.../app/client/ItAbstractThinClientTest.java | 4 +-
.../runner/app/client/ItThinClientComputeTest.java | 4 +-
.../app/client/ItThinClientConnectionTest.java | 4 +-
.../runner/app/client/ItThinClientSqlTest.java | 4 +-
.../app/client/ItThinClientTransactionsTest.java | 4 +-
.../runner/app/jdbc/AbstractJdbcSelfTest.java | 4 +-
.../app/jdbc/ItJdbcAbstractStatementSelfTest.java | 4 +-
.../runner/app/jdbc/ItJdbcBatchSelfTest.java | 4 +-
.../app/jdbc/ItJdbcComplexDmlDdlSelfTest.java | 4 +-
.../app/jdbc/ItJdbcComplexQuerySelfTest.java | 4 +-
.../app/jdbc/ItJdbcConnectionPropertiesTest.java | 4 +-
.../runner/app/jdbc/ItJdbcConnectionSelfTest.java | 4 +-
.../app/jdbc/ItJdbcDeleteStatementSelfTest.java | 4 +-
.../app/jdbc/ItJdbcErrorsAbstractSelfTest.java | 4 +-
.../runner/app/jdbc/ItJdbcErrorsSelfTest.java | 4 +-
.../app/jdbc/ItJdbcInsertStatementSelfTest.java | 4 +-
.../runner/app/jdbc/ItJdbcJoinsSelfTest.java | 4 +-
.../jdbc/ItJdbcMetadataPrimaryKeysSelfTest.java | 4 +-
.../runner/app/jdbc/ItJdbcMetadataSelfTest.java | 4 +-
.../app/jdbc/ItJdbcMultiStatementSelfTest.java | 4 +-
.../runner/app/jdbc/ItJdbcResultSetSelfTest.java | 4 +-
.../app/jdbc/ItJdbcSelectAfterAlterTable.java | 4 +-
.../app/jdbc/ItJdbcStatementCancelSelfTest.java | 4 +-
.../runner/app/jdbc/ItJdbcStatementSelfTest.java | 4 +-
.../app/jdbc/ItJdbcUpdateStatementSelfTest.java | 4 +-
.../ignite/internal/sql/api/ItCommonApiTest.java | 4 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 4 +-
.../sql/api/ItSqlClientAsynchronousApiTest.java | 4 +-
.../sql/api/ItSqlClientSynchronousApiTest.java | 4 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 4 +-
.../sql/engine/AbstractBasicIntegrationTest.java | 4 +-
.../internal/sql/engine/ItAggregatesTest.java | 4 +-
.../internal/sql/engine/ItCorrelatesTest.java | 4 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 4 +-
.../internal/sql/engine/ItDataTypesTest.java | 4 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 4 +-
.../internal/sql/engine/ItFunctionsTest.java | 4 +-
.../internal/sql/engine/ItHashSpoolTest.java | 4 +-
.../internal/sql/engine/ItIndexSpoolTest.java | 4 +-
.../ignite/internal/sql/engine/ItIntervalTest.java | 4 +-
.../ignite/internal/sql/engine/ItJoinTest.java | 4 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 4 +-
.../internal/sql/engine/ItMixedQueriesTest.java | 4 +-
.../internal/sql/engine/ItOrToUnionRuleTest.java | 4 +-
.../sql/engine/ItProjectScanMergeRuleTest.java | 4 +-
.../internal/sql/engine/ItSecondaryIndexTest.java | 4 +-
.../ignite/internal/sql/engine/ItSetOpTest.java | 4 +-
.../internal/sql/engine/ItSortAggregateTest.java | 4 +-
.../internal/sql/engine/ItSqlOperatorsTest.java | 4 +-
.../internal/sql/engine/util/CursorUtils.java | 4 +-
.../internal/sql/engine/util/MetadataMatcher.java | 4 +-
.../internal/sql/engine/util/QueryChecker.java | 4 +-
.../ignite/internal/sqllogic/ItSqlLogicTest.java | 4 +-
.../internal/sqllogic/SqlLogicTestEnvironment.java | 4 +-
.../ignite/internal/sqllogic/SqlScriptRunner.java | 4 +-
.../internal/table/ItPublicApiColocationTest.java | 4 +-
.../internal/test/WatchListenerInhibitor.java | 4 +-
.../sql/sqlite/select1/select1.test_slow | 2684 --------------------
.../sql/sqlite/select1/select1_p1.test | 275 ++
.../sql/sqlite/select1/select1_p2.test | 191 ++
.../sql/sqlite/select1/select1_p3.test_ignored | 859 +++++++
.../sql/sqlite/select1/select1_p4.test_ignored | 441 ++++
.../sql/sqlite/select1/select1_p5.test_ignored | 551 ++++
.../sql/sqlite/select1/select1_p6.test_ignored | 212 ++
.../sql/sqlite/select1/select1_p7.test_ignored | 333 +++
.../sql/sqlite/select1/select1_p8.test_ignored | 485 ++++
.../org/apache/ignite/app/IgniteCliRunner.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 5 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 4 +-
.../ignite/internal/app/LifecycleManager.java | 2 +-
.../internal/configuration/CompoundModule.java | 4 +-
.../configuration/ConfigurationModules.java | 4 +-
.../CoreDistributedConfigurationModule.java | 4 +-
.../CoreLocalConfigurationModule.java | 4 +-
.../ServiceLoaderModulesProvider.java | 4 +-
.../storage/DistributedConfigurationStorage.java | 8 +-
.../storage/LocalConfigurationStorage.java | 4 +-
.../recovery/ConfigurationCatchUpListener.java | 4 +-
.../recovery/RecoveryCompletionFutureFactory.java | 4 +-
.../ignite/internal/rest/node/NameProvider.java | 4 +-
.../rest/node/NodeManagementController.java | 4 +-
.../rest/node/NodeManagementRestFactory.java | 4 +-
.../ignite/internal/rest/node/StateProvider.java | 4 +-
.../internal/configuration/CompoundModuleTest.java | 4 +-
.../configuration/ConfigurationModulesTest.java | 4 +-
.../CoreDistributedConfigurationModuleTest.java | 4 +-
.../CoreLocalConfigurationModuleTest.java | 4 +-
.../ServiceLoaderModulesProviderTest.java | 4 +-
.../configuration/TestConfigurationModule.java | 4 +-
.../storage/ConfigurationStorageTest.java | 2 +-
.../DistributedConfigurationCatchUpTest.java | 2 +-
.../DistributedConfigurationStorageTest.java | 2 +-
.../storage/LocalConfigurationStorageTest.java | 2 +-
modules/schema/build.gradle | 6 +-
.../ignite/internal/schema/AssemblyException.java | 4 +-
.../ignite/internal/schema/BinaryConverter.java | 6 +-
.../apache/ignite/internal/schema/BinaryRow.java | 4 +-
.../apache/ignite/internal/schema/BinaryRowEx.java | 4 +-
.../apache/ignite/internal/schema/BinaryTuple.java | 4 +-
.../ignite/internal/schema/BinaryTupleSchema.java | 4 +-
.../ignite/internal/schema/BitmaskNativeType.java | 4 +-
.../ignite/internal/schema/ByteBufferRow.java | 4 +-
.../org/apache/ignite/internal/schema/Column.java | 4 +-
.../org/apache/ignite/internal/schema/Columns.java | 4 +-
.../ignite/internal/schema/DecimalNativeType.java | 4 +-
.../internal/schema/DefaultValueGenerator.java | 4 +-
.../internal/schema/DefaultValueProvider.java | 4 +-
.../internal/schema/InvalidTypeException.java | 4 +-
.../apache/ignite/internal/schema/NativeType.java | 4 +-
.../ignite/internal/schema/NativeTypeSpec.java | 4 +-
.../apache/ignite/internal/schema/NativeTypes.java | 4 +-
.../ignite/internal/schema/NumberNativeType.java | 4 +-
.../apache/ignite/internal/schema/SchemaAware.java | 4 +-
.../ignite/internal/schema/SchemaDescriptor.java | 4 +-
.../ignite/internal/schema/SchemaException.java | 4 +-
.../ignite/internal/schema/SchemaManager.java | 4 +-
.../internal/schema/SchemaMismatchException.java | 4 +-
.../schema/SchemaModificationException.java | 4 +-
.../ignite/internal/schema/SchemaRegistry.java | 4 +-
.../apache/ignite/internal/schema/SchemaUtils.java | 4 +-
.../ignite/internal/schema/TemporalNativeType.java | 4 +-
.../ignite/internal/schema/VarlenNativeType.java | 4 +-
.../configuration/ColumnTypeValidatorImpl.java | 4 +-
.../configuration/KnownDataStorageValidator.java | 4 +-
.../SchemaConfigurationConverter.java | 4 +-
.../configuration/SchemaDescriptorConverter.java | 4 +-
.../SchemaDistributedConfigurationModule.java | 4 +-
.../schema/configuration/TableValidatorImpl.java | 4 +-
.../schema/definition/AbstractSchemaObject.java | 4 +-
.../schema/definition/ColumnDefinitionImpl.java | 4 +-
.../schema/definition/SchemaValidationUtils.java | 4 +-
.../schema/definition/TableDefinitionImpl.java | 4 +-
.../definition/index/HashIndexDefinitionImpl.java | 4 +-
.../index/IndexColumnDefinitionImpl.java | 4 +-
.../definition/index/PrimaryKeyDefinitionImpl.java | 4 +-
.../index/SortedIndexColumnDefinitionImpl.java | 4 +-
.../index/SortedIndexDefinitionImpl.java | 4 +-
.../ignite/internal/schema/event/SchemaEvent.java | 4 +-
.../schema/event/SchemaEventParameters.java | 4 +-
.../internal/schema/mapping/ColumnMapper.java | 4 +-
.../internal/schema/mapping/ColumnMapperImpl.java | 4 +-
.../internal/schema/mapping/ColumnMapping.java | 4 +-
.../internal/schema/marshaller/BinaryMode.java | 4 +-
.../internal/schema/marshaller/KvMarshaller.java | 4 +-
.../schema/marshaller/MarshallerException.java | 4 +-
.../schema/marshaller/MarshallerFactory.java | 4 +-
.../internal/schema/marshaller/MarshallerUtil.java | 4 +-
.../schema/marshaller/RecordMarshaller.java | 4 +-
.../marshaller/asm/AsmMarshallerGenerator.java | 4 +-
.../marshaller/asm/ColumnAccessCodeGenerator.java | 4 +-
.../asm/IdentityMarshallerCodeGenerator.java | 4 +-
.../marshaller/asm/MarshallerCodeGenerator.java | 4 +-
.../asm/ObjectMarshallerCodeGenerator.java | 4 +-
.../marshaller/reflection/ColumnBinding.java | 4 +-
.../marshaller/reflection/KvMarshallerImpl.java | 4 +-
.../schema/marshaller/reflection/Marshaller.java | 4 +-
.../reflection/RecordMarshallerImpl.java | 4 +-
.../reflection/ReflectionMarshallerFactory.java | 4 +-
.../schema/AbstractSchemaSerializer.java | 4 +-
.../schema/marshaller/schema/SchemaSerializer.java | 4 +-
.../marshaller/schema/SchemaSerializerImpl.java | 4 +-
.../ignite/internal/schema/package-info.java | 4 +-
.../SchemaRegistrationConflictException.java | 4 +-
.../schema/registry/SchemaRegistryException.java | 4 +-
.../schema/registry/SchemaRegistryImpl.java | 4 +-
.../schema/registry/UpgradingRowAdapter.java | 4 +-
.../internal/schema/registry/package-info.java | 4 +-
.../internal/schema/row/ExpandableByteBuf.java | 4 +-
.../ignite/internal/schema/row/InternalTuple.java | 2 +-
.../org/apache/ignite/internal/schema/row/Row.java | 4 +-
.../ignite/internal/schema/row/RowAssembler.java | 4 +-
.../internal/schema/row/TemporalTypesHelper.java | 4 +-
.../ignite/internal/schema/row/VarTableFormat.java | 4 +-
.../ignite/internal/util/ColocationUtils.java | 4 +-
.../org/apache/ignite/internal/util/Factory.java | 4 +-
.../apache/ignite/internal/util/ObjectFactory.java | 4 +-
.../java/org/apache/ignite/internal/util/Pair.java | 4 +-
.../benchmarks/SerializerBenchmarkTest.java | 4 +-
.../internal/schema/ColumnDefinitionTest.java | 4 +-
.../apache/ignite/internal/schema/ColumnsTest.java | 4 +-
.../internal/schema/ExpandableByteBufTest.java | 4 +-
.../ignite/internal/schema/NativeTypeTest.java | 4 +-
.../schema/RowAssemblerAdvancedSchemaTest.java | 4 +-
.../schema/RowAssemblerSimpleSchemaTest.java | 4 +-
.../org/apache/ignite/internal/schema/RowTest.java | 4 +-
.../internal/schema/SchemaConfigurationTest.java | 4 +-
.../internal/schema/SchemaDescriptorTest.java | 4 +-
.../ignite/internal/schema/TemporalTypesTest.java | 4 +-
.../builder/ColumnDefinitionBuilderTest.java | 4 +-
.../builder/HashIndexDefinitionBuilderTest.java | 4 +-
.../PrimaryKeyDefinitionDefinitionBuilderTest.java | 4 +-
.../builder/SortedIndexDefinitionBuilderTest.java | 4 +-
.../schema/builder/TableDefinitionBuilderTest.java | 4 +-
.../configuration/AbstractSchemaConverterTest.java | 4 +-
.../KnownDataStorageValidatorTest.java | 4 +-
.../SchemaConfigurationConverterTest.java | 4 +-
.../SchemaDescriptorConverterTest.java | 4 +-
.../SchemaDistributedConfigurationModuleTest.java | 4 +-
.../configuration/TableValidatorImplTest.java | 4 +-
.../schema/TestDataStorageConfigurationSchema.java | 4 +-
.../schema/marshaller/KvMarshallerTest.java | 4 +-
.../internal/schema/marshaller/MapperTest.java | 4 +-
.../RecordMarshallerValidationsTest.java | 4 +-
.../marshaller/reflection/ColumnBindingTest.java | 4 +-
.../reflection/SerializingConverter.java | 4 +-
.../schema/registry/SchemaRegistryImplTest.java | 4 +-
.../schema/registry/UpgradingRowAdapterTest.java | 4 +-
.../schema/serializer/AbstractSerializerTest.java | 4 +-
.../ignite/internal/schema/SchemaTestUtils.java | 4 +-
.../schema/marshaller/RecordMarshallerTest.java | 4 +-
.../schema/testobjects/TestObjectWithAllTypes.java | 4 +-
.../TestObjectWithNoDefaultConstructor.java | 4 +-
.../TestObjectWithPrivateConstructor.java | 4 +-
.../schema/testobjects/TestOuterObject.java | 4 +-
.../schema/testobjects/TestSimpleObject.java | 4 +-
.../testutils/builder/AbstractIndexBuilder.java | 4 +-
.../testutils/builder/ColumnDefinitionBuilder.java | 4 +-
.../builder/ColumnDefinitionBuilderImpl.java | 4 +-
.../builder/HashIndexDefinitionBuilder.java | 4 +-
.../builder/HashIndexDefinitionBuilderImpl.java | 4 +-
.../builder/PrimaryKeyDefinitionBuilder.java | 4 +-
.../builder/PrimaryKeyDefinitionBuilderImpl.java | 4 +-
.../schema/testutils/builder/SchemaBuilders.java | 4 +-
.../testutils/builder/SchemaObjectBuilder.java | 4 +-
.../builder/SortedIndexDefinitionBuilder.java | 4 +-
.../builder/SortedIndexDefinitionBuilderImpl.java | 4 +-
.../testutils/builder/TableDefinitionBuilder.java | 4 +-
.../builder/TableDefinitionBuilderImpl.java | 4 +-
modules/sql-engine/build.gradle | 73 +-
.../apache/calcite/plan/volcano/VolcanoUtils.java | 4 +-
.../apache/calcite/plan/volcano/package-info.java | 4 +-
.../internal/sql/api/AsyncResultSetImpl.java | 4 +-
.../internal/sql/api/ColumnMetadataImpl.java | 4 +-
.../ignite/internal/sql/api/IgniteSqlImpl.java | 4 +-
.../internal/sql/api/ResultSetMetadataImpl.java | 4 +-
.../internal/sql/api/SessionBuilderImpl.java | 4 +-
.../ignite/internal/sql/api/SessionImpl.java | 4 +-
.../internal/sql/api/StatementBuilderImpl.java | 21 +-
.../ignite/internal/sql/api/StatementImpl.java | 10 +-
.../ignite/internal/sql/engine/AsyncCloseable.java | 4 +-
.../ignite/internal/sql/engine/AsyncCursor.java | 4 +-
.../ignite/internal/sql/engine/AsyncSqlCursor.java | 4 +-
.../internal/sql/engine/AsyncSqlCursorImpl.java | 4 +-
.../internal/sql/engine/CurrentTimeProvider.java | 4 +-
.../ignite/internal/sql/engine/QueryCancel.java | 4 +-
.../sql/engine/QueryCancelledException.java | 4 +-
.../ignite/internal/sql/engine/QueryContext.java | 4 +-
.../ignite/internal/sql/engine/QueryProcessor.java | 4 +-
.../ignite/internal/sql/engine/QueryProperty.java | 4 +-
.../ignite/internal/sql/engine/QueryState.java | 4 +-
.../ignite/internal/sql/engine/QueryValidator.java | 4 +-
.../ignite/internal/sql/engine/SqlCursor.java | 4 +-
.../internal/sql/engine/SqlQueryProcessor.java | 4 +-
.../ignite/internal/sql/engine/SqlQueryType.java | 4 +-
.../apache/ignite/internal/sql/engine/Stubs.java | 4 +-
.../sql/engine/exec/AbstractIndexScan.java | 4 +-
.../internal/sql/engine/exec/ArrayRowHandler.java | 4 +-
.../internal/sql/engine/exec/AsyncWrapper.java | 4 +-
.../internal/sql/engine/exec/ExchangeService.java | 4 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 4 +-
.../engine/exec/ExecutionCancelledException.java | 4 +-
.../internal/sql/engine/exec/ExecutionContext.java | 4 +-
.../internal/sql/engine/exec/ExecutionService.java | 4 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 4 +-
.../internal/sql/engine/exec/LifecycleAware.java | 4 +-
.../sql/engine/exec/LogicalRelImplementor.java | 4 +-
.../internal/sql/engine/exec/MailboxRegistry.java | 4 +-
.../sql/engine/exec/MailboxRegistryImpl.java | 4 +-
.../sql/engine/exec/QueryTaskExecutor.java | 4 +-
.../sql/engine/exec/QueryTaskExecutorImpl.java | 4 +-
.../sql/engine/exec/QueryValidationException.java | 4 +-
.../sql/engine/exec/RemoteFragmentKey.java | 4 +-
.../internal/sql/engine/exec/RowHandler.java | 4 +-
.../internal/sql/engine/exec/RuntimeHashIndex.java | 4 +-
.../internal/sql/engine/exec/RuntimeIndex.java | 4 +-
.../sql/engine/exec/RuntimeSortedIndex.java | 4 +-
.../sql/engine/exec/TableFunctionScan.java | 4 +-
.../ignite/internal/sql/engine/exec/TreeIndex.java | 4 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 4 +-
.../internal/sql/engine/exec/exp/BiScalar.java | 8 +-
.../sql/engine/exec/exp/CallImplementor.java | 8 +-
.../sql/engine/exec/exp/ConverterUtils.java | 8 +-
.../sql/engine/exec/exp/ExpressionFactory.java | 4 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 4 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 8 +-
.../sql/engine/exec/exp/ImplementableFunction.java | 8 +-
.../sql/engine/exec/exp/NotNullImplementor.java | 8 +-
.../exec/exp/ReflectiveCallNotNullImplementor.java | 8 +-
.../sql/engine/exec/exp/RexExecutorImpl.java | 8 +-
.../internal/sql/engine/exec/exp/RexImpTable.java | 8 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 8 +-
.../internal/sql/engine/exec/exp/Scalar.java | 4 +-
.../internal/sql/engine/exec/exp/SingleScalar.java | 4 +-
.../sql/engine/exec/exp/agg/Accumulator.java | 4 +-
.../engine/exec/exp/agg/AccumulatorWrapper.java | 4 +-
.../sql/engine/exec/exp/agg/Accumulators.java | 4 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 4 +-
.../sql/engine/exec/exp/agg/AggregateType.java | 4 +-
.../internal/sql/engine/exec/exp/agg/GroupKey.java | 4 +-
.../internal/sql/engine/exec/rel/AbstractNode.java | 4 +-
.../sql/engine/exec/rel/AbstractSetOpNode.java | 4 +-
.../sql/engine/exec/rel/AsyncRootNode.java | 4 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 4 +-
.../internal/sql/engine/exec/rel/Downstream.java | 4 +-
.../internal/sql/engine/exec/rel/FilterNode.java | 4 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 4 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 4 +-
.../sql/engine/exec/rel/IndexSpoolNode.java | 4 +-
.../sql/engine/exec/rel/IntersectNode.java | 4 +-
.../internal/sql/engine/exec/rel/LimitNode.java | 8 +-
.../internal/sql/engine/exec/rel/Mailbox.java | 4 +-
.../sql/engine/exec/rel/MergeJoinNode.java | 4 +-
.../internal/sql/engine/exec/rel/MinusNode.java | 4 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 4 +-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 4 +-
.../ignite/internal/sql/engine/exec/rel/Node.java | 4 +-
.../internal/sql/engine/exec/rel/Outbox.java | 4 +-
.../internal/sql/engine/exec/rel/ProjectNode.java | 4 +-
.../internal/sql/engine/exec/rel/RootNode.java | 4 +-
.../internal/sql/engine/exec/rel/ScanNode.java | 4 +-
.../internal/sql/engine/exec/rel/SingleNode.java | 4 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 4 +-
.../internal/sql/engine/exec/rel/SortNode.java | 4 +-
.../sql/engine/exec/rel/TableScanNode.java | 4 +-
.../sql/engine/exec/rel/TableSpoolNode.java | 4 +-
.../internal/sql/engine/exec/rel/UnionAllNode.java | 4 +-
.../sql/engine/externalize/RelInputEx.java | 8 +-
.../internal/sql/engine/externalize/RelJson.java | 8 +-
.../sql/engine/externalize/RelJsonReader.java | 8 +-
.../sql/engine/externalize/RelJsonWriter.java | 8 +-
.../internal/sql/engine/message/ErrorMessage.java | 4 +-
.../message/ExecutionContextAwareMessage.java | 4 +-
.../sql/engine/message/InboxCloseMessage.java | 4 +-
.../sql/engine/message/MessageListener.java | 4 +-
.../sql/engine/message/MessageService.java | 4 +-
.../sql/engine/message/MessageServiceImpl.java | 4 +-
.../message/QueryBatchAcknowledgeMessage.java | 4 +-
.../sql/engine/message/QueryBatchMessage.java | 4 +-
.../sql/engine/message/QueryCloseMessage.java | 4 +-
.../sql/engine/message/QueryStartRequest.java | 4 +-
.../sql/engine/message/QueryStartResponse.java | 4 +-
.../sql/engine/message/SqlQueryMessageGroup.java | 4 +-
.../sql/engine/metadata/AffinityService.java | 4 +-
.../sql/engine/metadata/ColocationGroup.java | 4 +-
.../metadata/ColocationMappingException.java | 4 +-
.../sql/engine/metadata/FragmentDescription.java | 4 +-
.../sql/engine/metadata/FragmentMapping.java | 4 +-
.../engine/metadata/FragmentMappingException.java | 4 +-
.../sql/engine/metadata/IgniteMdCollation.java | 4 +-
.../engine/metadata/IgniteMdCumulativeCost.java | 4 +-
.../engine/metadata/IgniteMdDistinctRowCount.java | 4 +-
.../sql/engine/metadata/IgniteMdDistribution.java | 4 +-
.../engine/metadata/IgniteMdFragmentMapping.java | 4 +-
.../engine/metadata/IgniteMdNonCumulativeCost.java | 4 +-
.../metadata/IgniteMdPercentageOriginalRows.java | 4 +-
.../sql/engine/metadata/IgniteMdPredicates.java | 4 +-
.../sql/engine/metadata/IgniteMdRowCount.java | 4 +-
.../sql/engine/metadata/IgniteMdSelectivity.java | 4 +-
.../sql/engine/metadata/IgniteMetadata.java | 4 +-
.../sql/engine/metadata/MappingService.java | 4 +-
.../sql/engine/metadata/MappingServiceImpl.java | 4 +-
.../sql/engine/metadata/NodeMappingException.java | 4 +-
.../sql/engine/metadata/RelMetadataQueryEx.java | 4 +-
.../sql/engine/metadata/RemoteException.java | 4 +-
.../sql/engine/metadata/cost/IgniteCost.java | 4 +-
.../engine/metadata/cost/IgniteCostFactory.java | 4 +-
.../sql/engine/prepare/AbstractMultiStepPlan.java | 4 +-
.../internal/sql/engine/prepare/CacheKey.java | 4 +-
.../ignite/internal/sql/engine/prepare/Cloner.java | 4 +-
.../internal/sql/engine/prepare/DdlPlan.java | 4 +-
.../internal/sql/engine/prepare/ExecutionPlan.java | 4 +-
.../internal/sql/engine/prepare/ExplainPlan.java | 4 +-
.../internal/sql/engine/prepare/Fragment.java | 4 +-
.../internal/sql/engine/prepare/FragmentPlan.java | 4 +-
.../sql/engine/prepare/FragmentSplitter.java | 4 +-
.../internal/sql/engine/prepare/IdGenerator.java | 4 +-
.../sql/engine/prepare/IgniteConvertletTable.java | 4 +-
.../internal/sql/engine/prepare/IgnitePlanner.java | 4 +-
.../sql/engine/prepare/IgnitePrograms.java | 4 +-
.../sql/engine/prepare/IgniteRelShuttle.java | 4 +-
.../engine/prepare/IgniteSqlToRelConvertor.java | 4 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 4 +-
.../sql/engine/prepare/IgniteTypeCoercion.java | 4 +-
.../sql/engine/prepare/LazyResultSetMetadata.java | 4 +-
.../sql/engine/prepare/MappingQueryContext.java | 4 +-
.../sql/engine/prepare/MultiStepDmlPlan.java | 4 +-
.../internal/sql/engine/prepare/MultiStepPlan.java | 4 +-
.../sql/engine/prepare/MultiStepQueryPlan.java | 4 +-
.../internal/sql/engine/prepare/PlannerHelper.java | 4 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 4 +-
.../sql/engine/prepare/PlanningContext.java | 4 +-
.../sql/engine/prepare/PrepareService.java | 4 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 4 +-
.../internal/sql/engine/prepare/QueryPlan.java | 4 +-
.../sql/engine/prepare/QueryPlanFactory.java | 4 +-
.../internal/sql/engine/prepare/QueryTemplate.java | 4 +-
.../internal/sql/engine/prepare/Splitter.java | 4 +-
.../sql/engine/prepare/ValidationResult.java | 4 +-
.../prepare/ddl/AbstractTableDdlCommand.java | 4 +-
.../engine/prepare/ddl/AlterTableAddCommand.java | 4 +-
.../engine/prepare/ddl/AlterTableDropCommand.java | 4 +-
.../sql/engine/prepare/ddl/ColumnDefinition.java | 4 +-
.../sql/engine/prepare/ddl/CreateIndexCommand.java | 4 +-
.../sql/engine/prepare/ddl/CreateTableCommand.java | 4 +-
.../sql/engine/prepare/ddl/DdlCommand.java | 4 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 4 +-
.../engine/prepare/ddl/DefaultValueDefinition.java | 4 +-
.../sql/engine/prepare/ddl/DropIndexCommand.java | 4 +-
.../sql/engine/prepare/ddl/DropTableCommand.java | 4 +-
.../sql/engine/prepare/ddl/TableOptionInfo.java | 4 +-
.../sql/engine/property/PropertiesHelper.java | 4 +-
.../sql/engine/property/PropertiesHolder.java | 4 +-
.../sql/engine/property/PropertiesHolderImpl.java | 4 +-
.../internal/sql/engine/property/Property.java | 4 +-
.../sql/engine/rel/AbstractIgniteJoin.java | 4 +-
.../sql/engine/rel/AbstractIgniteSpool.java | 4 +-
.../internal/sql/engine/rel/AbstractIndexScan.java | 4 +-
.../internal/sql/engine/rel/IgniteAggregate.java | 4 +-
.../internal/sql/engine/rel/IgniteConvention.java | 4 +-
.../engine/rel/IgniteCorrelatedNestedLoopJoin.java | 4 +-
.../internal/sql/engine/rel/IgniteExchange.java | 4 +-
.../internal/sql/engine/rel/IgniteFilter.java | 4 +-
.../internal/sql/engine/rel/IgniteGateway.java | 4 +-
.../sql/engine/rel/IgniteHashIndexSpool.java | 4 +-
.../internal/sql/engine/rel/IgniteIndexScan.java | 4 +-
.../internal/sql/engine/rel/IgniteLimit.java | 8 +-
.../internal/sql/engine/rel/IgniteMergeJoin.java | 4 +-
.../sql/engine/rel/IgniteNestedLoopJoin.java | 4 +-
.../internal/sql/engine/rel/IgniteProject.java | 4 +-
.../internal/sql/engine/rel/IgniteReceiver.java | 4 +-
.../ignite/internal/sql/engine/rel/IgniteRel.java | 4 +-
.../internal/sql/engine/rel/IgniteRelVisitor.java | 4 +-
.../internal/sql/engine/rel/IgniteSender.java | 4 +-
.../ignite/internal/sql/engine/rel/IgniteSort.java | 4 +-
.../sql/engine/rel/IgniteSortedIndexSpool.java | 4 +-
.../sql/engine/rel/IgniteTableFunctionScan.java | 4 +-
.../internal/sql/engine/rel/IgniteTableModify.java | 4 +-
.../internal/sql/engine/rel/IgniteTableScan.java | 4 +-
.../internal/sql/engine/rel/IgniteTableSpool.java | 4 +-
.../sql/engine/rel/IgniteTrimExchange.java | 4 +-
.../internal/sql/engine/rel/IgniteUnionAll.java | 4 +-
.../internal/sql/engine/rel/IgniteValues.java | 4 +-
.../internal/sql/engine/rel/InternalIgniteRel.java | 8 +-
.../engine/rel/ProjectableFilterableTableScan.java | 4 +-
.../sql/engine/rel/SourceAwareIgniteRel.java | 4 +-
.../engine/rel/agg/IgniteHashAggregateBase.java | 4 +-
.../sql/engine/rel/agg/IgniteMapAggregateBase.java | 4 +-
.../sql/engine/rel/agg/IgniteMapHashAggregate.java | 4 +-
.../sql/engine/rel/agg/IgniteMapSortAggregate.java | 4 +-
.../engine/rel/agg/IgniteReduceAggregateBase.java | 4 +-
.../engine/rel/agg/IgniteReduceHashAggregate.java | 4 +-
.../engine/rel/agg/IgniteReduceSortAggregate.java | 4 +-
.../engine/rel/agg/IgniteSingleAggregateBase.java | 4 +-
.../engine/rel/agg/IgniteSingleHashAggregate.java | 4 +-
.../engine/rel/agg/IgniteSingleSortAggregate.java | 4 +-
.../engine/rel/agg/IgniteSortAggregateBase.java | 4 +-
.../engine/rel/logical/IgniteLogicalIndexScan.java | 8 +-
.../engine/rel/logical/IgniteLogicalTableScan.java | 8 +-
.../sql/engine/rel/set/IgniteIntersect.java | 4 +-
.../sql/engine/rel/set/IgniteMapIntersect.java | 4 +-
.../sql/engine/rel/set/IgniteMapMinus.java | 4 +-
.../sql/engine/rel/set/IgniteMapSetOp.java | 4 +-
.../internal/sql/engine/rel/set/IgniteMinus.java | 4 +-
.../sql/engine/rel/set/IgniteMinusBase.java | 4 +-
.../sql/engine/rel/set/IgniteReduceIntersect.java | 4 +-
.../sql/engine/rel/set/IgniteReduceMinus.java | 4 +-
.../sql/engine/rel/set/IgniteReduceSetOp.java | 4 +-
.../internal/sql/engine/rel/set/IgniteSetOp.java | 4 +-
.../sql/engine/rel/set/IgniteSingleIntersect.java | 4 +-
.../sql/engine/rel/set/IgniteSingleMinus.java | 4 +-
.../sql/engine/rel/set/IgniteSingleSetOp.java | 4 +-
.../engine/rule/AbstractIgniteConverterRule.java | 4 +-
.../sql/engine/rule/CorrelateToNestedLoopRule.java | 4 +-
.../engine/rule/CorrelatedNestedLoopJoinRule.java | 4 +-
.../sql/engine/rule/FilterConverterRule.java | 4 +-
.../rule/FilterSpoolMergeToHashIndexSpoolRule.java | 4 +-
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 4 +-
.../engine/rule/HashAggregateConverterRule.java | 4 +-
.../sql/engine/rule/LogicalScanConverterRule.java | 8 +-
.../sql/engine/rule/MergeJoinConverterRule.java | 4 +-
.../sql/engine/rule/MinusConverterRule.java | 4 +-
.../engine/rule/NestedLoopJoinConverterRule.java | 4 +-
.../sql/engine/rule/ProjectConverterRule.java | 4 +-
.../sql/engine/rule/SetOpConverterRule.java | 4 +-
.../engine/rule/SortAggregateConverterRule.java | 4 +-
.../sql/engine/rule/SortConverterRule.java | 4 +-
.../rule/TableFunctionScanConverterRule.java | 8 +-
.../sql/engine/rule/TableModifyConverterRule.java | 4 +-
.../sql/engine/rule/UnionConverterRule.java | 4 +-
.../sql/engine/rule/ValuesConverterRule.java | 4 +-
.../sql/engine/rule/logical/ExposeIndexRule.java | 4 +-
.../engine/rule/logical/FilterScanMergeRule.java | 4 +-
.../engine/rule/logical/LogicalOrToUnionRule.java | 4 +-
.../engine/rule/logical/ProjectScanMergeRule.java | 8 +-
.../sql/engine/rule/logical/RuleFactoryConfig.java | 8 +-
.../internal/sql/engine/rule/package-info.java | 4 +-
.../sql/engine/schema/ColumnDescriptor.java | 4 +-
.../sql/engine/schema/ColumnDescriptorImpl.java | 4 +-
.../sql/engine/schema/DefaultValueStrategy.java | 4 +-
.../internal/sql/engine/schema/IgniteIndex.java | 4 +-
.../internal/sql/engine/schema/IgniteSchema.java | 4 +-
.../internal/sql/engine/schema/IgniteTable.java | 4 +-
.../sql/engine/schema/IgniteTableImpl.java | 4 +-
.../sql/engine/schema/InternalIgniteTable.java | 4 +-
.../internal/sql/engine/schema/ModifyRow.java | 4 +-
.../sql/engine/schema/SchemaUpdateListener.java | 4 +-
.../sql/engine/schema/SqlSchemaManager.java | 4 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 4 +-
.../sql/engine/schema/TableDescriptor.java | 4 +-
.../sql/engine/schema/TableDescriptorImpl.java | 4 +-
.../internal/sql/engine/session/Session.java | 4 +-
.../internal/sql/engine/session/SessionId.java | 4 +-
.../internal/sql/engine/session/SessionInfo.java | 4 +-
.../sql/engine/session/SessionManager.java | 4 +-
.../engine/sql/IgniteAbstractSqlAlterTable.java | 8 +-
.../engine/sql/IgniteSqlAlterTableAddColumn.java | 8 +-
.../engine/sql/IgniteSqlAlterTableDropColumn.java | 8 +-
.../sql/engine/sql/IgniteSqlConformance.java | 8 +-
.../sql/engine/sql/IgniteSqlCreateIndex.java | 8 +-
.../sql/engine/sql/IgniteSqlCreateTable.java | 8 +-
.../sql/engine/sql/IgniteSqlCreateTableOption.java | 4 +-
.../sql/engine/sql/IgniteSqlDropIndex.java | 8 +-
.../sql/engine/sql/IgniteSqlIndexType.java | 8 +-
.../engine/sql/IgniteSqlIntervalTypeNameSpec.java | 4 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 8 +-
.../sql/engine/sql/fun/SqlSystemRangeFunction.java | 8 +-
.../internal/sql/engine/trait/AffinityAdapter.java | 4 +-
.../ignite/internal/sql/engine/trait/AllNodes.java | 4 +-
.../sql/engine/trait/CorrelationTrait.java | 4 +-
.../sql/engine/trait/CorrelationTraitDef.java | 4 +-
.../internal/sql/engine/trait/Destination.java | 4 +-
.../sql/engine/trait/DistributionFunction.java | 4 +-
.../sql/engine/trait/DistributionTrait.java | 4 +-
.../sql/engine/trait/DistributionTraitDef.java | 4 +-
.../sql/engine/trait/IgniteDistribution.java | 4 +-
.../sql/engine/trait/IgniteDistributions.java | 4 +-
.../internal/sql/engine/trait/Partitioned.java | 4 +-
.../internal/sql/engine/trait/RandomNode.java | 4 +-
.../internal/sql/engine/trait/RelFactory.java | 4 +-
.../sql/engine/trait/RewindabilityTrait.java | 4 +-
.../sql/engine/trait/RewindabilityTraitDef.java | 4 +-
.../internal/sql/engine/trait/TraitUtils.java | 4 +-
.../sql/engine/trait/TraitsAwareIgniteRel.java | 4 +-
.../sql/engine/type/IgniteTypeFactory.java | 4 +-
.../internal/sql/engine/type/IgniteTypeSystem.java | 4 +-
.../sql/engine/util/AbstractQueryContext.java | 4 +-
.../internal/sql/engine/util/BaseQueryContext.java | 4 +-
.../ignite/internal/sql/engine/util/Commons.java | 12 +-
.../ignite/internal/sql/engine/util/HintUtils.java | 4 +-
.../internal/sql/engine/util/IgniteMethod.java | 4 +-
.../internal/sql/engine/util/IgniteResource.java | 4 +-
.../internal/sql/engine/util/IndexConditions.java | 4 +-
.../internal/sql/engine/util/NodeLeaveHandler.java | 4 +-
.../internal/sql/engine/util/Primitives.java | 4 +-
.../ignite/internal/sql/engine/util/RexUtils.java | 4 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 4 +-
.../internal/sql/engine/IgniteSqlApiTest.java | 14 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 4 +-
.../apache/ignite/internal/sql/engine/TestRow.java | 4 +-
.../sql/engine/exec/AsyncWrapperSelfTest.java | 4 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 4 +-
.../sql/engine/exec/MockedStructuresTest.java | 4 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 4 +-
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 4 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 4 +-
.../exec/rel/AbstractSetOpExecutionTest.java | 4 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 4 +-
.../sql/engine/exec/rel/ExecutionTest.java | 4 +-
.../exec/rel/HashAggregateExecutionTest.java | 4 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 4 +-
.../exec/rel/HashIndexSpoolExecutionTest.java | 4 +-
.../engine/exec/rel/IntersectExecutionTest.java | 4 +-
.../sql/engine/exec/rel/LimitExecutionTest.java | 4 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 4 +-
.../sql/engine/exec/rel/MinusExecutionTest.java | 4 +-
.../exec/rel/NestedLoopJoinExecutionTest.java | 4 +-
.../exec/rel/SortAggregateExecutionTest.java | 4 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 4 +-
.../engine/exec/rel/TableSpoolExecutionTest.java | 4 +-
.../engine/exec/schema/SqlSchemaManagerTest.java | 4 +-
.../sql/engine/externalize/RelJsonReaderTest.java | 4 +-
.../planner/AbstractAggregatePlannerTest.java | 4 +-
.../sql/engine/planner/AbstractPlannerTest.java | 4 +-
.../planner/AggregateDistinctPlannerTest.java | 4 +-
.../sql/engine/planner/AggregatePlannerTest.java | 4 +-
.../CorrelatedNestedLoopJoinPlannerTest.java | 4 +-
.../planner/CorrelatedSubqueryPlannerTest.java | 6 +-
.../engine/planner/HashAggregatePlannerTest.java | 4 +-
.../sql/engine/planner/HashIndexPlannerTest.java | 4 +-
.../engine/planner/HashIndexSpoolPlannerTest.java | 4 +-
.../engine/planner/JoinColocationPlannerTest.java | 4 +-
.../sql/engine/planner/JoinCommutePlannerTest.java | 8 +-
.../engine/planner/JoinWithUsingPlannerTest.java | 4 +-
.../sql/engine/planner/LimitOffsetPlannerTest.java | 4 +-
.../sql/engine/planner/MergeJoinPlannerTest.java | 4 +-
.../internal/sql/engine/planner/PlannerTest.java | 4 +-
.../planner/ProjectFilterScanMergePlannerTest.java | 4 +-
.../sql/engine/planner/SetOpPlannerTest.java | 4 +-
.../engine/planner/SortAggregatePlannerTest.java | 4 +-
.../planner/SortedIndexSpoolPlannerTest.java | 4 +-
.../engine/planner/TableFunctionPlannerTest.java | 4 +-
.../sql/engine/planner/TableSpoolPlannerTest.java | 4 +-
.../sql/engine/planner/UnionPlannerTest.java | 4 +-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 4 +-
.../sql/engine/property/PropertiesHelperTest.java | 4 +-
.../sql/engine/session/SessionManagerTest.java | 4 +-
.../internal/sql/engine/sql/SqlDdlParserTest.java | 4 +-
modules/storage-api/build.gradle | 6 +-
.../apache/ignite/internal/storage/DataRow.java | 4 +-
.../internal/storage/DataStorageManager.java | 4 +-
.../ignite/internal/storage/DataStorageModule.java | 4 +-
.../internal/storage/DataStorageModules.java | 4 +-
.../ignite/internal/storage/InvokeClosure.java | 4 +-
.../internal/storage/MvPartitionStorage.java | 2 +-
.../ignite/internal/storage/OperationType.java | 4 +-
.../ignite/internal/storage/PartitionStorage.java | 4 +-
.../apache/ignite/internal/storage/ReadResult.java | 4 +-
.../org/apache/ignite/internal/storage/RowId.java | 2 +-
.../apache/ignite/internal/storage/SearchRow.java | 4 +-
.../ignite/internal/storage/StorageException.java | 4 +-
.../internal/storage/TxIdMismatchException.java | 2 +-
.../internal/storage/basic/BinarySearchRow.java | 2 +-
.../internal/storage/basic/DelegatingDataRow.java | 4 +-
.../storage/basic/DeleteExactInvokeClosure.java | 4 +-
.../storage/basic/GetAndRemoveInvokeClosure.java | 4 +-
.../storage/basic/GetAndReplaceInvokeClosure.java | 4 +-
.../storage/basic/InsertInvokeClosure.java | 4 +-
.../storage/basic/ReplaceExactInvokeClosure.java | 4 +-
.../internal/storage/basic/SimpleDataRow.java | 4 +-
.../storage/basic/SimpleReadInvokeClosure.java | 4 +-
.../storage/basic/SimpleRemoveInvokeClosure.java | 4 +-
.../storage/basic/SimpleWriteInvokeClosure.java | 4 +-
.../ExistingDataStorageValidator.java | 4 +-
...torageEngineDistributedConfigurationModule.java | 4 +-
.../internal/storage/engine/MvTableStorage.java | 2 +-
.../internal/storage/engine/StorageEngine.java | 4 +-
.../internal/storage/engine/TableStorage.java | 4 +-
.../storage/index/HashIndexDescriptor.java | 2 +-
.../internal/storage/index/HashIndexStorage.java | 2 +-
.../ignite/internal/storage/index/IndexRow.java | 2 +-
.../internal/storage/index/IndexRowImpl.java | 2 +-
.../storage/index/SortedIndexDescriptor.java | 2 +-
.../internal/storage/index/SortedIndexStorage.java | 12 +-
.../ConcurrentHashMapMvTableStorageTest.java | 2 +-
.../internal/storage/DataStorageManagerTest.java | 4 +-
.../internal/storage/DataStorageModulesTest.java | 4 +-
.../storage/TestMvPartitionStorageTest.java | 2 +-
.../ExistingDataStorageValidatorTest.java | 4 +-
.../index/AbstractSortedIndexStorageTest.java | 206 +-
.../storage/index/TestHashIndexStorageTest.java | 2 +-
.../storage/index/TestSortedIndexStorageTest.java | 31 +-
.../internal/storage/index/impl/TestIndexRow.java | 2 +-
.../storage/AbstractMvPartitionStorageTest.java | 2 +-
.../storage/AbstractMvTableStorageTest.java | 2 +-
.../storage/AbstractPartitionStorageTest.java | 4 +-
.../internal/storage/BaseMvStoragesTest.java | 2 +-
.../TestConcurrentHashMapDataStorageModule.java | 4 +-
.../TestConcurrentHashMapMvPartitionStorage.java | 8 +-
.../chm/TestConcurrentHashMapMvTableStorage.java | 2 +-
.../chm/TestConcurrentHashMapStorageEngine.java | 4 +-
...torageEngineDistributedConfigurationModule.java | 4 +-
...rrentHashMapDataStorageConfigurationSchema.java | 4 +-
.../index/AbstractHashIndexStorageTest.java | 2 +-
.../storage/index/impl/BinaryTupleComparator.java | 2 +-
.../index/impl/BinaryTupleRowSerializer.java | 4 +-
.../internal/storage/index/impl/IndexRowImpl.java | 2 +-
.../storage/index/impl/TestHashIndexStorage.java | 2 +-
.../storage/index/impl/TestSortedIndexStorage.java | 16 +-
modules/storage-page-memory/build.gradle | 6 +-
.../pagememory/AbstractPageMemoryTableStorage.java | 4 +-
.../pagememory/PersistentPageMemoryDataRegion.java | 4 +-
.../PersistentPageMemoryDataStorageModule.java | 4 +-
.../PersistentPageMemoryStorageEngine.java | 4 +-
.../PersistentPageMemoryTableStorage.java | 4 +-
.../pagememory/VolatilePageMemoryDataRegion.java | 4 +-
.../VolatilePageMemoryDataStorageModule.java | 4 +-
.../VolatilePageMemoryStorageEngine.java | 4 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 4 +-
.../configuration/PageMemoryDataRegionName.java | 4 +-
.../PageMemoryDataRegionValidatorImpl.java | 4 +-
...torageEngineDistributedConfigurationModule.java | 4 +-
...PageMemoryStorageEngineConfigurationSchema.java | 4 +-
...ntPageMemoryDataStorageConfigurationSchema.java | 4 +-
...PageMemoryStorageEngineConfigurationSchema.java | 4 +-
...lePageMemoryDataStorageConfigurationSchema.java | 4 +-
...PageMemoryStorageEngineConfigurationSchema.java | 4 +-
.../pagememory/index/IndexPageIoModule.java | 13 +-
.../storage/pagememory/index/IndexPageTypes.java | 11 +-
.../pagememory/index/freelist/IndexColumns.java | 3 +-
.../index/freelist/IndexColumnsFreeList.java | 3 +-
.../index/freelist/ReadIndexColumnsValue.java | 6 +-
.../index/freelist/io/IndexColumnsDataIo.java | 7 +-
.../pagememory/index/hash/HashIndexRow.java | 4 +-
.../pagememory/index/hash/HashIndexRowKey.java | 4 +-
.../pagememory/index/hash/HashIndexTree.java | 4 +-
.../hash/InsertHashIndexRowInvokeClosure.java | 2 +-
.../index/hash/PageMemoryHashIndexStorage.java | 2 +-
.../hash/RemoveHashIndexRowInvokeClosure.java | 2 +-
.../index/hash/io/HashIndexTreeInnerIo.java | 2 +-
.../pagememory/index/hash/io/HashIndexTreeIo.java | 12 +-
.../index/hash/io/HashIndexTreeLeafIo.java | 2 +-
.../index/hash/io/HashIndexTreeMetaIo.java | 4 +-
.../storage/pagememory/index/meta/IndexMeta.java | 5 +-
.../pagememory/index/meta/IndexMetaTree.java | 4 +-
.../pagememory/index/meta/io/IndexMetaInnerIo.java | 7 +-
.../pagememory/index/meta/io/IndexMetaIo.java | 4 +-
.../pagememory/index/meta/io/IndexMetaLeafIo.java | 7 +-
.../index/meta/io/IndexMetaTreeMetaIo.java | 4 +-
.../pagememory/index/sorted/SortedIndexRow.java | 49 +
.../pagememory/index/sorted/SortedIndexRowKey.java | 43 +
.../pagememory/index/sorted/SortedIndexTree.java | 103 +
.../index/sorted/io/SortedIndexTreeInnerIo.java | 62 +
.../index/sorted/io/SortedIndexTreeIo.java | 173 ++
.../index/sorted/io/SortedIndexTreeLeafIo.java | 62 +
.../index/sorted/io/SortedIndexTreeMetaIo.java | 40 +
.../mv/AbstractPageMemoryMvPartitionStorage.java | 4 +-
.../storage/pagememory/mv/HybridTimestamps.java | 4 +-
.../storage/pagememory/mv/MvPageIoModule.java | 4 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 4 +-
.../storage/pagememory/mv/ReadRowVersion.java | 4 +-
.../storage/pagememory/mv/ReadRowVersionValue.java | 4 +-
.../internal/storage/pagememory/mv/RowVersion.java | 4 +-
.../storage/pagememory/mv/RowVersionFreeList.java | 4 +-
.../pagememory/mv/ScanVersionChainByTimestamp.java | 4 +-
.../storage/pagememory/mv/VersionChain.java | 4 +-
.../storage/pagememory/mv/VersionChainKey.java | 4 +-
.../storage/pagememory/mv/VersionChainTree.java | 4 +-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 4 +-
.../storage/pagememory/mv/io/RowVersionDataIo.java | 4 +-
.../pagememory/mv/io/VersionChainInnerIo.java | 4 +-
.../storage/pagememory/mv/io/VersionChainIo.java | 4 +-
.../pagememory/mv/io/VersionChainLeafIo.java | 4 +-
.../pagememory/mv/io/VersionChainMetaIo.java | 4 +-
.../storage/pagememory/util/TreeCursorAdapter.java | 2 +-
.../PersistentPageMemoryDataRegionTest.java | 4 +-
.../PageMemoryDataRegionValidatorImplTest.java | 4 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 2 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 2 +-
.../AbstractPageMemoryMvPartitionStorageTest.java | 4 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 4 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 4 +-
modules/storage-rocksdb/build.gradle | 6 +-
.../storage/rocksdb/ColumnFamilyUtils.java | 2 +-
.../internal/storage/rocksdb/HashIndices.java | 2 +-
.../storage/rocksdb/RocksDbDataRegion.java | 4 +-
.../storage/rocksdb/RocksDbDataStorageModule.java | 4 +-
.../storage/rocksdb/RocksDbFlushListener.java | 112 -
.../storage/rocksdb/RocksDbMetaStorage.java | 2 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 35 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 6 +-
.../storage/rocksdb/RocksDbTableStorage.java | 154 +-
.../configuration/RocksDbDataRegionName.java | 4 +-
.../RocksDbDataRegionValidatorImpl.java | 4 +-
...torageEngineDistributedConfigurationModule.java | 4 +-
.../RocksDbDataRegionConfigurationSchema.java | 4 +-
.../RocksDbDataStorageConfigurationSchema.java | 4 +-
.../RocksDbStorageEngineConfigurationSchema.java | 4 +-
.../rocksdb/index/RocksDbHashIndexStorage.java | 2 +-
.../rocksdb/RocksDbMvPartitionStorageTest.java | 2 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 4 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 2 +-
.../RocksDbDataRegionValidatorImplTest.java | 4 +-
.../rocksdb/index/RocksDbHashIndexStorageTest.java | 2 +-
modules/table/build.gradle | 12 +-
.../distributed/ItInternalTableScanTest.java | 4 +-
.../ignite/distributed/ItTablePersistenceTest.java | 4 +-
.../distributed/ItTxDistributedTestSingleNode.java | 4 +-
.../ItTxDistributedTestSingleNodeCollocated.java | 4 +-
...ItTxDistributedTestThreeNodesThreeReplicas.java | 4 +-
...butedTestThreeNodesThreeReplicasCollocated.java | 4 +-
.../ignite/internal/table/ItColocationTest.java | 4 +-
.../org/apache/ignite/binary/BinaryObjects.java | 4 +-
.../org/apache/ignite/binary/package-info.java | 4 +-
.../TableDistributedConfigurationModule.java | 4 +-
.../schema/marshaller/TupleMarshaller.java | 4 +-
.../marshaller/TupleMarshallerException.java | 4 +-
.../schema/marshaller/TupleMarshallerImpl.java | 4 +-
.../internal/table/AbstractRowTupleAdapter.java | 4 +-
.../ignite/internal/table/AbstractTableView.java | 4 +-
.../internal/table/IgniteTablesInternal.java | 4 +-
.../ignite/internal/table/InternalTable.java | 4 +-
.../internal/table/KeyValueBinaryViewImpl.java | 4 +-
.../ignite/internal/table/KeyValueViewImpl.java | 4 +-
.../internal/table/MutableRowTupleAdapter.java | 4 +-
.../internal/table/RecordBinaryViewImpl.java | 4 +-
.../ignite/internal/table/RecordViewImpl.java | 4 +-
.../apache/ignite/internal/table/TableImpl.java | 4 +-
.../org/apache/ignite/internal/table/TableRow.java | 4 +-
.../internal/table/distributed/TableManager.java | 7 +-
.../table/distributed/TableTxManagerImpl.java | 4 +-
.../table/distributed/command/CommandUtils.java | 4 +-
.../distributed/command/DeleteAllCommand.java | 4 +-
.../table/distributed/command/DeleteCommand.java | 4 +-
.../distributed/command/DeleteExactAllCommand.java | 4 +-
.../distributed/command/DeleteExactCommand.java | 4 +-
.../table/distributed/command/FinishTxCommand.java | 4 +-
.../table/distributed/command/GetAllCommand.java | 4 +-
.../distributed/command/GetAndDeleteCommand.java | 4 +-
.../distributed/command/GetAndReplaceCommand.java | 4 +-
.../distributed/command/GetAndUpsertCommand.java | 4 +-
.../table/distributed/command/GetCommand.java | 4 +-
.../distributed/command/InsertAllCommand.java | 4 +-
.../table/distributed/command/InsertCommand.java | 4 +-
.../table/distributed/command/MultiKeyCommand.java | 4 +-
.../table/distributed/command/ReplaceCommand.java | 4 +-
.../distributed/command/ReplaceIfExistCommand.java | 4 +-
.../distributed/command/SingleKeyCommand.java | 4 +-
.../distributed/command/TransactionalCommand.java | 4 +-
.../distributed/command/UpsertAllCommand.java | 4 +-
.../table/distributed/command/UpsertCommand.java | 4 +-
.../command/response/MultiRowsResponse.java | 4 +-
.../command/response/SingleRowResponse.java | 4 +-
.../distributed/command/scan/ScanCloseCommand.java | 4 +-
.../distributed/command/scan/ScanInitCommand.java | 4 +-
.../command/scan/ScanRetrieveBatchCommand.java | 4 +-
.../table/distributed/raft/PartitionListener.java | 4 +-
.../raft/RebalanceRaftGroupEventsListener.java | 4 +-
.../raft/snapshot/InitPartitionSnapshotReader.java | 2 +-
.../distributed/raft/snapshot/PartitionAccess.java | 28 +
.../raft/snapshot/PartitionSnapshotStorage.java | 12 +-
.../snapshot/PartitionSnapshotStorageFactory.java | 16 +-
.../raft/snapshot/PartitionSnapshotWriter.java | 2 +-
.../distributed/storage/InternalTableImpl.java | 4 +-
.../distributed/storage/VersionedRowStore.java | 4 +-
.../ignite/internal/table/event/TableEvent.java | 4 +-
.../internal/table/event/TableEventParameters.java | 4 +-
.../internal/table/message/HasDataRequest.java | 4 +-
.../internal/table/message/HasDataResponse.java | 4 +-
.../internal/table/message/TableMessageGroup.java | 4 +-
.../apache/ignite/internal/table/package-info.java | 4 +-
.../ignite/internal/utils/RebalanceUtil.java | 4 +-
.../TupleMarshallerFixlenOnlyBenchmark.java | 4 +-
.../TupleMarshallerVarlenOnlyBenchmark.java | 4 +-
.../TableDistributedConfigurationModuleTest.java | 4 +-
.../table/ColocationHashCalculationTest.java | 4 +-
.../org/apache/ignite/internal/table/Example.java | 4 +-
.../internal/table/InteropOperationsTest.java | 4 +-
.../table/KeyValueBinaryViewOperationsTest.java | 4 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 4 +-
.../internal/table/KeyValueViewOperationsTest.java | 4 +-
.../internal/table/MessagingServiceTestUtils.java | 2 +-
.../internal/table/MutableRowTupleAdapterTest.java | 4 +-
.../table/RecordBinaryViewOperationsTest.java | 4 +-
.../internal/table/RecordViewOperationsTest.java | 4 +-
.../internal/table/SchemaValidationTest.java | 4 +-
.../ignite/internal/table/TxAbstractTest.java | 4 +-
.../apache/ignite/internal/table/TxLocalTest.java | 4 +-
.../table/distributed/TableManagerTest.java | 4 +-
.../raft/PartitionCommandListenerTest.java | 4 +-
.../raft/RebalanceRaftGroupEventsListenerTest.java | 4 +-
.../table/impl/DummyInternalTableImpl.java | 4 +-
.../table/impl/DummySchemaManagerImpl.java | 4 +-
.../internal/table/impl/TestTupleBuilder.java | 4 +-
.../table/type/NumericTypesSerializerTest.java | 4 +-
.../org/apache/ignite/table/TupleImplTest.java | 4 +-
modules/transactions/build.gradle | 6 +-
.../ignite/internal/tx/InternalTransaction.java | 4 +-
.../apache/ignite/internal/tx/LockException.java | 4 +-
.../org/apache/ignite/internal/tx/LockManager.java | 4 +-
.../org/apache/ignite/internal/tx/Timestamp.java | 4 +-
.../org/apache/ignite/internal/tx/TxManager.java | 4 +-
.../java/org/apache/ignite/internal/tx/TxMeta.java | 4 +-
.../org/apache/ignite/internal/tx/TxState.java | 4 +-
.../java/org/apache/ignite/internal/tx/Waiter.java | 4 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 4 +-
.../internal/tx/impl/IgniteTransactionsImpl.java | 4 +-
.../ignite/internal/tx/impl/TransactionImpl.java | 4 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 4 +-
.../internal/tx/message/TxFinishRequest.java | 6 +-
.../internal/tx/message/TxFinishResponse.java | 6 +-
.../ignite/internal/tx/message/TxMessageGroup.java | 4 +-
.../internal/tx/storage/state/TxStateStorage.java | 43 +-
.../state/rocksdb/TxStateRocksDbStorage.java | 306 ++-
.../internal/tx/AbstractLockManagerTest.java | 4 +-
.../ignite/internal/tx/HeapLockManagerTest.java | 4 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 4 +-
.../tx/storage/state/TxStateStorageTest.java | 74 +-
modules/vault/build.gradle | 6 +-
.../ItPersistencePropertiesVaultServiceTest.java | 4 +-
.../persistence/ItPersistentVaultServiceTest.java | 4 +-
.../apache/ignite/internal/vault/VaultEntry.java | 4 +-
.../apache/ignite/internal/vault/VaultManager.java | 4 +-
.../apache/ignite/internal/vault/VaultService.java | 4 +-
.../vault/persistence/PersistentVaultService.java | 4 +-
.../ignite/internal/vault/VaultManagerTest.java | 4 +-
.../ignite/internal/vault/VaultServiceTest.java | 4 +-
.../vault/inmemory/InMemoryVaultServiceTest.java | 4 +-
.../vault/inmemory/InMemoryVaultService.java | 2 +-
parent/pom.xml | 3 +-
settings.gradle | 4 +-
3360 files changed, 19843 insertions(+), 12901 deletions(-)
delete mode 100644 buildscripts/java-library.gradle
create mode 100644 buildscripts/sql-parser-generator.gradle
delete mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/call/cluster/topology/TopologyCallInput.java
delete mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/call/StatusCallInput.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/call/UrlCallInput.java
create mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/exception/handler/ClusterNotInitializedExceptionHandler.java
delete mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/exception/handler/ShowConfigExceptionHandler.java
delete mode 100644 modules/cli/src/main/java/org/apache/ignite/cli/core/style/component/CommonMessages.java
create mode 100644 modules/client-common/src/main/java/org/apache/ignite/internal/client/proto/ClientBinaryTupleUtils.java
delete mode 100644 modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/rest/exception/ClusterNotInitializedException.java
delete mode 100644 modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/rest/exception/handler/ClusterNotInitializedExceptionHandler.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/ComponentNotStartedException.java
delete mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteRandom.java
create mode 100644 modules/core/src/testFixtures/java/org/apache/ignite/internal/util/IgniteRandom.java
create mode 100644 modules/metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/MetricExportersLoadingTest.java
create mode 100644 modules/metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/TestMetricsSource.java
create mode 100644 modules/metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/TestPullMetricExporter.java
create mode 100644 modules/metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/TestPushMetricExporter.java
create mode 100644 modules/metrics/src/integrationTest/resources/META-INF/services/org.apache.ignite.internal.metrics.exporters.MetricExporter
create mode 100644 modules/metrics/src/main/java/org/apache/ignite/internal/metrics/MetricProvider.java
create mode 100644 modules/metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/BasicMetricExporter.java
create mode 100644 modules/metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/MetricExporter.java
create mode 100644 modules/metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/PushMetricExporter.java
create mode 100644 modules/platforms/cpp/common/Bits.h
create mode 100644 modules/platforms/cpp/common/Bytes.h
create mode 100644 modules/platforms/cpp/common/Config.h
create mode 100644 modules/platforms/cpp/common/Uuid.h
create mode 100644 modules/platforms/cpp/tests/CMakeLists.txt
create mode 100644 modules/platforms/cpp/tests/testBits.cpp
create mode 100644 modules/platforms/cpp/tests/testBytes.cpp
create mode 100644 modules/platforms/cpp/tests/testUuid.cpp
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Internal.Generators/Apache.Ignite.Internal.Generators.csproj
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Internal.Generators/ErrorGroupsGenerator.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Internal.Generators/ExceptionTemplate.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Internal.Generators/ExceptionsGenerator.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Internal.Generators/GeneratorUtils.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/ErrorGroupTests.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/ExceptionsTests.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/StringExtensions.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Table/Poco2.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/ErrorGroups.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/IgniteClientConnectionException.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/IgniteException.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/BinaryTupleBuilderExtensions.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/BinaryTupleMethods.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/ByteSpanExtensions.cs
delete mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/MessagePackMethods.cs
delete mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/client/service/ItAbstractListenerSnapshotTest.java
delete mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/CounterListener.java
delete mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/CounterSnapshotFile.java
delete mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/GetValueCommand.java
delete mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/IncrementAndGetCommand.java
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/counter/CounterListener.java
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/counter/CounterSnapshotFile.java
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/counter/GetValueCommand.java
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/counter/IncrementAndGetCommand.java
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/snasphot/SnapshotInMemoryStorageFactory.java
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/snasphot/TestWriteCommand.java
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/snasphot/UpdateCountRaftListener.java
delete mode 100644 modules/raft/src/test/java/org/apache/ignite/internal/raft/server/impl/RaftServerImpl.java
create mode 100644 modules/raft/src/testFixtures/java/org/apache/ignite/internal/raft/server/impl/RaftServerImpl.java
create mode 100644 modules/raft/src/testFixtures/java/org/apache/ignite/raft/client/service/ItAbstractListenerSnapshotTest.java
create mode 100644 modules/rest-api/src/main/java/org/apache/ignite/internal/rest/exception/ClusterNotInitializedException.java
create mode 100644 modules/rest-api/src/main/java/org/apache/ignite/internal/rest/exception/handler/ClusterNotInitializedExceptionHandler.java
create mode 100644 modules/rest-api/src/main/java/org/apache/ignite/internal/rest/exception/handler/JavaExceptionHandler.java
create mode 100644 modules/rocksdb-common/src/main/java/org/apache/ignite/internal/rocksdb/BusyRocksIteratorAdapter.java
create mode 100644 modules/rocksdb-common/src/main/java/org/apache/ignite/internal/rocksdb/flush/RocksDbFlushListener.java
create mode 100644 modules/rocksdb-common/src/main/java/org/apache/ignite/internal/rocksdb/flush/RocksDbFlusher.java
delete mode 100644 modules/runner/src/integrationTest/sql/sqlite/select1/select1.test_slow
create mode 100644 modules/runner/src/integrationTest/sql/sqlite/select1/select1_p1.test
create mode 100644 modules/runner/src/integrationTest/sql/sqlite/select1/select1_p2.test
create mode 100644 modules/runner/src/integrationTest/sql/sqlite/select1/select1_p3.test_ignored
create mode 100644 modules/runner/src/integrationTest/sql/sqlite/select1/select1_p4.test_ignored
create mode 100644 modules/runner/src/integrationTest/sql/sqlite/select1/select1_p5.test_ignored
create mode 100644 modules/runner/src/integrationTest/sql/sqlite/select1/select1_p6.test_ignored
create mode 100644 modules/runner/src/integrationTest/sql/sqlite/select1/select1_p7.test_ignored
create mode 100644 modules/runner/src/integrationTest/sql/sqlite/select1/select1_p8.test_ignored
create mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/sorted/SortedIndexRow.java
create mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/sorted/SortedIndexRowKey.java
create mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/sorted/SortedIndexTree.java
create mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/sorted/io/SortedIndexTreeInnerIo.java
create mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/sorted/io/SortedIndexTreeIo.java
create mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/sorted/io/SortedIndexTreeLeafIo.java
create mode 100644 modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/sorted/io/SortedIndexTreeMetaIo.java
delete mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbFlushListener.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/PartitionAccess.java