You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2023/06/14 11:19:32 UTC
[ignite-3] branch ignite-17765-2 updated (701fc8f02c -> 8515c39246)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-17765-2
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 701fc8f02c minor.
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 3278c01b05 Merge branch 'main' into ignite-17765-2
add 8515c39246 minor.
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 +-
.../cluster/management/raft/CmgRaftService.java | 34 ++
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} | 27 +-
.../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 | 241 +---------
.../distributionzones/rebalance/RebalanceUtil.java | 42 ++
.../DistributionZoneAwaitDataNodesTest.java | 522 ---------------------
.../DistributionZoneManagerFilterTest.java | 60 ++-
.../DistributionZoneManagerScaleUpTest.java | 27 +-
.../DistributionZoneManagerWatchListenerTest.java | 8 +-
.../apache/ignite/internal/index/HashIndex.java | 5 +-
.../ignite/internal/index/SortedIndexImpl.java | 5 +-
modules/jdbc/build.gradle | 6 +-
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 ++
.../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 -
.../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 +-
.../datatypes/tests/BaseIndexDataTypeTest.java | 6 +-
.../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 +
.../internal/sql/engine/SqlQueryProcessor.java | 90 ++--
.../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/CacheKey.java | 9 +-
.../internal/sql/engine/prepare/Fragment.java | 4 +-
.../sql/engine/prepare/MappingQueryContext.java | 2 +-
.../internal/sql/engine/prepare/MultiStepPlan.java | 4 +-
.../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/util/IgniteMethod.java | 5 -
.../internal/sql/engine/StopCalciteModuleTest.java | 10 +-
.../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 | 6 +-
.../internal/sql/engine/framework/TestNode.java | 12 +-
.../internal/sql/engine/framework/TestTable.java | 23 +-
.../sql/engine/planner/AbstractPlannerTest.java | 16 -
.../engine/schema/CatalogSqlSchemaManagerTest.java | 4 +-
.../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 | 267 ++++++-----
.../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 -
318 files changed, 9501 insertions(+), 5510 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/TestMvPartitionStorageConcurrencyTest.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/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/exception/DeploymentUnitNotFoundException.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/storage-api/src/main/java/org/apache/ignite/internal/storage/index/StorageIndexDescriptorSupplier.java