This is an automated email from the ASF dual-hosted git repository. sdanilov pushed a change to branch ignite-19363 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 1307c410c8 Review fixes add 44c97c0065 IGNITE-19698 Add node name to threads in DefaultMessagingService (#2175) add 764e8a124b IGNITE-19090 Don't show progress bar in case of an error (#2169) add 995eba14b3 IGNITE-19518 Validate unit after node restart (#2151) add 19d1ff5a17 IGNITE-19304 Forbid creating index on the duplicate columns (#2174) add 17d53e99cf IGNITE-19707 Fix AssertionError in DistributionZoneManagerScaleUpTest (#2180) add 575ce79edb IGNITE-19552 Build JDBC module jar (#2127) add 79a841d952 IGNITE-19545 .NET: Add Basic Data Streamer (#2182) add 7bcea31c9e IGNITE-18692 ItRebalanceTest fix (#2157) add 006ddb06e1 IGNITE-19522 Modify deploy unit command (#2152) add f90f949b34 IGNITE-19517 Cache JobClassLoaders (#2146) add dd927f7d43 IGNITE-19483 Transform TableManager and IndexManager to internally work against Catalog event types (#2184) add 5200f0c1f3 IGNITE-19600 Removed topologyVersionedDataNodes (#2171) add dab1c8d3ad IGNITE-19204 Implement ODBC connection establishment (#2149) add 1b5fce2a6a IGNITE-19079 Enabled tests in ItIgniteNodeRestartTest: testTwoNodesRestartDirect and testTwoNodesRestartReverse (#2187) add c99ca59509 IGNITE-19709 Sql. Remove reflection call from mapping implementation (#2181) add fa76d246f5 IGNITE-19728 .NET: Fix TestAutoFlushFrequency flakiness (#2189) add 2373d9bd3f IGNITE-19587: Sql. Remove execution-related part from IgniteTable. (#2140) add 3a7cf4d0e5 IGNITE-19373 Get rid of waitForIndex from tests (#2190) add 7e1f785e21 IGNITE-19714 Fix AssertionError in DistributionZoneManagerWatchListenerTest (#2185) add 5dd07b8f95 IGNITE-18831 Sql. Fix dynamic parameters type coercion. (#2047) add f91a642951 IGNITE-19184 Added javadocs and md file to describe node attributes and distribution zone filters (#2188) add a3d3a3b5a9 Merge branch 'main' into ignite-19363 add 298f19c911 Merge fixes No new revisions were added by this update. Summary of changes: .../ignite/internal/affinity/AffinityUtils.java | 6 +- .../org/apache/ignite/compute/DeploymentUnit.java | 22 + modules/catalog/build.gradle | 2 + .../internal/catalog/CatalogServiceImpl.java | 39 +- .../internal/catalog/commands/CatalogUtils.java | 9 +- .../descriptors/CatalogDataStorageDescriptor.java | 61 +++ .../descriptors/CatalogDescriptorUtils.java | 40 ++ .../descriptors/CatalogTableDescriptor.java | 11 +- .../catalog/descriptors/CatalogZoneDescriptor.java | 49 +- .../internal/catalog/CatalogServiceSelfTest.java | 184 +++++--- .../cli/call/unit/DeployUndeployTestSupport.java | 7 +- .../cli/commands/unit/ItDeploymentUnitTest.java | 106 ++++- .../internal/rest/ItGeneratedRestClientTest.java | 5 +- .../cli/call/cluster/unit/DeployUnitCall.java | 21 +- .../cli/call/cluster/unit/DeployUnitCallInput.java | 19 +- .../cli/call/cluster/unit/DeployUnitClient.java | 62 ++- .../ignite/internal/cli/commands/Options.java | 9 +- .../cluster/unit/ClusterUnitDeployCommand.java | 42 +- .../cluster/unit/ClusterUnitDeployReplCommand.java | 42 +- ...loyCommand.java => UnitDeployOptionsMixin.java} | 90 ++-- .../cli/core/call/AsyncCallExecutionPipeline.java | 18 +- .../internal/cli/core/call/ProgressBarTracker.java | 36 +- .../internal/cli/core/call/ProgressTracker.java | 5 +- .../completer/DynamicCompleterActivationPoint.java | 12 + .../unit/UnitNodesDynamicCompleterFactory.java | 48 ++ .../cli/commands/UrlOptionsNegativeTest.java | 28 +- .../cli/commands/unit/DeployCommandTest.java | 55 +++ .../cluster/management/ItClusterManagerTest.java | 18 + .../management/ClusterManagementGroupManager.java | 11 +- .../NodeAttributeConfigurationSchema.java | 7 +- .../cluster/management/raft/CmgRaftService.java | 34 ++ .../management/topology/api/LogicalNode.java | 7 +- modules/code-deployment/build.gradle | 2 + .../internal/deployunit/DefaultNodeCallback.java | 98 ++++ .../deployunit/DeployMessagingService.java | 6 +- .../internal/deployunit/DeploymentManagerImpl.java | 203 +++++--- .../deployunit/DeploymentUnitAccessor.java} | 40 +- .../deployunit/DeploymentUnitAccessorImpl.java | 55 +++ .../deployunit/DisposableDeploymentUnit.java | 96 ++++ .../{DeployTracker.java => DownloadTracker.java} | 24 +- .../internal/deployunit/FileDeployerService.java | 20 +- .../internal/deployunit/IgniteDeployment.java | 83 +++- .../internal/deployunit/InitialDeployMode.java} | 16 +- .../exception/DeploymentUnitNotFoundException.java | 48 +- .../DeploymentUnitUnavailableException.java | 87 ++++ .../exception/InvalidNodesArgumentException.java} | 17 +- .../metastore/DeploymentUnitFailover.java | 88 ++++ .../deployunit/metastore/DeploymentUnitStore.java | 2 - .../deployunit/metastore/NodeEventCallback.java | 38 +- .../metastore/NodeStatusWatchListener.java | 7 +- .../metastore/DeploymentUnitStoreImplTest.java | 7 +- .../deployunit/DeploymentManagerImplTest.java | 83 ++++ modules/compute/build.gradle | 2 +- .../compute/ClassLoaderExceptionsMapper.java | 82 ++++ .../internal/compute/ComputeComponentImpl.java | 33 +- .../compute/{ => loader}/JobClassLoader.java | 42 +- .../{ => loader}/JobClassLoaderFactory.java | 78 +-- .../internal/compute/loader/JobContext.java} | 28 +- .../internal/compute/loader/JobContextManager.java | 195 ++++++++ modules/compute/src/test/README.md | 8 +- .../compute/ClassLoaderExceptionsMapperTest.java | 77 +++ .../internal/compute/ComputeComponentImplTest.java | 52 +- .../compute/JobClassLoaderFactoryTest.java | 342 -------------- .../compute/loader/JobClassLoaderFactoryTest.java | 220 +++++++++ .../compute/{ => loader}/JobClassLoaderTest.java | 44 +- .../compute/loader/JobContextManagerTest.java | 218 +++++++++ .../compute/util/DummyIgniteDeployment.java | 139 ++++++ .../units/apache-ignite-1.0-SNAPSHOT-src.zip | Bin .../units/test-units-1.0-SNAPSHOT-src.zip | Bin 69386 -> 0 bytes .../units/unit1/1.0.0/unit1-1.0-SNAPSHOT.jar | Bin 1693 -> 1749 bytes .../units/unit1/2.0.0/unit2-1.0-SNAPSHOT.jar | Bin 1681 -> 1724 bytes .../units/unit1/3.0.1/unit1-1.0-SNAPSHOT.jar | Bin 1693 -> 1749 bytes .../units/unit1/3.0.1/unit2-1.0-SNAPSHOT.jar | Bin 1681 -> 1724 bytes .../unit1/3.0.2/subdir/unit2-1.0-SNAPSHOT.jar | Bin 1681 -> 1724 bytes .../units/unit1/3.0.2/unit1-1.0-SNAPSHOT.jar | Bin 1693 -> 1749 bytes .../units/unit2/1.0.0/unit1-1.0-SNAPSHOT.jar | Bin 1693 -> 1749 bytes .../units/unit2/2.0.0/unit2-1.0-SNAPSHOT.jar | Bin 1681 -> 1724 bytes .../internal/thread/StripedThreadPoolExecutor.java | 9 +- .../ignite/internal/util/RefCountedObjectPool.java | 87 ++++ .../java/org/apache/ignite/lang/ErrorGroups.java | 6 + .../internal/util/RefCountedObjectPoolTest.java | 94 ++++ .../distributionzones/DistributionZoneManager.java | 243 +--------- .../DistributionZoneConfigurationSchema.java | 2 + .../distributionzones/rebalance/RebalanceUtil.java | 42 ++ .../DistributionZoneAwaitDataNodesTest.java | 522 --------------------- .../DistributionZoneManagerFilterTest.java | 60 ++- .../DistributionZoneManagerScaleUpTest.java | 27 +- .../DistributionZoneManagerWatchListenerTest.java | 8 +- modules/distribution-zones/tech-notes/filters.md | 70 +++ .../apache/ignite/internal/index/HashIndex.java | 5 +- .../ignite/internal/index/SortedIndexImpl.java | 5 +- modules/jdbc/build.gradle | 6 +- .../ignite/network/DefaultMessagingService.java | 20 +- .../scalecube/ScaleCubeClusterServiceFactory.java | 1 + .../network/DefaultMessagingServiceTest.java | 1 + modules/platforms/cpp/CMakeLists.txt | 4 + .../ignite/client/detail/cluster_connection.cpp | 4 +- .../cpp/ignite/client/detail/cluster_connection.h | 4 +- .../ignite/client/detail/ignite_client_impl.cpp | 2 +- .../cpp/ignite/client/detail/node_connection.cpp | 8 +- .../ignite/client/ignite_client_configuration.h | 28 +- .../cpp/ignite/client/network/cluster_node.h | 6 +- modules/platforms/cpp/ignite/common/bits.h | 1 + modules/platforms/cpp/ignite/common/end_point.h | 2 +- modules/platforms/cpp/ignite/common/ignite_error.h | 4 +- .../cpp/ignite/network/detail/linux/sockets.cpp | 40 +- .../cpp/ignite/network/detail/linux/sockets.h | 15 +- .../network/detail/linux/tcp_socket_client.h | 248 ++++++++++ .../platforms/cpp/ignite/network/detail/utils.h | 23 + .../cpp/ignite/network/detail/win/sockets.cpp | 50 +- .../cpp/ignite/network/detail/win/sockets.h | 21 +- .../ignite/network/detail/win/tcp_socket_client.h | 245 ++++++++++ modules/platforms/cpp/ignite/network/network.cpp | 7 + modules/platforms/cpp/ignite/network/network.h | 6 + .../platforms/cpp/ignite/network/socket_client.h | 92 ++++ modules/platforms/cpp/ignite/odbc/CMakeLists.txt | 5 +- .../ignite/odbc/app/application_data_buffer.cpp | 1 + .../cpp/ignite/odbc/config/config_tools.cpp | 84 +--- .../cpp/ignite/odbc/config/config_tools.h | 13 +- .../cpp/ignite/odbc/config/configuration.cpp | 7 +- .../cpp/ignite/odbc/config/configuration.h | 51 +- .../odbc/config/connection_string_parser.cpp | 4 +- .../cpp/ignite/odbc/install/install_linux.ini | 6 + .../cpp/ignite/odbc/install/install_win.cmd | 26 + modules/platforms/cpp/ignite/odbc/log.cpp | 9 +- modules/platforms/cpp/ignite/odbc/log.h | 24 +- modules/platforms/cpp/ignite/odbc/message.cpp | 60 --- modules/platforms/cpp/ignite/odbc/message.h | 175 ------- .../platforms/cpp/ignite/odbc/meta/column_meta.cpp | 2 +- modules/platforms/cpp/ignite/odbc/odbc_error.h | 11 +- .../platforms/cpp/ignite/odbc/sql_connection.cpp | 328 +++++++++---- modules/platforms/cpp/ignite/odbc/sql_connection.h | 132 +----- .../platforms/cpp/ignite/odbc/sql_statement.cpp | 31 +- modules/platforms/cpp/ignite/odbc/utility.cpp | 2 + .../cpp/tests/client-test/ignite_runner_suite.h | 25 +- modules/platforms/cpp/tests/client-test/main.cpp | 119 ++--- .../platforms/cpp/tests/odbc-test/CMakeLists.txt | 39 ++ .../cpp/tests/odbc-test/connection_test.cpp | 104 ++++ .../cpp/tests/{client-test => odbc-test}/main.cpp | 31 +- .../cpp/tests/test-common/ignite_runner.cpp | 8 +- .../cpp/tests/test-common/ignite_runner.h | 39 +- .../platforms/cpp/tests/test-common/test_utils.cpp | 32 +- .../platforms/cpp/tests/test-common/test_utils.h | 27 +- .../dotnet/Apache.Ignite.Benchmarks/Program.cs | 8 +- .../Table/DataStreamerBenchmark.cs | 127 +++++ .../SerializerHandlerBenchmarksBase.cs | 2 +- .../dotnet/Apache.Ignite.Tests/FakeServer.cs | 26 + .../dotnet/Apache.Ignite.Tests/HeartbeatTests.cs | 6 +- .../Apache.Ignite.Tests/IgniteClientTests.cs | 3 +- .../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 6 +- .../dotnet/Apache.Ignite.Tests/LoggingTests.cs | 4 +- .../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 65 ++- .../Proto/ColocationHashTests.cs | 2 +- .../dotnet/Apache.Ignite.Tests/SslTests.cs | 2 +- .../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 216 +++++++++ .../Serialization/ObjectSerializerHandlerTests.cs | 2 +- .../Transactions/TransactionsTests.cs | 9 +- .../Internal/Buffers/PooledArrayBuffer.cs | 12 +- .../Apache.Ignite/Internal/ClientFailoverSocket.cs | 19 +- .../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 3 +- .../Internal/Common/IgniteArgumentCheck.cs | 10 +- .../Proto/BinaryTuple/BinaryTupleBuilder.cs | 73 +-- .../Proto/BinaryTuple/BinaryTupleCommon.cs | 42 ++ .../Apache.Ignite/Internal/Table/DataStreamer.cs | 282 +++++++++++ .../Apache.Ignite/Internal/Table/KeyValueView.cs | 16 + .../Apache.Ignite/Internal/Table/RecordView.cs | 30 +- .../dotnet/Apache.Ignite/Internal/Table/Schema.cs | 2 + .../dotnet/Apache.Ignite/Internal/Table/Table.cs | 42 +- .../Apache.Ignite/Internal/Table/TemporalTypes.cs | 20 + .../Apache.Ignite/Table/DataStreamerOptions.cs | 48 ++ .../Apache.Ignite/Table/IDataStreamerTarget.cs | 39 ++ .../dotnet/Apache.Ignite/Table/IKeyValueView.cs | 2 +- .../dotnet/Apache.Ignite/Table/IRecordView.cs | 2 +- .../ItPlacementDriverReplicaSideTest.java | 2 +- .../raft/client/TopologyAwareRaftGroupService.java | 9 +- .../apache/ignite/internal/replicator/Replica.java | 3 +- .../ignite/internal/replicator/ReplicaManager.java | 21 +- modules/rest-api/openapi/openapi.yaml | 46 +- .../rest/api/deployment/DeploymentCodeApi.java | 11 +- .../rest/api/deployment/InitialDeployMode.java} | 17 +- .../DeploymentManagementControllerTest.java | 37 +- .../deployment/DeploymentManagementController.java | 31 +- .../InvalidNodesArgumentExceptionHandler.java | 44 ++ modules/runner/build.gradle | 1 + .../java/org/apache/ignite/internal/Cluster.java | 43 +- .../internal/ClusterPerTestIntegrationTest.java | 6 +- .../internal/compute/ItComputeTestStandalone.java | 86 +++- .../storage/ItRebalanceDistributedTest.java | 25 +- .../ignite/internal/deployment/DeployFile.java | 56 +++ .../ignite/internal/deployment/DeployFiles.java | 175 +++++++ .../deployment/ItDeploymentUnitFailoverTest.java | 79 ++++ .../internal/deployment/ItDeploymentUnitTest.java | 306 +++--------- .../apache/ignite/internal/deployment/Unit.java | 129 +++++ .../apache/ignite/internal/jdbc/ItJdbcTest.java | 2 +- .../raftsnapshot/ItTableRaftSnapshotsTest.java | 3 - .../ignite/internal/rebalance/ItRebalanceTest.java | 161 +++---- .../runner/app/ItIgniteNodeRestartTest.java | 7 +- .../internal/sql/api/ItSqlAsynchronousApiTest.java | 15 +- .../internal/sql/api/ItSqlSynchronousApiTest.java | 12 + .../sql/engine/ClusterPerClassIntegrationTest.java | 17 +- .../internal/sql/engine/ItAggregatesTest.java | 4 - .../internal/sql/engine/ItBuildIndexTest.java | 19 + .../internal/sql/engine/ItCorrelatesTest.java | 6 - .../sql/engine/ItDynamicParameterTest.java | 40 +- .../internal/sql/engine/ItImplicitCastsTest.java | 66 +++ .../internal/sql/engine/ItIndexSpoolTest.java | 4 - .../ignite/internal/sql/engine/ItJoinTest.java | 10 +- .../internal/sql/engine/ItMixedQueriesTest.java | 4 - .../internal/sql/engine/ItOrToUnionRuleTest.java | 8 +- .../internal/sql/engine/ItSecondaryIndexTest.java | 20 +- .../engine/datatypes/tests/BaseDataTypeTest.java | 2 +- .../datatypes/tests/BaseDmlDataTypeTest.java | 81 +++- .../tests/BaseExpressionDataTypeTest.java | 15 +- .../datatypes/tests/BaseIndexDataTypeTest.java | 6 +- .../datatypes/tests/BaseQueryDataTypeTest.java | 32 +- .../datatypes/uuid/ItUuidExpressionTest.java | 20 - .../sql/engine/datatypes/uuid/ItUuidQueryTest.java | 4 +- .../datatypes/varbinary/ItVarBinaryQueryTest.java | 21 + .../datatypes/varbinary/ItVarBinarySetOpTest.java | 4 +- .../ignite/internal/table/ItTableScanTest.java | 5 +- .../resources/units/unit1-1.0-SNAPSHOT.jar | Bin 0 -> 1749 bytes .../resources/units/unit2-1.0-SNAPSHOT.jar | Bin 0 -> 1724 bytes .../org/apache/ignite/internal/app/IgniteImpl.java | 14 +- .../storage/DataStorageConfigurationSchema.java | 1 + modules/sql-engine/build.gradle | 5 + .../internal/sql/engine/SqlQueryProcessor.java | 15 +- .../internal/sql/engine/exec/ExecutableTable.java} | 29 +- .../sql/engine/exec/ExecutableTableRegistry.java} | 21 +- .../engine/exec/ExecutableTableRegistryImpl.java | 130 +++++ .../engine/exec/ExecutionDependencyResolver.java} | 19 +- .../exec/ExecutionDependencyResolverImpl.java | 103 ++++ .../sql/engine/exec/ExecutionServiceImpl.java | 31 +- .../sql/engine/exec/LogicalRelImplementor.java | 26 +- .../sql/engine/exec/QueryTaskExecutorImpl.java | 3 +- .../sql/engine/exec/ResolvedDependencies.java | 63 +++ .../internal/sql/engine/exec/ScannableTable.java} | 44 +- .../sql/engine/exec/ScannableTableImpl.java | 68 +++ .../sql/engine/exec/TableRowConverter.java} | 46 +- .../sql/engine/exec/TableRowConverterImpl.java | 82 ++++ .../{UpdateableTable.java => UpdatableTable.java} | 2 +- .../UpdatableTableImpl.java} | 388 ++------------- .../sql/engine/exec/ddl/DdlCommandHandler.java | 32 +- .../sql/engine/exec/rel/IndexScanNode.java | 17 +- .../internal/sql/engine/exec/rel/ModifyNode.java | 8 +- .../sql/engine/exec/rel/StorageScanNode.java | 25 +- .../sql/engine/exec/rel/TableScanNode.java | 36 +- .../sql/engine/metadata/IgniteFragmentMapping.java | 398 ++++++++++++++++ .../sql/engine/metadata/IgniteMdCollation.java | 3 +- .../engine/metadata/IgniteMdFragmentMapping.java | 266 ----------- .../sql/engine/metadata/IgniteMetadata.java | 26 - .../sql/engine/metadata/RelMetadataQueryEx.java | 26 - .../internal/sql/engine/prepare/Fragment.java | 4 +- .../sql/engine/prepare/IgniteSqlValidator.java | 290 +++++++----- .../sql/engine/prepare/IgniteTypeCoercion.java | 353 +++++++++++++- .../sql/engine/prepare/MappingQueryContext.java | 2 +- .../internal/sql/engine/prepare/MultiStepPlan.java | 4 +- .../sql/engine/prepare/PrepareServiceImpl.java | 20 +- .../internal/sql/engine/prepare/QueryTemplate.java | 4 +- .../sql/engine/schema/IgniteSchemaTable.java | 17 - .../internal/sql/engine/schema/IgniteTable.java | 23 - .../sql/engine/schema/IgniteTableImpl.java | 468 ++---------------- .../sql/engine/schema/SqlSchemaManagerImpl.java | 39 +- .../internal/sql/engine/type/IgniteTypeSystem.java | 4 +- .../internal/sql/engine/util/IgniteMethod.java | 5 - .../internal/sql/engine/util/IgniteResource.java | 9 +- .../util/SafeCustomTypeInternalConversion.java | 6 - .../ignite/internal/sql/engine/util/TypeUtils.java | 37 +- .../internal/sql/engine/StopCalciteModuleTest.java | 10 +- .../RepeatedRandomRowDataProviderFactory.java | 54 +-- .../exec/ExecutableTableRegistrySelfTest.java | 157 +++++++ .../exec/ExecutionDependencyResolverSelfTest.java | 278 +++++++++++ .../sql/engine/exec/ExecutionServiceImplTest.java | 19 +- .../sql/engine/exec/MockedStructuresTest.java | 11 +- .../engine/exec/NoOpExecutableTableRegistry.java | 62 +++ .../exec/rel/IndexScanNodeExecutionTest.java | 34 +- .../exec/rel/TableScanNodeExecutionTest.java | 78 ++- .../engine/exec/schema/SqlSchemaManagerTest.java | 12 +- .../sql/engine/framework/TestBuilders.java | 24 +- .../internal/sql/engine/framework/TestNode.java | 12 +- .../internal/sql/engine/framework/TestTable.java | 23 +- .../sql/engine/planner/AbstractPlannerTest.java | 62 ++- .../sql/engine/planner/DynamicParametersTest.java | 360 ++++++++++++++ .../internal/sql/engine/planner/FunctionsTest.java | 100 ++++ .../sql/engine/planner/ImplicitCastsTest.java | 462 +++++++++++++----- .../planner/IndexSearchBoundsPlannerTest.java | 2 +- .../engine/schema/CatalogSqlSchemaManagerTest.java | 4 +- .../internal/sql/engine/util/StatementChecker.java | 508 ++++++++++++++++++++ .../sql/engine/util/StatementCheckerTest.java | 178 +++++++ .../internal/sql/engine/util/TypeUtilsTest.java | 144 ++++++ .../internal/sql/engine/util/NativeTypeValues.java | 128 +++++ .../internal/storage/DataStorageManager.java | 9 + .../internal/storage/engine/StorageEngine.java | 13 +- .../storage/engine/StorageTableDescriptor.java | 13 +- .../index/StorageIndexDescriptorSupplier.java | 68 +++ .../TestMvPartitionStorageConcurrencyTest.java | 11 +- .../storage/TestMvPartitionStorageGcTest.java | 11 +- .../storage/TestMvPartitionStorageTest.java | 12 +- .../internal/storage/TestMvTableStorageTest.java | 19 +- .../storage/index/TestHashIndexStorageTest.java | 12 +- .../storage/index/TestSortedIndexStorageTest.java | 12 +- .../storage/AbstractMvTableStorageTest.java | 49 +- .../storage/BaseMvPartitionStorageTest.java | 54 +-- .../internal/storage/impl/TestMvTableStorage.java | 20 +- .../internal/storage/impl/TestStorageEngine.java | 19 +- .../storage/index/AbstractIndexStorageTest.java | 6 +- .../pagememory/AbstractPageMemoryTableStorage.java | 32 +- .../PersistentPageMemoryStorageEngine.java | 23 +- .../PersistentPageMemoryTableStorage.java | 16 +- .../VolatilePageMemoryStorageEngine.java | 26 +- .../pagememory/VolatilePageMemoryTableStorage.java | 19 +- .../mv/AbstractPageMemoryMvPartitionStorage.java | 45 +- .../PersistentPageMemoryMvTableStorageTest.java | 57 ++- .../VolatilePageMemoryMvTableStorageTest.java | 41 +- .../AbstractPageMemoryHashIndexStorageTest.java | 6 +- .../AbstractPageMemorySortedIndexStorageTest.java | 6 +- .../PersistentPageMemoryHashIndexStorageTest.java | 27 +- ...PersistentPageMemorySortedIndexStorageTest.java | 27 +- .../VolatilePageMemoryHashIndexStorageTest.java | 27 +- .../VolatilePageMemorySortedIndexStorageTest.java | 28 +- ...ageMemoryMvPartitionStorageConcurrencyTest.java | 53 ++- ...rsistentPageMemoryMvPartitionStorageGcTest.java | 53 ++- ...PersistentPageMemoryMvPartitionStorageTest.java | 61 ++- ...ageMemoryMvPartitionStorageConcurrencyTest.java | 52 +- ...VolatilePageMemoryMvPartitionStorageGcTest.java | 50 +- .../VolatilePageMemoryMvPartitionStorageTest.java | 49 +- .../storage/rocksdb/RocksDbDataStorageModule.java | 4 +- .../storage/rocksdb/RocksDbStorageEngine.java | 52 +- .../storage/rocksdb/RocksDbTableStorage.java | 66 +-- .../RocksDbMvPartitionStorageConcurrencyTest.java | 50 +- .../rocksdb/RocksDbMvPartitionStorageGcTest.java | 50 +- .../rocksdb/RocksDbMvPartitionStorageTest.java | 50 +- .../storage/rocksdb/RocksDbMvTableStorageTest.java | 42 +- .../storage/rocksdb/RocksDbStorageEngineTest.java | 74 ++- .../rocksdb/index/RocksDbHashIndexStorageTest.java | 25 +- .../index/RocksDbSortedIndexStorageTest.java | 25 +- .../ignite/distributed/ItTablePersistenceTest.java | 21 +- .../distributed/ItTxDistributedTestSingleNode.java | 2 +- .../ignite/distributed/ReplicaUnavailableTest.java | 2 +- .../internal/table/distributed/TableManager.java | 273 ++++++----- .../raft/RebalanceRaftGroupEventsListener.java | 105 ++--- .../ignite/internal/utils/RebalanceUtil.java | 5 +- .../AbstractMvStorageUpdateHandlerTest.java | 55 +-- ...istentPageMemoryMvStorageUpdateHandlerTest.java | 50 +- .../RocksDbMvStorageUpdateHandlerTest.java | 48 +- .../table/distributed/TableManagerTest.java | 21 +- .../TestMvStorageUpdateHandlerTest.java | 12 +- ...latilePageMemoryMvStorageUpdateHandlerTest.java | 49 +- .../tx/storage/state/TxStateTableStorage.java | 6 - .../state/rocksdb/TxStateRocksDbStorage.java | 2 +- .../state/rocksdb/TxStateRocksDbTableStorage.java | 48 +- .../state/rocksdb/RocksDbTxStateStorageTest.java | 18 +- .../state/test/TestTxStateTableStorage.java | 6 - 352 files changed, 12178 insertions(+), 5876 deletions(-) create mode 100644 modules/catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogDataStorageDescriptor.java copy modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/cluster/unit/{ClusterUnitDeployCommand.java => UnitDeployOptionsMixin.java} (52%) create mode 100644 modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/completer/unit/UnitNodesDynamicCompleterFactory.java create mode 100644 modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/unit/DeployCommandTest.java create mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DefaultNodeCallback.java copy modules/{storage-api/src/main/java/org/apache/ignite/internal/storage/engine/StorageTableDescriptor.java => code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DeploymentUnitAccessor.java} (54%) create mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DeploymentUnitAccessorImpl.java create mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DisposableDeploymentUnit.java rename modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/{DeployTracker.java => DownloadTracker.java} (68%) copy modules/{platforms/dotnet/Apache.Ignite.Benchmarks/Program.cs => code-deployment/src/main/java/org/apache/ignite/internal/deployunit/InitialDeployMode.java} (79%) create mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/exception/DeploymentUnitUnavailableException.java copy modules/{platforms/dotnet/Apache.Ignite.Benchmarks/Program.cs => code-deployment/src/main/java/org/apache/ignite/internal/deployunit/exception/InvalidNodesArgumentException.java} (71%) create mode 100644 modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/metastore/DeploymentUnitFailover.java create mode 100644 modules/code-deployment/src/test/java/org/apache/ignite/internal/deployunit/DeploymentManagerImplTest.java create mode 100644 modules/compute/src/main/java/org/apache/ignite/internal/compute/ClassLoaderExceptionsMapper.java rename modules/compute/src/main/java/org/apache/ignite/internal/compute/{ => loader}/JobClassLoader.java (78%) rename modules/compute/src/main/java/org/apache/ignite/internal/compute/{ => loader}/JobClassLoaderFactory.java (54%) copy modules/{storage-api/src/test/java/org/apache/ignite/internal/storage/TestMvPartitionStorageTest.java => compute/src/main/java/org/apache/ignite/internal/compute/loader/JobContext.java} (60%) create mode 100644 modules/compute/src/main/java/org/apache/ignite/internal/compute/loader/JobContextManager.java create mode 100644 modules/compute/src/test/java/org/apache/ignite/internal/compute/ClassLoaderExceptionsMapperTest.java delete mode 100644 modules/compute/src/test/java/org/apache/ignite/internal/compute/JobClassLoaderFactoryTest.java create mode 100644 modules/compute/src/test/java/org/apache/ignite/internal/compute/loader/JobClassLoaderFactoryTest.java rename modules/compute/src/test/java/org/apache/ignite/internal/compute/{ => loader}/JobClassLoaderTest.java (63%) create mode 100644 modules/compute/src/test/java/org/apache/ignite/internal/compute/loader/JobContextManagerTest.java create mode 100644 modules/compute/src/test/java/org/apache/ignite/internal/compute/util/DummyIgniteDeployment.java copy modules/{runner/src/integrationTest => compute/src/test}/resources/units/apache-ignite-1.0-SNAPSHOT-src.zip (100%) delete mode 100644 modules/compute/src/test/resources/units/test-units-1.0-SNAPSHOT-src.zip create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/RefCountedObjectPool.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/RefCountedObjectPoolTest.java delete mode 100644 modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/DistributionZoneAwaitDataNodesTest.java create mode 100644 modules/distribution-zones/tech-notes/filters.md create mode 100644 modules/platforms/cpp/ignite/network/detail/linux/tcp_socket_client.h create mode 100644 modules/platforms/cpp/ignite/network/detail/win/tcp_socket_client.h create mode 100644 modules/platforms/cpp/ignite/network/socket_client.h create mode 100644 modules/platforms/cpp/ignite/odbc/install/install_linux.ini create mode 100644 modules/platforms/cpp/ignite/odbc/install/install_win.cmd delete mode 100644 modules/platforms/cpp/ignite/odbc/message.cpp delete mode 100644 modules/platforms/cpp/ignite/odbc/message.h create mode 100644 modules/platforms/cpp/tests/odbc-test/CMakeLists.txt create mode 100644 modules/platforms/cpp/tests/odbc-test/connection_test.cpp copy modules/platforms/cpp/tests/{client-test => odbc-test}/main.cpp (78%) create mode 100644 modules/platforms/dotnet/Apache.Ignite.Benchmarks/Table/DataStreamerBenchmark.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Table/DataStreamerTests.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Table/DataStreamer.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite/Table/DataStreamerOptions.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite/Table/IDataStreamerTarget.cs copy modules/{platforms/dotnet/Apache.Ignite.Benchmarks/Program.cs => rest-api/src/main/java/org/apache/ignite/internal/rest/api/deployment/InitialDeployMode.java} (75%) create mode 100644 modules/rest/src/main/java/org/apache/ignite/internal/rest/deployment/exception/handler/InvalidNodesArgumentExceptionHandler.java create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/deployment/DeployFile.java create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/deployment/DeployFiles.java create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/deployment/ItDeploymentUnitFailoverTest.java create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/deployment/Unit.java create mode 100644 modules/runner/src/integrationTest/resources/units/unit1-1.0-SNAPSHOT.jar create mode 100644 modules/runner/src/integrationTest/resources/units/unit2-1.0-SNAPSHOT.jar copy modules/{code-deployment/src/main/java/org/apache/ignite/internal/deployunit/exception/DeploymentUnitNotFoundException.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutableTable.java} (61%) copy modules/{code-deployment/src/main/java/org/apache/ignite/internal/deployunit/metastore/NodeEventCallback.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutableTableRegistry.java} (59%) create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutableTableRegistryImpl.java copy modules/{code-deployment/src/main/java/org/apache/ignite/internal/deployunit/metastore/NodeEventCallback.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java} (66%) create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolverImpl.java create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ResolvedDependencies.java copy modules/{storage-api/src/main/java/org/apache/ignite/internal/storage/engine/StorageTableDescriptor.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ScannableTable.java} (50%) create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ScannableTableImpl.java copy modules/{storage-api/src/main/java/org/apache/ignite/internal/storage/engine/StorageTableDescriptor.java => sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/TableRowConverter.java} (50%) create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/TableRowConverterImpl.java rename modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{UpdateableTable.java => UpdatableTable.java} (98%) copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{schema/IgniteTableImpl.java => exec/UpdatableTableImpl.java} (52%) create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteFragmentMapping.java delete mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/IgniteMdFragmentMapping.java create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutableTableRegistrySelfTest.java create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolverSelfTest.java create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/NoOpExecutableTableRegistry.java create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/DynamicParametersTest.java create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/FunctionsTest.java create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/StatementChecker.java create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/StatementCheckerTest.java create mode 100644 modules/sql-engine/src/testFixtures/java/org/apache/ignite/internal/sql/engine/util/NativeTypeValues.java create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/StorageIndexDescriptorSupplier.java