This is an automated email from the ASF dual-hosted git repository.
mpochatkin pushed a change to branch IGNITE-22394
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 1c4eb2b9ce Merge branch 'main' into IGNITE-22394
add 1783a4a3de IGNITE-22541 Fix bool handling in C++ binary_tuple_builder
(#3984)
add de847a9fa2 IGNITE-22589 Rename
StopNodeOrHaltFailureHandlerConfigurationSchema.timeout to timeoutMillis (#3991)
add 9b42e3e815 IGNITE-22073 Sql. Add processing of the provided query
timeout (#3953)
add aab9667bda IGNITE-22589 Fix FailureProcessor initialization (#3994)
add 6e7f25d33c IGNITE-22569 Java thin: fix SqlBatchException propagation
(#3982)
add 055b61f97c IGNITE-22539 .NET: Add JobTarget (#3993)
add 351c235c4e IGNITE-22540 .NET: Add ReceiverDescriptor to Data Streamer
(#3996)
add bd01805e70 IGNITE-22574 Ignite CLI: Allow to pass multiple files with
cluster configuration for init command. (#3986)
add f32aacace8 IGNITE-22532 Fix --metastorage-group option description
(#3992)
add 43260e7b05 IGNITE-22533 Extra error when trying to run non-existant
sql file (#3997)
add 9841802211 IGNITE-22224 Rework embedded mode API (#3908)
add 879936c865 IGNITE-22460 Rename libignite-client.so to
libignite3-client.so (#3998)
add b2695def59 IGNITE-22525 .NET: Rename JobStatus to JobState and vice
versa (#3999)
add 154d928095 IGNITE-22594 Fix compilation (#4000)
add 4ada0383ed IGNITE-22583 Get rid of byte[] in messages (#3990)
add 7bfa2a0fe8 IGNITE-20503 Sql. Support big clusters by mapping service
(#3966)
add 9a428ca373 IGNITE-22566 Add C++ docs generation to gradle (#4001)
add 2efe7840f4 IGNITE-22526 Rename job_state to job_status and vice versa
(#4002)
add 3acfe1c97e IGNITE-22264 Fix startup instructions in Ignite examples
(#3967)
add fa931b1c02 IGNITE-22426 Move deployment code to separate package
(#4008)
add 8a1a15a0d7 IGNITE-22364 Remove daemon mode in zip distribution (#3940)
add cb69d4f6f2 IGNITE-22527 C++ Add parameter object to Compute API (#4013)
add 079225e576 IGNITE-22603 Add InetSocketAddress caching for
DefaultMessagingService (#4011)
add ae3800ea82 IGNITE-22588 Fix performance of JDBC driver (#4012)
add 29b2e2b7fb IGNITE-22611 SQL. Statement should not extends AutoClosable
(#4015)
add 12c13ef177 IGNITE-22612 SQL highlighter sometimes fails (#4016)
add dc962df81b IGNITE-22434 Do not inherit TaskExecution from JobExecution
(#4007)
add 692ecdedc2 IGNITE-22478 Use single argument in Compute API (#3926)
add ea59431e01 IGNITE-22578 Sql. Extend test coverage for numeric to/from
decimal cast with overflow (#3985)
add 07dc45afc3 IGNITE-22614 Get rid of @Marshallable in package
org.apache.ignite.internal.partition.replicator.network (#4019)
add 9bc629a998 IGNITE-22618 Remove MvPartitionStorage#rowsCount (#4020)
add d9576076e1 IGNITE-22615 Get rid of @Marshallable in ReplicaRequest
(#4023)
add 787e868ede IGNITE-22632 Handle cluster configuration file reading
error (#4024)
add bd896fcf87 IGNITE-22597 Use SMFullThrowable when exception in user's
state machine happens. (#4022)
add a456027af3 IGNITE-22507 Add `MvPartitionStorage#estimatedSize` method
(#4025)
add a4ea716e72 IGNITE-22631 Get rid of @Marshallable in
org.apache.ignite.internal.tx.message (#4026)
add d6397cdaec IGNITE-22629 Disable
ItReplicaStateManagerTest.testReplicaStatesManagement (#4030)
add c8a03bc7f5 IGNITE-22410 Implement rebalance triggers for zone based
partitions (#3943)
add b68f771f3d IGNITE-22556 Fix exception in
IndexBuildController.requireMvTableStorageNonNull (#4033)
add 3279ae75f9 IGNITE-22448: Sql. Incorrect error message when aggregate
function is called with UUID type. (#4006)
add e1dca925ef IGNITE-22651 Add @Nullable for NetworkMessage fields for
generated classes (#4037)
add c76d322e12 IGNITE-22171: Sql. Row cast fails with NPE (#4010)
add cccb376830 IGNITE-22567 Add `containsAll` to `RecordView` and
`KeyValueView` (#4018)
add f8de23cd24 IGNITE-22408 Create MSI package for ODBC (#4041)
add 88782c880e IGNITE-22601 Pass instance of ValidationManager to
CmgRaftGroupListener constructor. (#4036)
add 548acde12f Bump org.rocksdb:rocksdbjni from 9.2.1 to 9.3.1 (#4039)
add f62f133bec Bump org.openapi.generator from 7.6.0 to 7.7.0 (#4029)
add d132b9f7db IGNITE-21512 Enable a test in ItSchemaSyncMultiNodeTest
(#4050)
add 086494ee07 IGNITE-22673 Fix predicate in candition of
IndexMetaStorage#saveToMetastore (#4051)
add 0799d6068b IGNITE-22674 Fix predicate in condition of
UpdateLogImpl#saveSnapshot (#4052)
add df2174bb0c IGNITE-22648: make linux packaging more native (#4046)
add 065700d196 IGNITE-22675 Recovery CLI commands don't accept profile
option (#4053)
add 4d2a6da039 IGNITE-22677 Fix C++ dependency handling for MacOS (#4054)
add 876a202f88 IGNITE-22415 Search for table in older versions of catalog
(#3885)
add 07fd38004c IGNITE-22668 Fix batch commit in StripeAwareLogManager
(#4047)
add 20a498fb49 IGNITE-22686 Fix ODBC MSI package build (#4058)
add 84b760b54c IGNITE-22315 Make raft-client starting only once and only
with raft-client and replica together (#3956)
add 4687dae71d IGNITE-22633 Catalog compaction. Implement choosing of
coordinator (#4042)
add eae38b8ee3 IGNITE-22521 Enable
ItIgniteNodeRestartTest.testSequentialAsyncTableCreationThenAlterZoneThenRestartOnMsSnapshot
(#4027)
add 044ad2a822 IGNITE-21303 Fix the way we save new assignments for
"resetPartitions" command (#4038)
add 8e0c592198 IGNITE-15624: Calcite. get rid of tests required support of
different connections in logical tests. (#4028)
add 57c07ee68d IGNITE-22465 Recover zones' replicas and pending/stable
events on a node restart (#4043)
add a5140d30ba IGNITE-22693 Add protection against internal thread
hijacking to PartitionManager (#4061)
add 2cc4e11381 IGNITE-22676 Add protection against internal thread
hijacking to IgniteCatalog (#4060)
add a00da3d757 IGNITE-22629 Fix
ItReplicaStateManagerTest.testReplicaStatesManagement (#4040)
add be15cc7c95 IGNITE-22150 .NET: Add PartitionManager API (#4062)
add a4d39fb194 IGNITE-22519: Sql. Numerics. Conversion produces incorrect
results (#4044)
add 2edaa01d00 IGNITE-22698 Sql. Extend test coverage for numeric
comparison with literal wider than numeric type (#4063)
add 618a0a9d83 Bump junit5 from 5.10.2 to 5.10.3 (#4003)
add d41170dd2d Bump net.bytebuddy:byte-buddy from 1.14.17 to 1.14.18
(#4064)
add 60b76cf961 IGNITE-22682 Use IndexMeta in FullStateTransferIndexChooser
(#4067)
add 942d94ddb3 IGNITE-22523 Thin client: reserve op code range for
extensions (#4071)
add c00b97c18d Bump org.junit.platform:junit-platform-testkit from 1.10.2
to 1.10.3 (#4004)
add eb7b4e58b1 IGNITE-22713: Sql. Move timeout scheduling code to
ExecutionContext (#4073)
add 496fe683cd IGNITE-22353 Basic Python DB API Driver (#4075)
add 644536bf1f IGNITE-22708 Do not start distributionZoneRebalanceEngineV2
without feature flag (#4074)
add 5446df3bac IGNITE-22714 Use IndexMeta in PartitionReplicaListener
(#4077)
add 0077758ad6 IGNITE-22709 Use IndexMeta in ChangeIndexStatusTask (#4072)
add c3ad113dd4 Bump io.github.goooler.shadow from 8.1.7 to 8.1.8 (#3995)
add b5575f5bde IGNITE-22720 Get rid of
CatalogIndexDescriptor#txWaitCatalogVersion (#4080)
add ae982d7fea IGNITE-22310 Do not log slow network processing in storage
threads (#4079)
add 75ed4f4c76 IGNITE-21771 Removed unnecessary TODO (#4084)
add a0811f97b3 IGNITE-22728 Switch to a different Gradle CMake plugin.
(#4082)
add 8f510c448a IGNITE-22736 Fix log buffers position change by
unmarshalling process (#4086)
add bc6c427574 IGNITE-22715 Support HybridTimestamp in Network
serialization (#4078)
add ba1624502f IGNITE-22737 Cleanup comments in the platforms native code
(#4087)
add 26f4e67810 IGNITE-22619 Add `InternalTable#estimatedSize` method
(#4065)
add 78a4b821b5 IGNITE-22750 log node start errors in error logging level
(#4093)
add 7dedc06ea2 IGNITE-22581 Add planner test to verify numeric type
coercion of source for INSERT, UPDATE and MERGE operators (#4045)
add 146e803bf7 IGNITE-22735 Sql. Avoid double parsing of sql queries
(#4085)
add 514949e722 IGNITE-22555 Fixed assertion in
ReplicaStateManager.onPrimaryElected (#4055)
add 2b7dbb6643 IGNITE-22710 Add exception translation to Transaction
implementations (#4070)
add b8d08f16b7 IGNITE-16444 Get rid of unnecessary TODO (#4097)
add ca69fcd96b IGNITE-22690 Fixe tx cleanup triggered by commit partition
primary replica election from non-primary node (#4083)
add 86b8dcbe3d IGNITE-22764 Increase readability in MvPartitionStorage
tests (#4101)
add cc2ea0d1a2 Bump org.assertj:assertj-core from 3.26.0 to 3.26.3 (#4076)
add 2592e6de34 IGNITE-20137 Fixed
ItIgniteNodeRestartTest#testOneNodeRestartWithGap (#4098)
add 7fc402d3f5 IGNITE-22292 Move LogSyncer out of Loza and RaftServer.
(#4094)
add 9c4f2a784d IGNITE-22616 Implement
AbstractPageMemoryMvPartitionStorage#estimatedSize (#4102)
add 96095a157b IGNITE-22770 Fix testBytesSentReceived fail on short
version (#4107)
add 9b271581a7 IGNITE-22285 Implement Embedded Data Streamer with Receiver
(#4103)
add 08222ebae4 IGNITE-22761 Disable WAL in RocksDB used to spill volatile
Raft logs on disk (#4113)
add 1c9366450f IGNITE-22699 Fix anti-hijack protection of
containsAllAsync() (#4115)
add 918becac48 IGNITE-20525 Fix
ItBuildIndexTest#testChangePrimaryReplicaOnMiddleBuildIndex (#4112)
add e22683ef88 IGNITE-22780 Sql. Fix cast from VARCHAR to TS WITH LOCAL TZ
(#4116)
add d81a14651c IGNITE-22185
DistributionZoneCausalityDataNodesTest.testEmptyDataNodesOnZoneCreationBeforeTopologyEventAndZoneInitialisation
became flaky on the main (#4095)
add 95fc4dfc10 Bump org.rocksdb:rocksdbjni from 9.3.1 to 9.4.0 (#4089)
add 1d2f377a58 Bump com.github.spotbugs from 6.0.18 to 6.0.19 (#4081)
add 6aeb623fff Bump jline from 3.26.2 to 3.26.3 (#4105)
new dc017ee38d Merge branch 'refs/heads/main' into IGNITE-22394
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.idea/inspectionProfiles/Project_Default.xml | 5 +-
docs/_docs/ignite-cli-tool.adoc | 2 +-
examples/README.md | 78 ++-
examples/config/ignite-config.conf | 23 +-
.../ignite/example/AbstractExamplesTest.java | 24 +-
.../apache/ignite/example/sql/SqlApiExample.java | 31 +-
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 22 +-
.../PersistentPageMemoryStorageExample.java | 26 +-
.../example/storage/RocksDbStorageExample.java | 26 +-
.../storage/VolatilePageMemoryStorageExample.java | 26 +-
.../ignite/example/table/KeyValueViewExample.java | 22 +-
.../example/table/KeyValueViewPojoExample.java | 22 +-
.../ignite/example/table/RecordViewExample.java | 22 +-
.../example/table/RecordViewPojoExample.java | 22 +-
.../ignite/example/tx/TransactionsExample.java | 22 +-
gradle/libs.versions.toml | 22 +-
.../src/main/java/org/apache/ignite/Ignite.java | 2 +-
.../src/main/java/org/apache/ignite/Ignition.java | 91 ---
.../java/org/apache/ignite/IgnitionManager.java | 126 ----
.../org/apache/ignite/InitParametersBuilder.java | 123 ----
.../java/org/apache/ignite/compute/ComputeJob.java | 35 +-
.../org/apache/ignite/compute/IgniteCompute.java | 99 +--
.../org/apache/ignite/compute/JobDescriptor.java | 78 ++-
.../compute/{ComputeJob.java => TaskState.java} | 49 +-
.../org/apache/ignite/compute/TaskStatus.java} | 38 +-
.../apache/ignite/compute/task/MapReduceJob.java | 43 +-
.../apache/ignite/compute/task/MapReduceTask.java | 18 +-
.../apache/ignite/compute/task/TaskExecution.java | 47 +-
.../{compute => deployment}/DeploymentUnit.java | 4 +-
.../version/UnitVersion.java | 2 +-
.../{compute => deployment}/version/Version.java | 2 +-
.../version/VersionParseException.java | 2 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 65 +-
.../ignite/marshaling/ByteArrayMarshaler.java | 56 ++
.../JavaSerializationByteArrayMarshallilng.java | 70 +++
.../org/apache/ignite/marshaling/Marshaler.java | 57 ++
.../ignite/marshaling/MarshallingException.java} | 31 +-
.../apache/ignite/marshaling/TupleMarshaller.java} | 17 +-
.../UnsupportedObjectTypeMarshalingException.java | 53 ++
.../org/apache/ignite/sql/SqlBatchException.java | 22 +-
.../java/org/apache/ignite/sql/SqlException.java | 9 +-
.../main/java/org/apache/ignite/sql/Statement.java | 2 +-
.../apache/ignite/table/DataStreamerReceiver.java | 11 +-
.../apache/ignite/table/DataStreamerTarget.java | 9 +-
.../java/org/apache/ignite/table/KeyValueView.java | 23 +-
.../apache/ignite/table/ReceiverDescriptor.java | 48 +-
.../java/org/apache/ignite/table/RecordView.java | 23 +-
.../version/VersionTest.java | 2 +-
.../ignite/marshaling/ByteArrayMarshalerTest.java | 167 +++++
modules/catalog-dsl/build.gradle | 2 +
.../catalog/ItCatalogApiThreadingTest.java | 184 ++++++
.../ignite/internal/catalog/ItCatalogDslTest.java | 138 +---
.../org/apache/ignite/internal/catalog/Pojo.java | 89 +++
.../apache/ignite/internal/catalog/PojoKey.java} | 25 +-
.../apache/ignite/internal/catalog/PojoValue.java | 82 +++
modules/catalog/build.gradle | 6 +
...ItCatalogCompactionCoordinatorChoosingTest.java | 118 ++++
.../internal/catalog/CatalogManagerImpl.java | 23 +-
.../commands/AbstractCreateIndexCommand.java | 4 +-
.../internal/catalog/commands/CatalogUtils.java | 10 +-
.../catalog/commands/CreateHashIndexCommand.java | 4 +-
.../catalog/commands/CreateSortedIndexCommand.java | 4 +-
.../catalog/commands/CreateTableCommand.java | 7 +-
.../descriptors/CatalogHashIndexDescriptor.java | 20 +-
.../descriptors/CatalogIndexDescriptor.java | 25 +-
.../descriptors/CatalogSortedIndexDescriptor.java | 19 +-
.../internal/catalog/events/CatalogEvent.java | 6 +-
.../storage/AbstractChangeIndexStatusEntry.java | 17 +-
.../internal/catalog/storage/RenameIndexEntry.java | 2 -
.../internal/catalog/storage/UpdateLogImpl.java | 11 +-
.../ignite/internal/catalog/CatalogIndexTest.java | 68 --
.../catalog/CatalogManagerRecoveryTest.java | 24 -
.../ignite/internal/catalog/CatalogTableTest.java | 1 -
...ractChangeIndexStatusCommandValidationTest.java | 1 -
.../catalog/commands/CatalogUtilsTest.java | 3 +-
.../CatalogHashIndexDescriptorTest.java | 2 +-
.../CatalogSortedIndexDescriptorTest.java | 2 +-
.../storage/CatalogEntrySerializationTest.java | 4 +-
.../catalog/storage/UpdateLogImplTest.java | 12 +-
.../ignite/internal/catalog/CatalogTestUtils.java | 17 +
...liCommandTestNotInitializedIntegrationBase.java | 2 +-
.../commands/cluster/init/ItClusterInitTest.java | 2 +-
.../internal/rest/ItGeneratedRestClientTest.java | 32 +-
.../recovery/reset/ResetPartitionsCallInput.java | 4 -
.../restart/RestartPartitionsCallInput.java | 4 -
.../recovery/{ => states}/PartitionStatesCall.java | 2 +-
.../{ => states}/PartitionStatesCallInput.java | 6 +-
.../ignite/internal/cli/commands/Options.java | 13 +-
.../commands/cluster/init/ClusterInitOptions.java | 30 +-
.../partitions/reset/ResetPartitionsCommand.java | 7 +-
.../partitions/reset/ResetPartitionsMixin.java | 10 -
.../reset/ResetPartitionsReplCommand.java | 7 +-
.../restart/RestartPartitionsCommand.java | 7 +-
.../partitions/restart/RestartPartitionsMixin.java | 10 -
.../restart/RestartPartitionsReplCommand.java | 7 +-
.../partitions/states/PartitionStatesCommand.java | 11 +-
.../partitions/states/PartitionStatesMixin.java | 10 -
.../states/PartitionStatesReplCommand.java | 11 +-
.../commands/treesitter/parser/SqlTokenType.java | 8 +-
.../handler/PicocliExecutionExceptionHandler.java | 3 +-
.../internal/cli/core/flow/builder/Flows.java | 30 +-
.../internal/cli/commands/CliCommandTestBase.java | 13 +
.../internal/cli/commands/ProfileMixinTest.java | 61 ++
.../internal/cli/commands/ProfileOptionTest.java | 97 +++
.../cli/commands/cluster/ClusterInitReplTest.java} | 21 +-
.../cli/commands/cluster/ClusterInitTest.java | 102 ++-
.../internal/cli/commands/flow/FlowTest.java | 53 ++
.../cluster-configuration-with-default.conf | 4 +
.../client/proto/ClientBinaryTupleUtils.java | 8 +-
.../internal/client/proto/ClientMessagePacker.java | 15 +-
.../client/proto/ClientMessageUnpacker.java | 13 +-
.../ignite/internal/client/proto/ClientOp.java | 14 +-
.../internal/client/proto/ErrorExtensions.java | 2 +
.../client/proto/StreamerReceiverSerializer.java | 138 +++-
.../jdbc/proto/JdbcQueryCursorHandler.java | 10 -
.../internal/jdbc/proto/JdbcStatementType.java | 2 +-
.../jdbc/proto/event/JdbcBatchExecuteRequest.java | 25 +-
.../proto/event/JdbcBatchPreparedStmntRequest.java | 28 +-
.../internal/jdbc/proto/event/JdbcColumnMeta.java | 235 +++----
.../jdbc/proto/event/JdbcQueryExecuteRequest.java | 31 +-
.../jdbc/proto/event/JdbcQuerySingleResult.java | 46 +-
.../proto/ClientMessagePackerUnpackerTest.java | 8 +-
.../handler/ClientInboundMessageHandler.java | 37 +-
.../ignite/client/handler/JdbcHandlerBase.java | 50 +-
.../client/handler/JdbcQueryCursorHandlerImpl.java | 65 --
.../client/handler/JdbcQueryEventHandlerImpl.java | 43 +-
.../ClientComputeExecuteColocatedRequest.java | 8 +-
.../ClientComputeExecuteMapReduceRequest.java | 11 +-
.../compute/ClientComputeExecuteRequest.java | 21 +-
.../compute/ClientComputeGetStateRequest.java | 13 +
.../jdbc/ClientJdbcQueryMetadataRequest.java | 49 --
.../handler/requests/jdbc/JdbcMetadataCatalog.java | 2 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 52 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 80 +--
.../table/ClientTupleContainsAllKeysRequest.java | 61 ++
.../handler/JdbcQueryEventHandlerImplTest.java | 14 +-
.../apache/ignite/client/ClientOperationType.java | 9 +-
.../org/apache/ignite/client/IgniteClient.java | 4 +-
.../org/apache/ignite/client/RetryReadPolicy.java | 1 +
.../apache/ignite/internal/client/ClientUtils.java | 76 +--
.../ignite/internal/client/TcpClientChannel.java | 35 +-
.../ignite/internal/client/TcpIgniteClient.java | 2 +-
.../internal/client/compute/ClientCompute.java | 130 ++--
.../client/compute/ClientJobExecution.java | 47 +-
.../client/compute/ClientTaskExecution.java | 11 +-
.../ignite/internal/client/sql/ClientSql.java | 50 +-
.../internal/client/table/AbstractClientView.java | 2 +-
.../internal/client/table/ClientDataStreamer.java | 16 +-
.../client/table/ClientKeyValueBinaryView.java | 37 +-
.../internal/client/table/ClientKeyValueView.java | 37 +-
.../client/table/ClientPartitionManager.java | 6 -
.../client/table/ClientRecordBinaryView.java | 37 +-
.../internal/client/table/ClientRecordView.java | 37 +-
.../ignite/internal/client/table/ClientTables.java | 2 +-
.../internal/client/tx/ClientTransaction.java | 2 +-
.../internal/client/tx/ClientTransactions.java | 2 +-
.../apache/ignite/client/ClientApiArchTest.java | 5 +-
.../apache/ignite/client/ClientComputeTest.java | 106 +++-
.../client/ClientKeyValueBinaryViewTest.java | 28 +
.../ignite/client/ClientKeyValueViewTest.java | 29 +
.../apache/ignite/client/ClientMetricsTest.java | 4 +-
.../ignite/client/ClientPutGetBenchmark.java | 1 -
.../apache/ignite/client/ClientRecordViewTest.java | 41 ++
.../org/apache/ignite/client/ClientTableTest.java | 53 ++
.../apache/ignite/client/ConfigurationTest.java | 3 +-
.../org/apache/ignite/client/DataStreamerTest.java | 83 ++-
.../client/ObservableTimestampPropagationTest.java | 2 +-
.../ignite/client/PartitionAwarenessTest.java | 30 +-
.../apache/ignite/client/RequestBalancingTest.java | 9 +-
.../org/apache/ignite/client/RetryPolicyTest.java | 7 +-
.../apache/ignite/client/ServerMetricsTest.java | 8 +-
.../ignite/client/TestClientHandlerModule.java | 4 +-
.../java/org/apache/ignite/client/TestServer.java | 6 +-
.../apache/ignite/client/fakes/FakeCompute.java | 59 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 17 +-
.../ignite/client/fakes/FakeIgniteTables.java | 14 +-
.../ignite/client/fakes/FakeInternalTable.java | 41 +-
.../ignite/internal/client/ClientUtilsTest.java | 3 +-
.../cluster/management/ItClusterManagerTest.java | 32 +
.../management/raft/ItCmgRaftServiceTest.java | 15 +-
.../management/topology/ItLogicalTopologyTest.java | 7 +-
.../management/ClusterManagementGroupManager.java | 105 +++-
...anager.java => ClusterStateStorageManager.java} | 4 +-
.../management/raft/CmgRaftGroupListener.java | 51 +-
.../cluster/management/raft/ValidationManager.java | 37 +-
.../cluster/management/raft/ValidationResult.java | 6 +-
.../AbstractClusterStateStorageManagerTest.java | 6 +-
.../management/raft/CmgRaftGroupListenerTest.java | 11 +-
.../RocksDbClusterStateStorageManagerTest.java | 2 +-
.../raft/TestClusterStateStorageManagerTest.java | 2 +-
.../internal/cluster/management/MockNode.java | 2 +-
.../ignite/internal/deployment/DeployFiles.java | 2 +-
.../deployment/ItDeploymentUnitFailoverTest.java | 2 +-
.../internal/deployment/ItDeploymentUnitTest.java | 2 +-
.../apache/ignite/internal/deployment/Unit.java | 2 +-
.../internal/deployunit/DefaultNodeCallback.java | 4 +-
.../deployunit/DeployMessagingService.java | 2 +-
.../internal/deployunit/DeploymentManagerImpl.java | 2 +-
.../deployunit/DeploymentUnitAccessor.java | 2 +-
.../deployunit/DeploymentUnitAccessorImpl.java | 2 +-
.../deployunit/DeploymentUnitAcquiredWaiter.java | 2 +-
.../deployunit/DisposableDeploymentUnit.java | 2 +-
.../internal/deployunit/DownloadTracker.java | 2 +-
.../internal/deployunit/FileDeployerService.java | 2 +-
.../internal/deployunit/IgniteDeployment.java | 2 +-
.../ignite/internal/deployunit/UnitStatus.java | 2 +-
.../ignite/internal/deployunit/UnitStatuses.java | 2 +-
.../internal/deployunit/UnitVersionStatus.java | 2 +-
.../exception/DeploymentUnitNotFoundException.java | 2 +-
.../DeploymentUnitUnavailableException.java | 2 +-
.../metastore/ClusterEventCallbackImpl.java | 2 +-
.../metastore/DeploymentUnitFailover.java | 2 +-
.../deployunit/metastore/DeploymentUnitStore.java | 2 +-
.../metastore/DeploymentUnitStoreImpl.java | 2 +-
.../deployunit/metastore/NodeEventCallback.java | 2 +-
.../metastore/status/ClusterStatusKey.java | 2 +-
.../deployunit/metastore/status/NodeStatusKey.java | 2 +-
.../metastore/status/SerializeUtils.java | 4 +-
.../metastore/status/UnitClusterStatus.java | 2 +-
.../metastore/status/UnitNodeStatus.java | 2 +-
.../ignite/deployment/FileDeployerServiceTest.java | 2 +-
.../deployment/UnitStatusesSerializerTest.java | 2 +-
.../metastore/DeploymentUnitStoreImplTest.java | 4 +-
.../deployunit/DeploymentManagerImplTest.java | 2 +-
.../deployunit/DeploymentUnitAccessorImplTest.java | 2 +-
.../DeploymentUnitAcquiredWaiterTest.java | 2 +-
.../deployunit/metastore/status/UnitKeyTest.java | 2 +-
modules/compute/build.gradle | 2 +
.../ignite/internal/compute/ItComputeBaseTest.java | 107 +++-
.../internal/compute/ItComputeErrorsBaseTest.java | 12 +-
.../internal/compute/ItComputeTestEmbedded.java | 47 +-
.../internal/compute/ItComputeTestStandalone.java | 12 +-
.../internal/compute/ItExecutionsCleanerTest.java | 5 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 2 +-
.../ignite/internal/compute/ItMapReduceTest.java | 77 +--
.../internal/compute/ItWorkerShutdownTest.java | 7 +-
.../threading/ItComputeApiThreadingTest.java | 30 +-
.../internal/compute/utils/InteractiveJobs.java | 30 +-
.../internal/compute/utils/InteractiveTasks.java | 31 +-
.../apache/ignite/internal/compute/ConcatJob.java | 7 +-
.../apache/ignite/internal/compute/FailingJob.java | 4 +-
.../ignite/internal/compute/GetNodeNameJob.java | 4 +-
.../apache/ignite/internal/compute/MapReduce.java | 16 +-
.../internal/compute/NonEmptyConstructorJob.java | 4 +-
.../org/apache/ignite/internal/compute/Pojo.java} | 44 +-
.../{NonEmptyConstructorJob.java => PojoJob.java} | 26 +-
.../apache/ignite/internal/compute/SleepJob.java | 6 +-
.../internal/compute/AntiHijackIgniteCompute.java | 18 +-
.../internal/compute/AntiHijackJobExecution.java | 2 +-
.../ignite/internal/compute/ComputeComponent.java | 45 +-
.../internal/compute/ComputeComponentImpl.java | 45 +-
.../internal/compute/ComputeJobFailover.java | 25 +-
.../ignite/internal/compute/ComputeUtils.java | 28 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 109 +++-
.../internal/compute/IgniteComputeInternal.java | 10 +-
.../apache/ignite/internal/compute/JobStarter.java | 4 +-
.../internal/compute/RemoteExecutionContext.java | 28 +-
.../internal/compute/TaskExecutionWrapper.java | 25 +-
...ecution.java => TaskToJobExecutionWrapper.java} | 44 +-
.../internal/compute/executor/ComputeExecutor.java | 12 +-
.../compute/executor/ComputeExecutorImpl.java | 34 +-
.../internal/compute/loader/JobContextManager.java | 4 +-
.../compute/message/DeploymentUnitMsg.java | 2 +-
.../internal/compute/message/ExecuteRequest.java | 3 +-
.../compute/messaging/ComputeMessaging.java | 14 +-
.../compute/streamer/StreamerReceiverJob.java | 64 ++
.../compute/task/AntiHijackTaskExecution.java | 33 +-
.../compute/task/DelegatingTaskExecution.java | 9 +-
.../ignite/internal/compute/task/JobSubmitter.java | 4 +-
.../compute/task/TaskExecutionInternal.java | 74 +--
.../compute/ClassLoaderExceptionsMapperTest.java | 2 +-
.../internal/compute/ComputeComponentImplTest.java | 74 ++-
.../internal/compute/IgniteComputeImplTest.java | 28 +-
.../compute/executor/ComputeExecutorTest.java | 37 +-
.../compute/loader/JobClassLoaderFactoryTest.java | 14 +-
.../compute/loader/JobContextManagerTest.java | 6 +-
.../compute/util/DummyIgniteDeployment.java | 2 +-
.../apache/ignite/internal/compute/UnitJob.java | 4 +-
.../apache/ignite/internal/compute/UnitJob.java | 4 +-
modules/core/build.gradle | 5 -
.../ignite/internal/compute/JobStateImpl.java | 2 +-
.../internal/compute/JobTaskStatusMapper.java | 84 +++
.../{JobStateImpl.java => TaskStateImpl.java} | 42 +-
.../internal/lang/IgniteExceptionMapperUtil.java | 50 +-
.../apache/ignite/internal/sql/StatementImpl.java | 6 -
.../org/apache/ignite/internal/util/ByteUtils.java | 42 ++
.../apache/ignite/internal/util/Cancellable.java | 4 +-
.../apache/ignite/internal/util/IgniteUtils.java | 8 +-
.../org/apache/ignite/internal/util/ViewUtils.java | 116 ++++
.../communication/MessageCollectionItemType.java | 6 +-
.../ignite/internal/lang/ExceptionUtilsTest.java | 56 ++
.../apache/ignite/internal/util/ByteUtilsTest.java | 30 +
.../asserts/CompletableFutureAssert.java | 29 +-
.../testframework/matchers/TaskStateMatcher.java | 133 ++++
...niteDistributionZoneManagerNodeRestartTest.java | 9 +-
.../distributionzones/DistributionZoneManager.java | 18 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 84 ++-
.../DistributionZoneRebalanceEngineV2.java | 253 ++++++++
.../RebalanceRaftGroupEventsListener.java | 18 +-
.../distributionzones/rebalance/RebalanceUtil.java | 78 +--
...a => ZoneRebalanceRaftGroupEventsListener.java} | 340 +++++-----
.../{RebalanceUtil.java => ZoneRebalanceUtil.java} | 407 +++++-------
.../DistributionZoneCausalityDataNodesTest.java | 4 +-
.../DistributionZoneRebalanceEngineTest.java | 25 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 18 +-
modules/failure-handler/build.gradle | 1 +
.../failure/handlers/FailureHandlerTest.java | 22 +-
.../ignite/internal/failure/FailureProcessor.java | 34 +-
.../ignite/internal/failure/NodeStopper.java} | 11 +-
.../failure/handlers/AbstractFailureHandler.java | 8 +-
.../internal/failure/handlers/FailureHandler.java | 10 +-
.../failure/handlers/NoOpFailureHandler.java | 4 +-
.../failure/handlers/StopNodeFailureHandler.java | 19 +-
.../handlers/StopNodeOrHaltFailureHandler.java | 28 +-
...odeOrHaltFailureHandlerConfigurationSchema.java | 4 +-
.../internal/failure/FailureProcessorTest.java | 42 +-
.../internal/failure/NoOpFailureProcessor.java | 11 +-
modules/index/build.gradle | 1 +
.../ignite/internal/index/ItBuildIndexTest.java | 277 ++++----
...IndexNodeFinishedRwTransactionsCheckerTest.java | 15 +-
.../internal/index/ChangeIndexStatusTask.java | 44 +-
.../index/ChangeIndexStatusTaskController.java | 5 +-
.../index/ChangeIndexStatusTaskScheduler.java | 7 +
.../index/IndexAvailabilityController.java | 15 +-
.../internal/index/IndexBuildController.java | 10 +-
.../ignite/internal/index/IndexBuildTask.java | 8 +-
.../internal/index/IndexBuildingManager.java | 9 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 2 +
.../internal/index/ChangeIndexStatusTaskTest.java | 40 +-
.../IndexAvailabilityControllerRestorerTest.java | 2 +-
.../index/IndexAvailabilityControllerTest.java | 12 +-
.../internal/index/IndexBuildControllerTest.java | 2 +
.../internal/jdbc/ItJdbcMetadataSelfTest.java | 42 +-
.../apache/ignite/jdbc/AbstractJdbcSelfTest.java | 20 +-
.../ignite/jdbc/ItJdbcAuthenticationTest.java | 7 +-
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 103 +++
.../ignite/jdbc/ItJdbcComplexQuerySelfTest.java | 4 +-
.../ignite/jdbc/ItJdbcMultiStatementSelfTest.java | 49 ++
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 67 ++
.../jdbc/JdbcClientQueryCursorHandler.java | 14 -
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 503 +++++++--------
.../internal/jdbc/JdbcPreparedStatement.java | 2 +-
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 77 +--
.../apache/ignite/internal/jdbc/JdbcStatement.java | 47 +-
.../ignite/internal/jdbc/JdbcResultSetTest.java | 2 +-
.../internal/metastorage/dsl/Conditions.java | 45 +-
.../ignite/internal/metastorage/dsl/Operation.java | 5 +-
.../internal/metastorage/dsl/Operations.java | 36 +-
.../internal/metastorage/dsl/SimpleCondition.java | 5 +-
.../internal/metastorage/dsl/StatementResult.java | 10 +-
.../metastorage/server/time/ClusterTime.java | 5 +
.../impl/ItIdempotentCommandCacheTest.java | 8 +-
.../impl/ItMetaStorageManagerImplTest.java | 2 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 2 +-
.../ItMetaStorageMultipleNodesRocksDbTest.java | 2 +-
...tMetaStorageSafeTimePropagationRocksDbTest.java | 2 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 2 +-
.../metastorage/impl/ItMetaStorageServiceTest.java | 5 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 4 +-
.../metastorage/command/GetAllCommand.java | 7 +-
.../internal/metastorage/command/GetCommand.java | 3 +-
.../metastorage/command/GetPrefixCommand.java | 3 +-
.../metastorage/command/GetRangeCommand.java | 5 +-
.../command/MetaStorageWriteCommand.java | 27 +-
.../metastorage/command/PutAllCommand.java | 5 +-
.../internal/metastorage/command/PutCommand.java | 5 +-
.../metastorage/command/RemoveAllCommand.java | 3 +-
.../metastorage/command/RemoveCommand.java | 3 +-
.../metastorage/impl/ElectionListener.java} | 21 +-
.../impl/MetaStorageLeaderElectionListener.java | 8 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 11 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 44 +-
.../metastorage/server/KeyValueStorage.java | 1 -
.../server/persistence/RocksDbKeyValueStorage.java | 5 +-
.../server/raft/MetaStorageListener.java | 24 +-
.../server/raft/MetaStorageWriteHandler.java | 29 +-
.../metastorage/server/time/ClusterTimeImpl.java | 10 +-
.../impl/IdempotentCommandCacheTest.java | 25 +-
.../impl/MetaStorageRocksDbRangeTest.java | 2 +-
.../RocksDbCompactionKeyValueStorageTest.java | 2 +-
.../server/RocksDbKeyValueStorageTest.java | 2 +-
.../impl/StandaloneMetaStorageManager.java | 4 +-
.../server/SimpleInMemoryKeyValueStorage.java | 11 +-
.../server/TestRocksDbKeyValueStorage.java | 2 +-
.../network/processor/MessageGeneratorUtils.java | 75 +++
.../messages/MessageBuilderGenerator.java | 67 +-
.../processor/messages/MessageImplGenerator.java | 45 +-
.../serialization/BaseMethodNameResolver.java | 7 +-
.../MessageCollectionItemTypeConverter.java | 7 +-
.../MessageDeserializerGenerator.java | 4 +-
.../serialization/MessageReaderMethodResolver.java | 4 +-
.../serialization/MessageWriterMethodResolver.java | 4 +-
.../network/TrackableNetworkMessageHandler.java | 23 +-
.../internal/network/annotations/Transferable.java | 2 +
.../network/serialization/MessageReader.java | 8 +
.../network/serialization/MessageWriter.java | 10 +
.../internal/network/DefaultMessagingService.java | 39 +-
.../network/direct/DirectMessageReader.java | 18 +
.../network/direct/DirectMessageWriter.java | 11 +
.../internal/network/messages/AllTypesMessage.java | 3 +
.../network/utils/ClusterServiceTestUtils.java | 2 +-
modules/partition-replicator/build.gradle | 1 +
.../replicator/ItReplicaLifecycleTest.java | 416 ++++++++++--
.../PartitionReplicaLifecycleManager.java | 680 +++++++++++++++++++-
.../PartitionCommandsMarshallerImpl.java | 2 +
.../network/PartitionReplicationMessageGroup.java | 10 +-
.../network/command/FinishTxCommand.java | 21 +-
.../network/command/TimedBinaryRowMessage.java | 9 +-
.../network/command/UpdateAllCommand.java | 5 +-
.../replicator/network/command/UpdateCommand.java | 9 +-
.../network/command/WriteIntentSwitchCommand.java | 15 +-
.../network/disaster/LocalPartitionStateEnum.java | 9 +
.../disaster/LocalPartitionStateMessage.java | 17 +-
.../network/raft/SnapshotTxDataResponse.java | 6 +-
...caRequest.java => GetEstimatedSizeRequest.java} | 15 +-
.../replication/MultipleRowPkReplicaRequest.java | 14 +-
.../replication/MultipleRowReplicaRequest.java | 14 +-
.../replication/ReadOnlyReplicaRequest.java | 6 +-
.../replication/ReadWriteReplicaRequest.java | 8 +-
.../network/replication/RequestType.java | 10 +
.../replication/SingleRowPkReplicaRequest.java | 14 +-
.../replication/SingleRowReplicaRequest.java | 14 +-
.../network/replication/SwapRowReplicaRequest.java | 14 +-
.../disaster/LocalPartitionStateEnumTest.java} | 20 +-
.../placementdriver/LeasePlacementDriver.java | 2 +-
.../message/LeaseGrantedMessage.java | 14 +-
.../internal/placementdriver/LeaseUpdater.java | 36 +-
.../placementdriver/leases/LeaseTracker.java | 8 +-
.../negotiation/LeaseAgreement.java | 21 +-
.../negotiation/LeaseNegotiator.java | 33 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 3 +-
modules/platforms/build.gradle | 42 +-
modules/platforms/cpp/CMakeLists.txt | 6 +-
modules/platforms/cpp/Doxyfile | 2 +-
modules/platforms/cpp/cmake/dependencies.cmake | 57 +-
modules/platforms/cpp/cmake/ignite_test.cmake | 4 +
modules/platforms/cpp/ignite/client/CMakeLists.txt | 10 +-
.../cpp/ignite/client/compute/compute.cpp | 24 +-
.../platforms/cpp/ignite/client/compute/compute.h | 67 +-
.../cpp/ignite/client/compute/job_descriptor.h | 126 ++++
.../cpp/ignite/client/compute/job_execution.cpp | 6 +-
.../cpp/ignite/client/compute/job_execution.h | 29 +-
.../ignite/client/compute/job_execution_options.h | 4 +-
.../cpp/ignite/client/compute/job_state.h | 31 +-
.../cpp/ignite/client/compute/job_status.h | 33 +-
.../ignite/client/detail/compute/compute_impl.cpp | 88 ++-
.../ignite/client/detail/compute/compute_impl.h | 30 +-
.../client/detail/compute/job_execution_impl.cpp | 29 +-
.../client/detail/compute/job_execution_impl.h | 26 +-
.../cpp/ignite/client/detail/table/table_impl.h | 13 +-
.../platforms/cpp/ignite/common/big_decimal.cpp | 10 -
.../platforms/cpp/ignite/common/big_integer.cpp | 237 ++-----
modules/platforms/cpp/ignite/common/big_integer.h | 27 +-
.../compute/job_state.h => common/binary_object.h} | 46 +-
modules/platforms/cpp/ignite/common/detail/bits.h | 2 +-
modules/platforms/cpp/ignite/common/detail/bytes.h | 2 +-
modules/platforms/cpp/ignite/common/detail/mpi.cpp | 14 +
modules/platforms/cpp/ignite/common/detail/mpi.h | 43 +-
.../cpp/ignite/common/detail/server_version.h | 2 +-
modules/platforms/cpp/ignite/common/error_codes.h | 35 +-
modules/platforms/cpp/ignite/common/ignite_error.h | 44 +-
.../platforms/cpp/ignite/network/CMakeLists.txt | 9 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 14 +-
.../cpp/ignite/odbc/config/configuration.h | 35 ++
modules/platforms/cpp/ignite/odbc/odbc_error.h | 21 +
.../ignite/odbc/query/column_metadata_query.cpp | 32 +-
.../cpp/ignite/odbc/query/column_metadata_query.h | 3 -
.../platforms/cpp/ignite/odbc/query/data_query.cpp | 69 +-
.../platforms/cpp/ignite/odbc/query/data_query.h | 7 +
.../platforms/cpp/ignite/odbc/sql_connection.cpp | 15 +-
modules/platforms/cpp/ignite/odbc/sql_connection.h | 36 ++
modules/platforms/cpp/ignite/protocol/utils.cpp | 18 +-
modules/platforms/cpp/ignite/protocol/utils.h | 9 +
.../cpp/ignite/tuple/binary_tuple_builder.cpp | 3 +-
modules/platforms/cpp/ignite/tuple/tuple_test.cpp | 137 +++-
.../platforms/cpp/tests/client-test/CMakeLists.txt | 2 +-
.../cpp/tests/client-test/compute_test.cpp | 177 ++++--
.../cpp/tests/client-test/ignite_runner_suite.h | 1 +
.../client-test/schema_synchronization_test.cpp | 3 +-
.../platforms/cpp/tests/odbc-test/CMakeLists.txt | 2 +-
.../cpp/tests/odbc-test/odbc_connection.h | 6 +-
.../cpp/tests/test-common/basic_auth_test_suite.h | 4 +-
.../cpp/tests/test-common/ignite_runner.h | 3 +-
.../Apache.Ignite.Tests/BasicAuthenticatorTests.cs | 5 +-
.../Compute/ComputeClusterAwarenessTests.cs | 19 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 265 ++++----
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 27 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 1 +
.../PartitionAwarenessRealClusterTests.cs | 9 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 24 +-
.../Proto/ColocationHashTests.cs | 42 +-
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 170 +++--
.../Table/PartitionManagerTests.cs | 180 ++++++
.../Table/SchemaSynchronizationTest.cs | 19 +-
.../dotnet/Apache.Ignite.Tests/TestUtils.cs | 3 +
.../dotnet/Apache.Ignite.Tests/ToStringTests.cs | 5 +-
.../dotnet/Apache.Ignite/ClientOperationType.cs | 7 +-
.../dotnet/Apache.Ignite/Compute/ICompute.cs | 61 +-
.../dotnet/Apache.Ignite/Compute/IJobExecution.cs | 2 +-
.../dotnet/Apache.Ignite/Compute/IJobTarget.cs} | 21 +-
.../dotnet/Apache.Ignite/Compute/JobDescriptor.cs | 4 +-
.../dotnet/Apache.Ignite/Compute/JobState.cs | 46 +-
.../dotnet/Apache.Ignite/Compute/JobStatus.cs | 48 +-
.../dotnet/Apache.Ignite/Compute/JobTarget.cs | 87 +++
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 61 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 171 ++---
.../Apache.Ignite/Internal/Compute/JobExecution.cs | 10 +-
.../Apache.Ignite/Internal/IgniteClientInternal.cs | 8 +-
.../Apache.Ignite/Internal/Network/ClusterNode.cs | 28 +
.../Apache.Ignite/Internal/Proto/ClientOp.cs | 3 +
.../Internal/Proto/ClientOpExtensions.cs | 1 +
.../Internal/Proto/MsgPack/MsgPackWriter.cs | 18 +
.../Internal/Table/DataStreamerWithReceiver.cs | 22 +-
.../Apache.Ignite/Internal/Table/HashPartition.cs} | 24 +-
.../Apache.Ignite/Internal/Table/KeyValueView.cs | 27 +-
.../Internal/Table/PartitionManager.cs | 224 +++++++
.../Apache.Ignite/Internal/Table/RecordView.cs | 28 +-
.../Serialization/IRecordSerializerHandler.cs | 24 +
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 5 +
.../dotnet/Apache.Ignite/RetryReadPolicy.cs | 1 +
.../Apache.Ignite/Table/IDataStreamerTarget.cs | 27 +-
.../dotnet/Apache.Ignite/Table/IPartition.cs} | 19 +-
.../Apache.Ignite/Table/IPartitionManager.cs | 61 ++
.../platforms/dotnet/Apache.Ignite/Table/ITable.cs | 5 +
.../Apache.Ignite/Table/ReceiverDescriptor.cs | 42 ++
modules/platforms/python/.gitignore | 13 +
modules/platforms/python/CMakeLists.txt | 54 ++
modules/platforms/python/LICENSE | 14 +
modules/platforms/python/MANIFEST.in | 7 +
modules/platforms/python/NOTICE | 5 +
modules/platforms/python/README.md | 48 ++
.../odbc-test => python/cpp_module}/CMakeLists.txt | 39 +-
modules/platforms/python/cpp_module/module.cpp | 195 ++++++
.../python/cpp_module/module.h} | 14 +-
.../platforms/python/cpp_module/py_connection.cpp | 109 ++++
.../platforms/python/cpp_module/py_connection.h | 70 +++
modules/platforms/python/pyignite3/__init__.py | 149 +++++
modules/platforms/python/requirements/install.txt | 3 +
modules/platforms/python/requirements/tests.txt | 7 +
modules/platforms/python/setup.py | 158 +++++
.../platforms/python/tests/__init__.py | 11 -
.../platforms/python/tests/conftest.py | 13 +-
.../platforms/python/tests/test_connect.py | 33 +-
modules/platforms/python/tests/util.py | 155 +++++
.../apache/ignite/internal/raft/RaftManager.java | 3 -
.../apache/ignite/internal/raft/ItLozaTest.java | 237 +++++--
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 1 +
.../java/org/apache/ignite/internal/raft/Loza.java | 6 -
.../internal/raft/server/impl/JraftServerImpl.java | 12 +-
.../internal/raft/storage/LogStorageFactory.java | 1 +
.../storage/impl/DefaultLogStorageFactory.java | 25 +-
.../raft/storage/impl/RocksDbSharedLogStorage.java | 12 +-
.../raft/storage/impl/StripeAwareLogManager.java | 29 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 10 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 5 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 12 +-
.../jraft/rpc/impl/ActionRequestProcessor.java | 8 +-
.../raft/jraft/rpc/impl/SMCompactedThrowable.java | 3 +
.../raft/jraft/storage/impl/RocksDbSpillout.java | 1 +
.../ignite/internal/raft/TestLozaFactory.java | 1 +
.../ItPlacementDriverReplicaSideTest.java | 7 +-
.../ignite/internal/replicator/ReplicaImpl.java | 7 +-
.../ignite/internal/replicator/ReplicaManager.java | 179 +++---
.../ignite/internal/replicator/ReplicaService.java | 4 +-
.../replicator/ZonePartitionReplicaImpl.java | 15 +-
.../command/SafeTimePropagatingCommand.java | 18 +-
.../replicator/message/ReplicaMessageGroup.java | 6 +
.../replicator/message/ReplicaMessageUtils.java | 59 ++
.../replicator/message/ReplicaRequest.java | 11 +-
...Request.java => ReplicationGroupIdMessage.java} | 18 +-
.../message}/TablePartitionIdMessage.java | 21 +-
.../replicator/message/TimestampAware.java | 20 +-
...icaRequest.java => ZonePartitionIdMessage.java} | 36 +-
.../replicator/PlacementDriverReplicaSideTest.java | 4 +-
.../rest/exception/handler/ErrorHandlingTest.java | 1 +
.../ignite/internal/rest/AbstractRestTestBase.java | 31 +-
...terStateHttpServerFilterNotInitializedTest.java | 2 +-
.../rest/ItNotInitializedClusterRestTest.java | 4 +-
.../internal/rest/ItRestAddressReportTest.java | 102 ---
.../ignite/internal/rest/ItRestPortsTest.java | 7 +-
.../org/apache/ignite/internal/rest/RestNode.java | 26 +-
.../cluster/ItClusterManagementControllerTest.java | 2 +-
.../rest/compute/ItComputeControllerTest.java | 6 +-
.../ignite/internal/rest/ssl/ItRestSslTest.java | 13 +-
.../rest/authentication/IgniteSecurityFilter.java | 2 +
.../deployment/DeploymentManagementController.java | 2 +-
.../handler/VersionParseExceptionHandler.java | 2 +-
modules/runner/build.gradle | 3 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 32 +-
.../ignite/internal/benchmark/InsertBenchmark.java | 29 +-
.../ignite/internal/benchmark/SelectBenchmark.java | 6 +-
.../cluster/management/ItClusterInitTest.java | 33 +-
.../ItDistributedConfigurationPropertiesTest.java | 2 +-
.../ItDistributedConfigurationStorageTest.java | 2 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 4 +-
.../runner/app/AbstractSchemaChangeTest.java | 43 +-
.../internal/runner/app/IgniteRunnerTest.java | 25 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 59 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 33 +-
.../runner/app/ItIgniteNodeRestartTest.java | 73 ++-
...ItIgnitionTest.java => ItIgniteServerTest.java} | 119 ++--
.../internal/runner/app/ItNoThreadsLeftTest.java | 29 +-
.../runner/app/ItReplicaStateManagerTest.java | 65 +-
.../internal/runner/app/ItSingleNodeTest.java | 46 +-
.../internal/runner/app/ItTablesApiTest.java | 30 +-
.../runner/app/PlatformBenchmarkNodeRunner.java | 6 +-
.../runner/app/PlatformTestNodeRunner.java | 128 ++--
.../app/client/ItAbstractThinClientTest.java | 23 +-
.../client/ItThinClientComputeMarshallingTest.java | 140 +++++
.../runner/app/client/ItThinClientComputeTest.java | 234 ++++---
.../client/ItThinClientPartitionAwarenessTest.java | 9 +-
.../ItSchemaForwardCompatibilityTest.java | 3 +-
.../schemasync/ItSchemaSyncMultiNodeTest.java | 3 -
.../schemasync/ItSchemaSyncSingleNodeTest.java | 27 +-
.../apache/ignite/internal/start/ItStartTest.java | 26 +-
.../streamer/ItAbstractDataStreamerTest.java | 64 +-
.../streamer/ItServerDataStreamerTest.java | 23 -
.../ignite/internal/table/ItDurableFinishTest.java | 6 +-
.../ignite/internal/table/ItInternalTableTest.java | 32 +-
.../main/java/org/apache/ignite/IgniteServer.java | 194 ++++++
.../java/org/apache/ignite/InitParameters.java | 13 -
.../org/apache/ignite/InitParametersBuilder.java | 210 +++++++
.../org/apache/ignite/internal/app/IgniteImpl.java | 337 +++++-----
.../apache/ignite/internal/app/IgniteRunner.java | 14 +-
.../ignite/internal/app/IgniteServerImpl.java | 289 +++++++++
.../apache/ignite/internal/app/IgnitionImpl.java | 256 --------
.../ignite/internal/app/LifecycleManager.java | 19 +-
.../internal/component/RestAddressReporter.java | 83 ---
.../threading/PublicApiThreadingIgniteCatalog.java | 148 +++++
.../ignite/lang/ClusterInitFailureException.java} | 29 +-
.../lang/ClusterNotInitializedException.java} | 26 +-
.../ignite/lang/NodeNotStartedException.java} | 24 +-
.../apache/ignite/lang/NodeStartException.java} | 28 +-
.../component/RestAddressReporterTest.java | 125 ----
.../DistributedConfigurationStorageTest.java | 5 +-
.../ignite/internal/BaseIgniteRestartTest.java | 73 +--
.../java/org/apache/ignite/internal/Cluster.java | 94 +--
.../internal/ClusterPerClassIntegrationTest.java | 7 +-
.../internal/ClusterPerTestIntegrationTest.java | 6 +-
.../ignite/internal/IgniteIntegrationTest.java | 31 -
.../internal/junit/StopAllIgnitesAfterTests.java | 66 --
.../testframework/TestIgnitionManager.java | 19 +-
.../ignite/internal/schema/BinaryRowMatcher.java | 44 +-
.../org/apache/ignite/internal/ssl/ItSslTest.java | 26 +-
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 99 +++
.../engine/ItCastToTsWithLocalTimeZoneTest.java | 596 ++++++++++++++++++
.../internal/sql/engine/ItDataTypesTest.java | 442 +++++++++----
.../ignite/internal/sql/engine/ItDmlTest.java | 2 +-
.../sql/engine/ItDynamicParameterTest.java | 38 +-
.../internal/sql/engine/ItFunctionsTest.java | 3 +-
.../sql/engine/ItPkOnlyTableCrossApiTest.java | 2 +-
.../internal/sql/sqllogic/ItSqlLogicTest.java | 41 +-
.../sql/threading/ItSqlApiThreadingTest.java | 1 -
.../sql/aggregate/aggregates/test_avg.test | 7 +-
.../sql/aggregate/aggregates/test_sum.test | 9 +
.../aggregate/group/test_group_by_distinct.test | 10 +-
.../sql/basic_queries/test_simple_table.test | 2 +-
.../integrationTest/sql/cast/test_cast_bigint.test | 6 +-
.../sql/cast/test_cast_decimal.test | 2 -
.../integrationTest/sql/cast/test_cast_float.test | 8 +-
.../integrationTest/sql/cast/test_cast_int.test | 4 +-
.../integrationTest/sql/cast/test_cast_real.test | 8 +-
.../sql/cast/test_cast_smallint.test | 4 +-
.../sql/cast/test_cast_tinyint.test | 4 +-
.../generic/test_in_list_of_single_element.test | 10 +-
.../integrationTest/sql/set/test_intersect.test | 2 +-
.../sql/types/decimal/test_decimal.test | 22 +
.../integrationTest/sql/types/row/test_row.test | 49 ++
.../sql/update/test_big_string_update.test | 47 ++
.../sql/update/test_big_string_update.test_ignore | 96 ---
.../sql/update/test_null_update.test | 40 ++
.../sql/update/test_null_update.test_ignore | 194 ------
.../update/test_repeated_string_update.test_ignore | 62 --
.../sql/update/test_string_update.test_ignore | 66 --
.../test_string_update_many_strings.test_ignore | 128 ----
.../sql/update/test_string_update_null.test_ignore | 40 --
.../update/test_string_update_rollback.test_ignore | 118 ----
.../test_string_update_rollback_null.test_ignore | 89 ---
.../sql/update/test_update.test_ignore | 80 ---
.../test_update_delete_same_tuple.test_ignore | 44 --
.../sql/update/test_update_from.test_ignore | 160 -----
.../update/test_update_many_updaters.test_ignore | 316 ----------
.../test_update_many_updaters_nulls.test_ignore | 119 ----
.../sql/update/test_update_mix.test_ignore | 75 ---
.../sql/update/test_update_same_value.test_ignore | 180 ------
.../ignite/internal/sql/api/IgniteSqlImpl.java | 9 +-
.../ignite/internal/sql/engine/QueryCancel.java | 107 +++-
.../sql/engine/QueryCancelledException.java | 22 +-
.../internal/sql/engine/SqlOperationContext.java | 6 +-
.../internal/sql/engine/SqlQueryProcessor.java | 73 ++-
.../sql/engine/exec/ExchangeServiceImpl.java | 2 +-
.../internal/sql/engine/exec/ExecutionContext.java | 26 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 128 +++-
.../sql/engine/exec/UpdatableTableImpl.java | 42 +-
.../sql/engine/exec/exp/ConverterUtils.java | 49 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 91 ++-
.../sql/engine/exec/exp/IgniteExpressions.java | 51 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 10 +-
.../sql/engine/exec/mapping/ExecutionTarget.java | 17 +-
.../sql/engine/exec/mapping/FragmentMapper.java | 6 +-
.../sql/engine/exec/mapping/MappingContext.java | 7 +-
.../AbstractTarget.java | 151 +++--
.../AllOfTarget.java | 10 +-
.../LargeClusterFactory.java} | 56 +-
.../OneOfTarget.java | 30 +-
.../PartitionedTarget.java | 46 +-
.../SomeOfTarget.java | 25 +-
.../exec/mapping/smallcluster/AbstractTarget.java | 42 +-
.../exec/mapping/smallcluster/AllOfTarget.java | 5 -
.../exec/mapping/smallcluster/OneOfTarget.java | 8 +-
.../mapping/smallcluster/PartitionedTarget.java | 7 +-
.../mapping/smallcluster/SmallClusterFactory.java | 19 +-
.../exec/mapping/smallcluster/SomeOfTarget.java | 5 -
.../sql/engine/message/QueryStartRequest.java | 15 +-
.../engine/prepare/IgniteSqlToRelConvertor.java | 43 ++
.../sql/engine/prepare/IgniteSqlValidator.java | 215 ++++---
.../sql/engine/prepare/KeyValueGetPlan.java | 2 +
.../sql/engine/prepare/KeyValueModifyPlan.java | 2 +
.../sql/engine/prepare/PlanningContext.java | 2 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 70 ++-
.../internal/sql/engine/rex/IgniteRexBuilder.java | 13 +
.../internal/sql/engine/sql/ParserServiceImpl.java | 19 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 16 +
.../ignite/internal/sql/engine/util/Commons.java | 22 -
.../internal/sql/engine/util/IgniteMath.java | 204 +++++-
.../internal/sql/engine/util/IgniteResource.java | 7 +
.../internal/sql/engine/util/Primitives.java | 27 +
.../ignite/internal/sql/engine/util/RexUtils.java | 6 +-
.../internal/sql/engine/util/cache/Cache.java | 14 +
.../engine/util/cache/CaffeineCacheFactory.java | 10 +
.../internal/sql/api/StatementBuilderImplTest.java | 16 +-
.../sql/engine/benchmarks/MappingBenchmark.java | 180 ++++++
.../sql/engine/exec/ExecutionServiceImplTest.java | 219 ++++++-
.../engine/exec/NoOpExecutableTableRegistry.java | 27 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 3 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 111 +++-
.../mapping/ExecutionTargetFactorySelfTest.java | 284 +++++++++
.../sql/engine/exec/rel/AbstractExecutionTest.java | 7 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 4 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 2 +-
.../exec/rel/TableScanNodeExecutionTest.java | 4 +-
.../sql/engine/framework/TestBuilders.java | 31 +-
.../internal/sql/engine/framework/TestIndex.java | 15 +-
.../internal/sql/engine/framework/TestNode.java | 3 +-
.../sql/engine/planner/AbstractPlannerTest.java | 14 +
.../sql/engine/planner/DynamicParametersTest.java | 18 +-
.../sql/engine/planner/PlannerTimeoutTest.java | 4 +-
.../planner/datatypes/BaseTypeCoercionTest.java | 16 +
.../datatypes/MergeSourcesCoercionTest.java | 700 +++++++++++++++++++++
.../NumericBinaryOperationsTypeCoercionTest.java | 10 +-
.../NumericComparisonTypeCoercionTest.java | 10 +-
.../NumericInsertSourcesCoercionTest.java | 642 +++++++++++++++++++
...st.java => NumericSetOperatorCoercionTest.java} | 28 +-
.../NumericUpdateSourcesCoercionTest.java | 687 ++++++++++++++++++++
.../sql/engine/prepare/PrepareServiceImplTest.java | 101 ++-
.../pruning/PartitionPruningPredicateSelfTest.java | 14 +-
.../sql/engine/util/EmptyCacheFactory.java | 10 +
.../internal/sql/engine/util/QueryCheckerImpl.java | 4 +-
.../internal/sql/engine/util/SqlTestUtils.java | 70 ++-
.../internal/storage/MvPartitionStorage.java | 30 +-
.../storage/ThreadAssertingMvPartitionStorage.java | 12 +-
.../storage/index/StorageIndexDescriptorTest.java | 2 -
.../AbstractMvPartitionStorageConcurrencyTest.java | 54 +-
.../storage/AbstractMvPartitionStorageGcTest.java | 19 +-
.../storage/AbstractMvPartitionStorageTest.java | 379 ++++++++---
.../storage/AbstractMvTableStorageTest.java | 101 ++-
.../storage/impl/TestMvPartitionStorage.java | 54 +-
.../index/AbstractHashIndexStorageTest.java | 1 -
.../index/AbstractSortedIndexStorageTest.java | 1 -
.../storage/pagememory/StoragePartitionMeta.java | 55 +-
.../pagememory/StoragePartitionMetaFactory.java | 3 +-
.../storage/pagememory/StoragePartitionMetaIo.java | 25 +
.../mv/AbstractPageMemoryMvPartitionStorage.java | 35 +-
.../mv/AddWriteCommittedInvokeClosure.java | 10 +
.../pagememory/mv/CommitWriteInvokeClosure.java | 24 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 15 +
.../mv/VolatilePageMemoryMvPartitionStorage.java | 23 +
.../StoragePartitionMetaManagerTest.java | 7 +-
.../pagememory/StoragePartitionMetaTest.java | 48 +-
.../AbstractPageMemoryMvPartitionStorageTest.java | 11 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 4 +-
.../internal/storage/rocksdb/GarbageCollector.java | 2 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 26 +-
.../RocksDbMvPartitionStorageConcurrencyTest.java | 7 +
.../rocksdb/RocksDbMvPartitionStorageTest.java | 49 ++
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 19 +
modules/table/build.gradle | 1 +
.../ignite/distributed/ReplicaUnavailableTest.java | 13 +-
.../ReplicasSafeTimePropagationTest.java | 17 +-
.../ItDisasterRecoveryReconfigurationTest.java | 11 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 7 +-
.../rebalance/ItRebalanceDistributedTest.java | 129 +++-
.../rebalance/ItRebalanceRecoveryTest.java | 7 +-
.../ignite/internal/rebalance/ItRebalanceTest.java | 65 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 19 +-
.../ignite/internal/table/ItColocationTest.java | 44 +-
.../ignite/internal/table/ItEstimatedSizeTest.java | 182 ++++++
.../internal/table/ItTransactionRecoveryTest.java | 5 +-
.../internal/table/ItTxResourcesVacuumTest.java | 4 +-
.../threading/ItKvRecordApiThreadingTest.java | 3 +-
.../ItPartitionManagerApiThreadingTest.java | 120 ++++
.../threading/ItTablesApiThreadingTest.java | 1 -
.../ignite/internal/table/AbstractTableView.java | 24 +-
.../apache/ignite/internal/table/DataStreamer.java | 2 +-
.../internal/table/IgniteTablesInternal.java | 2 +
.../ignite/internal/table/InternalTable.java | 27 +-
.../internal/table/KeyValueBinaryViewImpl.java | 73 ++-
.../ignite/internal/table/KeyValueViewImpl.java | 95 ++-
.../table/PublicApiThreadingKeyValueView.java | 10 +
.../table/PublicApiThreadingRecordView.java | 10 +
.../internal/table/PublicApiThreadingViewBase.java | 8 +-
.../internal/table/RecordBinaryViewImpl.java | 67 +-
.../ignite/internal/table/RecordViewImpl.java | 85 ++-
.../internal/table/StreamerReceiverRunner.java | 63 ++
.../table/distributed/PublicApiThreadingTable.java | 7 +-
.../internal/table/distributed/TableManager.java | 422 ++++++++-----
.../internal/table/distributed/TableUtils.java | 1 -
.../disaster/DisasterRecoveryManager.java | 24 +-
.../disaster/ManualGroupUpdateRequest.java | 101 ++-
.../table/distributed/index/IndexMeta.java | 2 +-
.../table/distributed/index/IndexMetaStorage.java | 17 +-
.../table/distributed/index/MetaIndexStatus.java | 2 +-
.../table/distributed/raft/PartitionListener.java | 2 +-
.../snapshot/FullStateTransferIndexChooser.java | 191 ++----
.../snapshot/incoming/IncomingSnapshotCopier.java | 2 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 26 +-
.../replicator/IncompatibleSchemaException.java | 1 +
.../replicator/PartitionReplicaListener.java | 123 ++--
.../StaleTransactionOperationException.java | 5 +-
.../replicator/TransactionStateResolver.java | 25 +-
.../schema/PartitionCommandsMarshallerImpl.java | 2 +
.../distributed/storage/InternalTableImpl.java | 461 ++++++++------
.../PublicApiThreadingPartitionManager.java | 68 ++
.../UpdateCommandsMarshalingMicroBenchmark.java | 31 +-
.../table/KeyValueBinaryViewOperationsTest.java | 40 ++
.../internal/table/KeyValueViewOperationsTest.java | 34 +
.../table/RecordBinaryViewOperationsTest.java | 45 ++
.../internal/table/RecordViewOperationsTest.java | 37 ++
.../table/distributed/IndexCleanupTest.java | 17 +-
.../table/distributed/StorageCleanupTest.java | 76 +--
.../distributed/StorageUpdateHandlerTest.java | 26 +-
.../distributed/TableManagerRecoveryTest.java | 59 +-
.../table/distributed/TableManagerTest.java | 46 +-
.../PartitionRaftCommandsSerializationTest.java | 64 +-
.../index/BaseIndexMetaStorageTest.java | 4 +-
.../distributed/index/IndexMetaStorageTest.java | 21 +
.../raft/PartitionCommandListenerTest.java | 136 ++--
.../FullStateTransferIndexChooserTest.java | 37 +-
.../incoming/IncomingSnapshotCopierTest.java | 12 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 18 +-
.../PartitionReplicaListenerIndexLockingTest.java | 62 +-
.../replication/PartitionReplicaListenerTest.java | 305 +++++----
.../replicator/action/RequestTypeTest.java | 8 +
.../CheckCatalogVersionOnActionRequestTest.java | 2 +-
.../PartitionCommandsMarshallerImplTest.java | 6 +-
.../storage/InternalTableEstimatedSizeTest.java | 476 ++++++++++++++
.../distributed/storage/InternalTableImplTest.java | 5 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 9 +-
.../table/impl/DummyInternalTableImpl.java | 4 +-
.../tx/MismatchingTransactionOutcomeException.java | 5 +-
.../internal/tx/TransactionInternalException.java} | 61 +-
.../apache/ignite/internal/tx/TransactionMeta.java | 6 +
.../java/org/apache/ignite/internal/tx/TxMeta.java | 24 +-
.../org/apache/ignite/internal/tx/TxState.java | 8 +
.../org/apache/ignite/internal/tx/TxStateMeta.java | 32 +-
.../ignite/internal/tx/TxStateMetaAbandoned.java | 26 +-
.../ignite/internal/tx/TxStateMetaFinishing.java | 22 +
.../tx/impl/IgniteAbstractTransactionImpl.java | 31 +-
.../ignite/internal/tx/impl/OrphanDetector.java | 11 +-
.../tx/impl/PersistentTxStateVacuumizer.java | 6 +-
.../tx/impl/TransactionsExceptionMapperUtil.java | 85 +++
.../internal/tx/impl/TxCleanupRequestHandler.java | 85 ++-
.../internal/tx/impl/TxCleanupRequestSender.java | 10 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 13 +-
.../ignite/internal/tx/impl/TxMessageSender.java | 85 ++-
...uest.java => CleanupReplicatedInfoMessage.java} | 31 +-
.../TransactionMetaMessage.java} | 30 +-
.../internal/tx/message/TxCleanupMessage.java | 28 +-
.../tx/message/TxCleanupMessageResponse.java | 7 +-
.../tx/message/TxFinishReplicaRequest.java | 27 +-
.../ignite/internal/tx/message/TxMessageGroup.java | 14 +
.../ignite/internal/tx/message/TxMetaMessage.java | 50 ++
.../tx/message/TxStateCoordinatorRequest.java | 8 +-
...ponse.java => TxStateMetaAbandonedMessage.java} | 33 +-
...ponse.java => TxStateMetaFinishingMessage.java} | 30 +-
.../internal/tx/message/TxStateMetaMessage.java | 59 ++
.../internal/tx/message/TxStateResponse.java | 7 +-
.../message/WriteIntentSwitchReplicaRequest.java | 19 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 7 +-
.../org/apache/ignite/internal/tx/TxStateTest.java | 13 +-
packaging/README.md | 6 +-
packaging/db/build.gradle | 46 +-
packaging/db/linux/common.sh | 9 +-
packaging/db/linux/deb/postUninstall.sh | 5 +-
packaging/db/linux/postInstall.sh | 15 +-
packaging/db/linux/rpm/postUninstall.sh | 2 +-
packaging/db/linux/service/ignite3db.service | 2 +-
packaging/db/zip/linux/ignite3db | 61 +-
packaging/odbc/build.gradle | 46 +-
packaging/odbc/template.wxs | 38 ++
900 files changed, 24342 insertions(+), 12017 deletions(-)
delete mode 100644 modules/api/src/main/java/org/apache/ignite/Ignition.java
delete mode 100644
modules/api/src/main/java/org/apache/ignite/IgnitionManager.java
delete mode 100644
modules/api/src/main/java/org/apache/ignite/InitParametersBuilder.java
copy modules/api/src/main/java/org/apache/ignite/compute/{ComputeJob.java =>
TaskState.java} (51%)
copy modules/{platforms/cpp/ignite/client/compute/job_state.h =>
api/src/main/java/org/apache/ignite/compute/TaskStatus.java} (62%)
rename modules/api/src/main/java/org/apache/ignite/{compute =>
deployment}/DeploymentUnit.java (96%)
rename modules/api/src/main/java/org/apache/ignite/{compute =>
deployment}/version/UnitVersion.java (98%)
rename modules/api/src/main/java/org/apache/ignite/{compute =>
deployment}/version/Version.java (97%)
rename modules/api/src/main/java/org/apache/ignite/{compute =>
deployment}/version/VersionParseException.java (96%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/marshaling/ByteArrayMarshaler.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/marshaling/JavaSerializationByteArrayMarshallilng.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/marshaling/Marshaler.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryCancelledException.java
=> api/src/main/java/org/apache/ignite/marshaling/MarshallingException.java}
(51%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/Cancellable.java =>
api/src/main/java/org/apache/ignite/marshaling/TupleMarshaller.java} (72%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/marshaling/UnsupportedObjectTypeMarshalingException.java
rename modules/api/src/test/java/org/apache/ignite/{compute =>
deployment}/version/VersionTest.java (98%)
create mode 100644
modules/api/src/test/java/org/apache/ignite/marshaling/ByteArrayMarshalerTest.java
create mode 100644
modules/catalog-dsl/src/integrationTest/java/org/apache/ignite/internal/catalog/ItCatalogApiThreadingTest.java
create mode 100644
modules/catalog-dsl/src/integrationTest/java/org/apache/ignite/internal/catalog/Pojo.java
copy
modules/{cluster-management/src/test/java/org/apache/ignite/internal/cluster/management/raft/RocksDbClusterStateStorageManagerTest.java
=>
catalog-dsl/src/integrationTest/java/org/apache/ignite/internal/catalog/PojoKey.java}
(65%)
create mode 100644
modules/catalog-dsl/src/integrationTest/java/org/apache/ignite/internal/catalog/PojoValue.java
create mode 100644
modules/catalog/src/integrationTest/java/org/apache/ignite/internal/catalog/ItCatalogCompactionCoordinatorChoosingTest.java
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/recovery/{ =>
states}/PartitionStatesCall.java (98%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/recovery/{ =>
states}/PartitionStatesCallInput.java (96%)
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/ProfileOptionTest.java
copy
modules/{failure-handler/src/main/java/org/apache/ignite/internal/failure/handlers/NoOpFailureHandler.java
=>
cli/src/test/java/org/apache/ignite/internal/cli/commands/cluster/ClusterInitReplTest.java}
(63%)
mode change 100755 => 100644
create mode 100644
modules/cli/src/test/resources/cluster-configuration-with-default.conf
delete mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/jdbc/ClientJdbcQueryMetadataRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/ClientTupleContainsAllKeysRequest.java
rename
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/raft/{RaftStorageManager.java
=> ClusterStateStorageManager.java} (97%)
copy
modules/{failure-handler/src/main/java/org/apache/ignite/internal/failure/handlers/NoOpFailureHandler.java
=> compute/src/jobs/java/org/apache/ignite/internal/compute/Pojo.java} (52%)
mode change 100755 => 100644
copy
modules/compute/src/jobs/java/org/apache/ignite/internal/compute/{NonEmptyConstructorJob.java
=> PojoJob.java} (64%)
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{AntiHijackJobExecution.java
=> TaskToJobExecutionWrapper.java} (56%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/streamer/StreamerReceiverJob.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/compute/JobTaskStatusMapper.java
copy
modules/core/src/main/java/org/apache/ignite/internal/compute/{JobStateImpl.java
=> TaskStateImpl.java} (84%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/ViewUtils.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/matchers/TaskStateMatcher.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/DistributionZoneRebalanceEngineV2.java
copy
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/{RebalanceRaftGroupEventsListener.java
=> ZoneRebalanceRaftGroupEventsListener.java} (70%)
copy
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/{RebalanceUtil.java
=> ZoneRebalanceUtil.java} (64%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/Cancellable.java =>
failure-handler/src/main/java/org/apache/ignite/internal/failure/NodeStopper.java}
(75%)
copy
modules/metastorage/src/{test/java/org/apache/ignite/internal/metastorage/impl/MetaStorageRocksDbRangeTest.java
=>
main/java/org/apache/ignite/internal/metastorage/impl/ElectionListener.java}
(58%)
create mode 100644
modules/network-annotation-processor/src/main/java/org/apache/ignite/internal/network/processor/MessageGeneratorUtils.java
copy
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication/{SingleRowPkReplicaRequest.java
=> GetEstimatedSizeRequest.java} (66%)
copy
modules/partition-replicator/src/{main/java/org/apache/ignite/internal/partition/replicator/network/replication/ReadOnlyReplicaRequest.java
=>
test/java/org/apache/ignite/internal/partition/replicator/network/disaster/LocalPartitionStateEnumTest.java}
(67%)
create mode 100644 modules/platforms/cpp/ignite/client/compute/job_descriptor.h
copy modules/platforms/cpp/ignite/{client/compute/job_state.h =>
common/binary_object.h} (59%)
mode change 100755 => 100644 modules/platforms/cpp/ignite/common/error_codes.h
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/PartitionManagerTests.cs
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/Cancellable.java =>
platforms/dotnet/Apache.Ignite/Compute/IJobTarget.cs} (73%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Compute/JobTarget.cs
mode change 100755 => 100644
modules/platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TransactionMeta.java
=> platforms/dotnet/Apache.Ignite/Internal/Table/HashPartition.cs} (66%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Table/PartitionManager.cs
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/Cancellable.java =>
platforms/dotnet/Apache.Ignite/Table/IPartition.cs} (73%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Table/IPartitionManager.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Table/ReceiverDescriptor.cs
create mode 100644 modules/platforms/python/.gitignore
create mode 100644 modules/platforms/python/CMakeLists.txt
create mode 100644 modules/platforms/python/LICENSE
create mode 100644 modules/platforms/python/MANIFEST.in
create mode 100644 modules/platforms/python/NOTICE
create mode 100644 modules/platforms/python/README.md
copy modules/platforms/{cpp/tests/odbc-test =>
python/cpp_module}/CMakeLists.txt (57%)
create mode 100644 modules/platforms/python/cpp_module/module.cpp
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/Cancellable.java =>
platforms/python/cpp_module/module.h} (73%)
create mode 100644 modules/platforms/python/cpp_module/py_connection.cpp
create mode 100644 modules/platforms/python/cpp_module/py_connection.h
create mode 100644 modules/platforms/python/pyignite3/__init__.py
create mode 100644 modules/platforms/python/requirements/install.txt
create mode 100644 modules/platforms/python/requirements/tests.txt
create mode 100644 modules/platforms/python/setup.py
copy packaging/db/linux/deb/postUninstall.sh =>
modules/platforms/python/tests/__init__.py (86%)
copy packaging/db/linux/deb/postUninstall.sh =>
modules/platforms/python/tests/conftest.py (86%)
copy packaging/db/linux/service/ignite3db.service =>
modules/platforms/python/tests/test_connect.py (64%)
create mode 100644 modules/platforms/python/tests/util.py
create mode 100644
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaMessageUtils.java
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/{ReplicaRequest.java
=> ReplicationGroupIdMessage.java} (75%)
rename
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/command
=>
replicator/src/main/java/org/apache/ignite/internal/replicator/message}/TablePartitionIdMessage.java
(67%)
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/{ReplicaRequest.java
=> ZonePartitionIdMessage.java} (55%)
delete mode 100644
modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/ItRestAddressReportTest.java
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/{ItIgnitionTest.java
=> ItIgniteServerTest.java} (57%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientComputeMarshallingTest.java
create mode 100644
modules/runner/src/main/java/org/apache/ignite/IgniteServer.java
rename modules/{api =>
runner}/src/main/java/org/apache/ignite/InitParameters.java (86%)
create mode 100644
modules/runner/src/main/java/org/apache/ignite/InitParametersBuilder.java
create mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/app/IgniteServerImpl.java
delete mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/app/IgnitionImpl.java
delete mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/component/RestAddressReporter.java
create mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/threading/PublicApiThreadingIgniteCatalog.java
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxCleanupMessageResponse.java
=>
runner/src/main/java/org/apache/ignite/lang/ClusterInitFailureException.java}
(55%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxCleanupMessageResponse.java
=>
runner/src/main/java/org/apache/ignite/lang/ClusterNotInitializedException.java}
(59%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TransactionMeta.java
=> runner/src/main/java/org/apache/ignite/lang/NodeNotStartedException.java}
(61%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TransactionMeta.java
=> runner/src/main/java/org/apache/ignite/lang/NodeStartException.java} (58%)
delete mode 100644
modules/runner/src/test/java/org/apache/ignite/internal/component/RestAddressReporterTest.java
delete mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/IgniteIntegrationTest.java
delete mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/junit/StopAllIgnitesAfterTests.java
rename modules/{core =>
runner}/src/testFixtures/java/org/apache/ignite/internal/testframework/TestIgnitionManager.java
(93%)
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItCastToTsWithLocalTimeZoneTest.java
create mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_big_string_update.test
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_big_string_update.test_ignore
create mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_null_update.test
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_null_update.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_repeated_string_update.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update_many_strings.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update_null.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update_rollback.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update_rollback_null.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_delete_same_tuple.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_from.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_many_updaters.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_many_updaters_nulls.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_mix.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_same_value.test_ignore
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/AbstractTarget.java (57%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/AllOfTarget.java (93%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster/SmallClusterFactory.java
=> largecluster/LargeClusterFactory.java} (68%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/OneOfTarget.java (83%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/PartitionedTarget.java (75%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/SomeOfTarget.java (84%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/benchmarks/MappingBenchmark.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/mapping/ExecutionTargetFactorySelfTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/datatypes/MergeSourcesCoercionTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/datatypes/NumericInsertSourcesCoercionTest.java
rename
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/datatypes/{SetOperatorCoercionTest.java
=> NumericSetOperatorCoercionTest.java} (98%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/datatypes/NumericUpdateSourcesCoercionTest.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItEstimatedSizeTest.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/threading/ItPartitionManagerApiThreadingTest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/StreamerReceiverRunner.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/partition/PublicApiThreadingPartitionManager.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/storage/InternalTableEstimatedSizeTest.java
copy modules/{api/src/main/java/org/apache/ignite/sql/SqlException.java =>
transactions/src/main/java/org/apache/ignite/internal/tx/TransactionInternalException.java}
(50%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TransactionsExceptionMapperUtil.java
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{TxStateCoordinatorRequest.java
=> CleanupReplicatedInfoMessage.java} (51%)
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/{TransactionMeta.java
=> message/TransactionMetaMessage.java} (56%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/TxMetaMessage.java
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{TxStateResponse.java
=> TxStateMetaAbandonedMessage.java} (51%)
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{TxStateResponse.java
=> TxStateMetaFinishingMessage.java} (54%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/TxStateMetaMessage.java
create mode 100644 packaging/odbc/template.wxs
