This is an automated email from the ASF dual-hosted git repository.
sdanilov pushed a change to branch ignite-19028
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 53bb6d844a Fix checkstyle
discard 5d2013b221 Fix checkstyle
omit 49727b9a49 Fix checkstyle
omit 42a805242e ..
add f189d00bde IGNITE-19022 ItReadOnlyTransactionTest is flaky in TC due
to replica is timed out (#1815)
add 37d1e0f847 IGNITE-19119 Prepare
org.apache.ignite.internal.storage.index.IndexStorage to built index (#1839)
add b68b1564a8 IGNITE-18888 Java client: Implement client-side metrics
(#1846)
add a67c0670a1 IGNITE-19122 Enable main branch protection (#1842)
add 27be2182c7 IGNITE-18868 Recursive update of pendingInvokes in
ReplicaService (#1773)
add 7381daeef3 IGNITE-19025 Remove deployment code from API module (#1844)
add a041b6c644 [IGNITE-18225] Sql. Pushdown MODIFY to data node. (#1798)
add 0eb83e183f IGNITE-19138 Disable ItDeployUndeployCallsTest (#1850)
add f0cc583fd2 IGNITE-19142 IncomingSnapshotCopier.cancel() blocks forever
if called from multiple threads (#1851)
add 54b4317d73 IGNITE-19143 Fix memory leak in ClientInboundMessageHandler
(#1852)
add 06bc4d6b0f IGNITE-18865 Test storage recovery on rebalance abortion
(#1854)
add 36f75c7168 IGNITE-19151 Add client connections benchmark (#1860)
add c2f8f54bb2 IGNITE-18607: add basic auth to the cli (#1821)
add 60b53b3c7e IGNITE-18860 Configuration of replicas/partitions number
moved from table configuration to zone configuration (#1799)
add 2ea18297f1 IGNITE-19043 ItRaftCommandLeftInLogUntilRestartTest fixed
(#1857)
add 8dbb46c8c9 IGNITE-19085 Fix waiting for indexes on recovery when
building indexes (#1855)
add f03de1a85c IGNITE-18778 Move test related entry point to testFixtures
(#1843)
add 9a1dd09170 IGNITE-19113 Refactoring after implementing index building
(#1858)
add 1d90e70a12 IGNITE-19159 Remove required_pull_request_reviews from git
- .asf.yaml (#1864)
add 2ceb0bc10b IGNITE-19092 ItIgniteNodeRestartTest::startPartialNode
Sql-engine component introduced into partial node (#1862)
add 6936b4c978 IGNITE-19129 Remove parallel Watch processing (#1863)
add c3ff9fea01 IGNITE-18655: Sql. Code cleanup. Unmute tests. (#1823)
add e60f78eed1 IGNITE-18889 .NET: Add metrics (#1868)
add 42f723f5b3 IGNITE-19171 Fix flaky ItClusterInitTest.testDoubleInit
(#1870)
add 11ee199daa IGNITE-18539 Implement build procedure for new indexes
(#1800)
add 5b234df53f IGNITE-19050 Javadoc wording corrections (#1840)
add e5696d5052 IGNITE-19127: Sql. Custom data types. Fix type inference in
the presence of nullable types. (#1845)
add 8c8a442a5a [IGNITE-19088]: Sql. Investigate why severals tests
ItTableRaftSnapshotsTest hang/fail. (#1853)
add 26ae1aeab1 IGNITE-18752 Sql. Bump calcite version to 1.34.0 - Fixes
#1847.
add 3d9b903041 IGNITE-19044 (#1879) ItIgniteInMemoryNodeRestartTest
enabled partially.
add 39bc0f37d5 IGNITE-18984 Sql. Migrate JDBC batched methods on new
internal API (#1866)
add adc5a4ffd2 IGNITE-19180 NamedListView made iterable (#1881)
add e715e530f8 IGNITE-18948 .NET: Add README for NuGet package (#1878)
add cef030bd85 IGNITE-19169 Deadlock detected while calling
MvPartitionStorage#pollForVacuum (#1874)
add e92e2319ef IGNITE-19182 fix npe on build index (#1884)
add 263b5f2150 IGNITE-18953 The ability to set attributes for a node to
use them for filtering specific nodes added (#1819)
add 0faaf6c40b IGNITE-19188 Fix broken compilation in
AbstractMvStorageUpdateHandlerTest (#1886)
add 94f3f5f331 IGNITE-19024 Atomic redeploy (#1865)
add b9a889ce9b IGNITE-19172 Obsolete TODO comments addressed and removed.
(#1885)
add 3043bec6c0 IGNITE-19181 ConfigurationNotificationEvent API modified to
include both old and new node/name values. (#1883)
add ef94997a8b ..
add 4e1c34f713 Fix checkstyle
add 9d0a4d1b5f Fix checkstyle
add 52027f3389 Fix checkstyle
add 55bbe5ccae Fix checkstyle
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (53bb6d844a)
\
N -- N -- N refs/heads/ignite-19028 (55bbe5ccae)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 6 +
examples/config/ignite-config.conf | 20 +-
.../ignite/example/AbstractExamplesTest.java | 3 +-
gradle/libs.versions.toml | 10 +-
modules/api/build.gradle | 1 +
.../src/main/java/org/apache/ignite/Ignite.java | 20 +-
.../src/main/java/org/apache/ignite/Ignition.java | 89 +----
.../java/org/apache/ignite/IgnitionManager.java | 70 +---
.../org/apache/ignite/binary/BinaryObject.java | 2 +-
.../org/apache/ignite/binary/package-info.java | 2 +-
.../java/org/apache/ignite/compute/ComputeJob.java | 11 +-
.../org/apache/ignite/compute/IgniteCompute.java | 112 +++---
.../apache/ignite/compute/JobExecutionContext.java | 2 +-
.../ignite/lang/ColumnAlreadyExistsException.java | 10 +-
.../ignite/lang/ColumnNotFoundException.java | 16 +-
.../apache/ignite/lang/IgniteCheckedException.java | 60 +--
.../org/apache/ignite/lang/IgniteException.java | 71 ++--
.../ignite/lang/IndexAlreadyExistsException.java | 10 +-
.../apache/ignite/lang/IndexNotFoundException.java | 8 +-
.../apache/ignite/lang/MarshallerException.java | 4 +-
.../java/org/apache/ignite/lang/NullableValue.java | 19 +-
.../ignite/lang/TableAlreadyExistsException.java | 10 +-
.../apache/ignite/lang/TableNotFoundException.java | 10 +-
.../ignite/lang/UnexpectedNullValueException.java | 4 +-
.../org/apache/ignite/network/ClusterNode.java | 22 +-
.../org/apache/ignite/network/NetworkAddress.java | 2 +-
.../ignite/network/TopologyEventHandler.java | 12 +-
.../org/apache/ignite/network/TopologyService.java | 20 +-
.../main/java/org/apache/ignite/package-info.java | 2 +-
.../org/apache/ignite/sql/BatchedArguments.java | 4 +-
.../java/org/apache/ignite/sql/ColumnMetadata.java | 25 +-
.../apache/ignite/sql/CursorClosedException.java | 11 +-
.../main/java/org/apache/ignite/sql/IgniteSql.java | 8 +-
.../ignite/sql/NoRowSetExpectedException.java | 8 +-
.../main/java/org/apache/ignite/sql/ResultSet.java | 45 +--
.../org/apache/ignite/sql/ResultSetMetadata.java | 10 +-
.../main/java/org/apache/ignite/sql/Session.java | 89 +++--
.../org/apache/ignite/sql/SqlBatchException.java | 18 +-
.../java/org/apache/ignite/sql/SqlException.java | 28 +-
.../main/java/org/apache/ignite/sql/SqlRow.java | 6 +-
.../main/java/org/apache/ignite/sql/Statement.java | 55 ++-
.../apache/ignite/sql/async/AsyncResultSet.java | 52 +--
.../org/apache/ignite/sql/async/package-info.java | 2 +-
.../ignite/sql/reactive/ReactiveResultSet.java | 22 +-
.../apache/ignite/sql/reactive/package-info.java | 2 +-
.../org/apache/ignite/table/InvocationContext.java | 30 +-
.../org/apache/ignite/table/InvokeProcessor.java | 16 +-
.../java/org/apache/ignite/table/KeyValueView.java | 355 +++++++++--------
.../java/org/apache/ignite/table/RecordView.java | 238 ++++++------
.../main/java/org/apache/ignite/table/Table.java | 20 +-
.../main/java/org/apache/ignite/table/Tuple.java | 233 +++++------
.../java/org/apache/ignite/table/TupleImpl.java | 12 +-
.../apache/ignite/table/manager/IgniteTables.java | 18 +-
.../org/apache/ignite/table/mapper/Mapper.java | 78 ++--
.../apache/ignite/table/mapper/MapperBuilder.java | 75 ++--
.../ignite/table/mapper/OneColumnMapper.java | 18 +-
.../ignite/table/mapper/OneColumnMapperImpl.java | 2 +-
.../org/apache/ignite/table/mapper/PojoMapper.java | 10 +-
.../apache/ignite/table/mapper/PojoMapperImpl.java | 4 +-
.../apache/ignite/table/mapper/TypeConverter.java | 12 +-
.../apache/ignite/table/mapper/package-info.java | 4 +-
.../org/apache/ignite/tx/IgniteTransactions.java | 12 +-
.../testframework/IntegrationTestBase.java | 8 +-
.../testframework/TestIgnitionManager.java | 80 ++++
.../internal/catalog/CatalogServiceImpl.java | 8 -
.../cli/call/unit/ItDeployUndeployCallsTest.java | 2 +
.../cli/commands/ItClusterCommandTest.java | 3 +-
.../internal/cli/commands/ItConfigCommandTest.java | 3 +-
.../commands/cluster/init/ItClusterInitTest.java | 88 +++++
.../repl/executor/ItIgnitePicocliCommandsTest.java | 4 +-
.../ignite/internal/cli/ssl/ItJdbcSslTest.java | 4 +-
.../internal/rest/ItGeneratedRestClientTest.java | 5 +-
.../cluster/AuthenticationConfigConverter.java | 64 ++++
.../internal/cli/call/cluster/ClusterInitCall.java | 6 +-
.../cli/call/cluster/ClusterInitCallInput.java | 48 ++-
.../cli/call/cluster/status/ClusterStatusCall.java | 2 +-
.../call/cluster/topology/LogicalTopologyCall.java | 2 +-
.../cluster/topology/PhysicalTopologyCall.java | 2 +-
.../call/configuration/ClusterConfigShowCall.java | 2 +-
.../configuration/ClusterConfigUpdateCall.java | 2 +-
.../cli/call/configuration/NodeConfigShowCall.java | 2 +-
.../call/configuration/NodeConfigUpdateCall.java | 2 +-
.../internal/cli/call/connect/ConnectCall.java | 2 +-
.../call/node/metric/NodeMetricSetListCall.java | 2 +-
.../node/metric/NodeMetricSourceEnableCall.java | 2 +-
.../call/node/metric/NodeMetricSourceListCall.java | 2 +-
.../cli/call/node/status/NodeStatusCall.java | 2 +-
.../cli/call/node/version/NodeVersionCall.java | 2 +-
.../internal/cli/call/unit/DeployUnitCall.java | 2 +-
.../cli/call/unit/DeployUnitCallFactory.java | 2 +-
.../internal/cli/call/unit/ListUnitCall.java | 2 +-
.../internal/cli/call/unit/UndeployUnitCall.java | 2 +-
.../internal/cli/call/unit/UnitStatusCall.java | 2 +-
.../ignite/internal/cli/commands/Options.java | 39 +-
.../cluster/init/AuthenticationOptions.java | 60 +++
.../commands/cluster/init/ClusterInitOptions.java | 14 +-
.../ignite/internal/cli/config/CliConfigKeys.java | 12 +-
.../internal/cli/config/ini/IniConfigManager.java | 12 +
.../ignite/internal/cli/core/ApiClientBuilder.java | 145 -------
.../ignite/internal/cli/core/ApiClientFactory.java | 70 ----
.../handler/IgniteCliApiExceptionHandler.java | 34 +-
.../repl/registry/impl/JdbcUrlRegistryImpl.java | 2 +-
.../internal/cli/core/rest/ApiClientFactory.java | 178 +++++++++
.../internal/cli/core/rest/ApiClientSettings.java | 103 +++++
.../cli/core/rest/ApiClientSettingsBuilder.java | 69 ++++
.../core/rest/BasicAuthenticationInterceptor.java} | 35 +-
.../internal/cli/IgniteCliInterfaceTest.java | 57 +++
.../internal/jdbc/proto/JdbcQueryEventHandler.java | 8 +-
.../handler/ClientInboundMessageHandler.java | 9 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 40 +-
.../jdbc/ClientJdbcExecuteBatchRequest.java | 4 +-
.../jdbc/ClientJdbcPreparedStmntBatchRequest.java | 4 +-
modules/client/build.gradle | 3 +-
.../org/apache/ignite/client/IgniteClient.java | 19 +-
.../ignite/client/IgniteClientConfiguration.java | 7 +
.../internal/client/ClientChannelFactory.java} | 23 +-
.../ignite/internal/client/ClientMetricSource.java | 424 +++++++++++++++++++++
.../client/IgniteClientConfigurationImpl.java | 16 +-
.../ignite/internal/client/ReliableChannel.java | 25 +-
.../ignite/internal/client/TcpClientChannel.java | 68 +++-
.../ignite/internal/client/TcpIgniteClient.java | 52 ++-
.../client/io/netty/NettyClientConnection.java | 29 +-
.../io/netty/NettyClientConnectionMultiplexer.java | 15 +-
.../apache/ignite/client/ClientMetricsTest.java | 197 ++++++++++
.../org/apache/ignite/client/RetryPolicyTest.java | 2 +-
.../{MetricsTest.java => ServerMetricsTest.java} | 2 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 6 -
.../client/fakes/FakeIgniteQueryProcessor.java | 11 -
.../cluster/management/ItClusterManagerTest.java | 32 +-
.../management/raft/ItCmgRaftServiceTest.java | 46 +--
.../cluster/management/ClusterInitializer.java | 4 +-
.../management/ClusterManagementGroupManager.java | 32 +-
.../ClusterManagementConfigurationModule.java | 2 +-
....java => NodeAttributeConfigurationSchema.java} | 30 +-
...java => NodeAttributesConfigurationSchema.java} | 24 +-
.../management/raft/CmgRaftGroupListener.java | 31 +-
.../cluster/management/raft/CmgRaftService.java | 44 ++-
.../management/raft/RaftStorageManager.java | 12 +-
.../cluster/management/raft/ValidationManager.java | 11 +-
.../raft/commands/ClusterNodeMessage.java | 3 +
.../management/topology/LogicalTopology.java | 12 +-
.../management/topology/LogicalTopologyImpl.java | 34 +-
.../management/topology/api/LogicalNode.java | 88 +++++
.../topology/api/LogicalTopologyEventListener.java | 14 +-
.../topology/api/LogicalTopologySnapshot.java | 7 +-
.../AbstractClusterStateStorageManagerTest.java | 7 +-
.../management/raft/CmgRaftGroupListenerTest.java | 3 +-
.../topology/LogicalTopologyImplTest.java | 73 ++--
.../management/BaseItClusterManagementTest.java | 11 +-
.../internal/cluster/management/MockNode.java | 14 +-
.../deployunit/DeployMessagingService.java | 18 +-
.../deployunit/DeployMetastoreService.java | 2 +-
.../ignite/internal/deployunit/DeployTracker.java | 2 +-
.../internal/deployunit}/DeploymentInfo.java | 2 +-
.../internal/deployunit/DeploymentManagerImpl.java | 98 ++---
.../internal/deployunit}/DeploymentStatus.java | 2 +-
.../internal/deployunit}/DeploymentUnit.java | 2 +-
.../internal/deployunit/FileDeployerService.java | 2 +-
.../internal/deployunit}/IgniteDeployment.java | 23 +-
.../ignite/internal/deployunit/UnitMeta.java | 3 +-
.../ignite/internal/deployunit}/UnitStatus.java | 4 +-
.../ignite/internal/deployunit/key/UnitKey.java | 2 +-
.../deployunit/key/UnitMetaSerializer.java | 4 +-
.../metastore/UnitStatusAccumulator.java | 6 +-
.../deployunit/metastore/UnitsAccumulator.java | 6 +-
.../internal/deployunit}/version/UnitVersion.java | 2 +-
.../internal/deployunit}/version/Version.java | 2 +-
.../deployunit}/version/VersionParseException.java | 2 +-
.../ignite/deployment/UnitMetaSerializerTest.java | 4 +-
.../ignite/deployment/version/VersionUnitTest.java | 3 +
.../ignite/configuration/NamedListChange.java | 2 +-
.../apache/ignite/configuration/NamedListView.java | 14 +-
.../ignite/configuration/annotation/Config.java | 2 +-
.../annotation/ConfigurationRoot.java | 2 +-
.../configuration/annotation/NamedConfigValue.java | 2 +-
.../ConfigurationNamedListListener.java | 8 +-
.../ConfigurationNotificationEvent.java | 36 +-
.../configuration/DynamicConfiguration.java | 17 -
.../asm/ConfigurationImplAsmGenerator.java | 19 +-
.../notifications/ConfigurationContainer.java | 86 +++--
.../ConfigurationNotificationContext.java | 21 +-
.../ConfigurationNotificationEventImpl.java | 39 +-
.../notifications/ConfigurationNotifier.java | 55 ++-
.../internal/configuration/tree/NamedListNode.java | 9 +-
.../ConfigurationAnyListenerTest.java | 162 +++-----
.../notifications/ConfigurationListenerTest.java | 373 +++++++++---------
.../ConfigurationListenerTestUtils.java | 2 +-
.../testframework/ConfigurationExtension.java | 2 +
.../internal/components/LongJvmPauseDetector.java | 8 +-
.../internal/testframework/IgniteTestUtils.java | 135 +++----
modules/distribution-zones/build.gradle | 8 +
.../DistributionZoneConfigurationParameters.java | 62 +++
.../distributionzones/DistributionZoneManager.java | 76 ++--
.../distributionzones/DistributionZonesUtil.java | 30 ++
.../DistributionZoneConfigurationSchema.java | 12 +
.../DistributionZoneNotFoundException.java | 9 +
...butionZoneManagerLogicalTopologyEventsTest.java | 86 ++---
.../DistributionZoneManagerScaleUpTest.java | 222 +++++------
.../DistributionZoneManagerWatchListenerTest.java | 2 +-
.../util/DistributionZonesTestUtil.java | 17 +-
.../DistributionZonesTestUtil.java | 60 +++
modules/index/build.gradle | 3 +
.../apache/ignite/internal/index/IndexBuilder.java | 276 ++++++++++++++
.../apache/ignite/internal/index/IndexManager.java | 28 +-
.../ignite/internal/index/IndexManagerTest.java | 5 +-
modules/jdbc/build.gradle | 7 +-
.../apache/ignite/jdbc/AbstractJdbcSelfTest.java | 3 +-
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 21 +-
.../internal/jdbc/JdbcClientQueryEventHandler.java | 17 +-
.../internal/jdbc/JdbcPreparedStatement.java | 2 +-
.../apache/ignite/internal/jdbc/JdbcStatement.java | 2 +-
.../internal/metastorage/MetaStorageManager.java | 6 +-
.../ignite/internal/metastorage/WatchEvent.java | 6 +-
.../ignite/internal/metastorage/WatchListener.java | 6 -
.../impl/ItMetaStorageManagerImplTest.java | 31 +-
.../impl/ItMetaStorageMultipleNodesTest.java | 14 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 2 +-
.../metastorage/impl/ItMetaStorageServiceTest.java | 2 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 34 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 53 ++-
.../impl/MetaStorageRaftGroupEventsListener.java | 9 +-
.../server/OnRevisionAppliedCallback.java | 7 +-
.../ignite/internal/metastorage/server/Watch.java | 54 +--
.../metastorage/server/WatchProcessor.java | 132 ++++---
.../server/AbstractKeyValueStorageTest.java | 23 +-
.../server/RocksDbKeyValueStorageTest.java | 12 +-
.../metastorage/server/WatchProcessorTest.java | 65 ++--
.../ignite/internal/metrics/MetricManager.java | 36 +-
.../configuration/ExporterConfigurationSchema.java | 4 +
.../metrics/exporters/jmx/JmxExporter.java | 18 +-
.../ignite/internal/metrics/JmxExporterTest.java | 3 +-
.../ignite/network/AbstractClusterService.java | 28 +-
.../ignite/network/ClusterLocalConfiguration.java | 62 ---
.../org/apache/ignite/network/ClusterService.java | 12 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 6 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 14 +-
.../ignite/utils/ClusterServiceTestUtils.java | 34 +-
modules/placement-driver/build.gradle | 2 +
.../internal/placementdriver/ActiveActorTest.java | 11 +-
.../PlacementDriverManagerTest.java | 37 +-
.../placementdriver/AssignmentsTracker.java | 24 +-
.../internal/placementdriver/LeaseTracker.java | 5 -
.../internal/placementdriver/LeaseUpdater.java | 4 +-
.../placementdriver/PlacementDriverManager.java | 3 +
.../internal/placementdriver/TopologyTracker.java | 7 +-
.../platforms/cpp/tests/client-test/sql_test.cpp | 3 +-
.../ManyConnectionsBenchmark.cs | 100 +++++
.../dotnet/Apache.Ignite.Benchmarks/Program.cs | 7 +-
.../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 240 ++++++++++++
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 3 +-
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 5 +
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 2 +
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 103 +++--
.../dotnet/Apache.Ignite/Internal/Metrics.cs | 164 ++++++++
modules/platforms/dotnet/README.md | 266 ++++++++++++-
.../ignite/internal/raft/ItLearnersTest.java | 2 +-
.../raft/ItTruncateSuffixAndRestartTest.java | 10 +-
.../raft/server/ItJraftCounterServerTest.java | 2 +
.../java/org/apache/ignite/internal/raft/Loza.java | 23 +-
.../internal/raft/server/RaftGroupOptions.java | 22 --
.../ignite/internal/raft/server/RaftServer.java | 9 +
.../internal/raft/server/impl/JraftServerImpl.java | 31 +-
.../apache/ignite/raft/jraft/RaftGroupService.java | 11 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 89 +++--
.../raft/jraft/disruptor/StripedDisruptor.java | 4 +-
.../ignite/raft/jraft/option/NodeOptions.java | 13 -
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 2 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 3 +-
.../raft/client/TopologyAwareRaftGroupService.java | 3 +-
.../apache/ignite/internal/replicator/Replica.java | 15 +
.../ignite/internal/replicator/ReplicaManager.java | 38 +-
.../ignite/internal/replicator/ReplicaService.java | 81 ++--
.../client/TopologyAwareRaftGroupServiceTest.java | 6 +-
.../replicator/PlacementDriverReplicaSideTest.java | 1 +
modules/rest-api/openapi/openapi.yaml | 4 +-
.../rest/api/deployment/UnitStatusDto.java | 23 +-
.../cluster/ItClusterManagementControllerTest.java | 18 +-
.../DeploymentManagementControllerTest.java | 2 +-
.../DelegatingAuthenticationProvider.java | 4 +-
.../internal/rest/cluster/TopologyController.java | 7 +-
.../rest/deployment/CodeDeploymentRestFactory.java | 2 +-
.../deployment/DeploymentManagementController.java | 32 +-
.../handler/VersionParseExceptionHandler.java | 2 +-
.../StubAuthenticationViewEvent.java | 17 +-
modules/runner/build.gradle | 41 +-
.../java/org/apache/ignite/internal/Cluster.java | 3 +-
.../internal/ClusterPerTestIntegrationTest.java | 11 +-
.../cluster/management/ItClusterInitTest.java | 27 +-
.../internal/compute/ItLogicalTopologyTest.java | 104 ++++-
.../ItDistributedConfigurationPropertiesTest.java | 10 +-
.../ItSslConfigurationValidationTest.java | 4 +-
.../ItDistributedConfigurationStorageTest.java | 12 +-
.../storage/ItRebalanceDistributedTest.java | 156 ++++----
.../internal/deployment/ItDeploymentUnitTest.java | 51 ++-
.../inmemory/ItRaftStorageVolatilityTest.java | 6 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 75 +++-
.../ignite/internal/rest/AbstractRestTestBase.java | 3 +-
.../org/apache/ignite/internal/rest/RestNode.java | 5 +-
.../runner/app/AbstractSchemaChangeTest.java | 3 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 7 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 9 +-
.../runner/app/ItIgniteNodeRestartTest.java | 146 +++++--
.../ignite/internal/runner/app/ItIgnitionTest.java | 114 ++----
.../internal/runner/app/ItNoThreadsLeftTest.java | 3 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 2 -
.../runner/app/ItTableApiContractTest.java | 8 +-
.../internal/runner/app/ItTableCreationTest.java | 3 +-
.../internal/runner/app/ItTablesApiTest.java | 7 +-
.../runner/app/PlatformBenchmarkNodeRunner.java | 73 ++++
.../runner/app/PlatformTestNodeRunner.java | 108 +++---
.../app/client/ItAbstractThinClientTest.java | 6 +-
.../runner/app/client/ItThinClientSqlTest.java | 6 +-
.../sql/engine/ClusterPerClassIntegrationTest.java | 35 +-
.../internal/sql/engine/ItAggregatesTest.java | 3 +-
.../internal/sql/engine/ItBuildIndexTest.java | 143 +++++++
.../internal/sql/engine/ItCorrelatesTest.java | 20 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 11 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 39 ++
.../sql/engine/ItDynamicParameterTest.java | 3 +-
.../internal/sql/engine/ItIndexSpoolTest.java | 5 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 4 +
.../ignite/internal/sql/engine/ItUuidTest.java | 7 +
.../ignite/internal/sqllogic/ItSqlLogicTest.java | 3 +-
.../internal/table/ItReadOnlyTransactionTest.java | 10 +-
.../ignite/internal/table/ItRoReadsTest.java | 11 +-
.../ignite/internal/table/ItTableScanTest.java | 4 +-
.../internal/test/WatchListenerInhibitor.java | 26 +-
.../sql/insert/test_big_insert.test_ignore | 2 +-
.../sql/join/inner/test_using_join.test | 16 +-
.../sql/join/inner/test_using_join.test_ignore | 3 +-
.../sql/join/test_not_distinct_from.test | 7 +
.../sql/join/test_not_distinct_from.test_ignore | 255 -------------
.../sql/types/decimal/test_decimal_ops.test | 33 +-
.../java/org/apache/ignite/app/IgniteRunner.java | 2 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 54 +--
.../apache/ignite/internal/app/IgnitionImpl.java | 50 +--
.../configuration/NodeBootstrapConfiguration.java | 135 -------
.../storage/DistributedConfigurationStorage.java | 16 +-
.../storage/LocalFileConfigurationStorage.java | 10 +-
.../DistributedConfigurationCatchUpTest.java | 11 +-
.../storage/LocalFileConfigurationStorageTest.java | 10 +-
.../ignite/internal/schema/SchemaManager.java | 2 +-
.../ConfigurationToSchemaDescriptorConverter.java | 6 +-
.../configuration/TableConfigurationSchema.java | 12 +-
.../AuthenticationProvidersValidatorImpl.java | 9 +-
modules/sql-engine/src/main/codegen/config.fmpp | 4 +-
.../internal/sql/engine/AsyncSqlCursorImpl.java | 53 ++-
.../ignite/internal/sql/engine/QueryProcessor.java | 25 --
.../internal/sql/engine/SqlQueryProcessor.java | 124 +-----
.../sql/engine/exec/ExecutionServiceImpl.java | 5 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 42 +-
.../exec/ddl/DdlToCatalogCommandConverter.java | 2 -
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 8 +
.../internal/sql/engine/exec/exp/RexImpTable.java | 321 +++++-----------
.../internal/sql/engine/exec/rel/ModifyNode.java | 26 +-
.../engine/metadata/IgniteMdFragmentMapping.java | 14 +-
.../sql/engine/prepare/IgniteConvertletTable.java | 5 +-
.../internal/sql/engine/prepare/IgnitePlanner.java | 13 +-
.../internal/sql/engine/prepare/Splitter.java | 12 +-
.../sql/engine/prepare/ddl/CreateTableCommand.java | 37 --
.../prepare/ddl/DdlSqlToCommandConverter.java | 28 +-
.../rule/TableFunctionScanConverterRule.java | 4 +-
.../sql/engine/rule/TableModifyConverterRule.java | 74 +++-
.../sql/engine/rule/ValuesConverterRule.java | 4 +-
.../sql/engine/schema/IgniteTableImpl.java | 3 +-
.../sql/engine/schema/TableDescriptorImpl.java | 20 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 25 ++
.../sql/engine/type/IgniteTypeFactory.java | 31 +-
.../sql/engine/util/HashFunctionFactoryImpl.java | 17 +-
.../internal/sql/engine/util/IgniteMethod.java | 6 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 28 +-
.../sql/engine/exec/MockedStructuresTest.java | 170 ++++-----
.../engine/framework/ClusterServiceFactory.java | 18 +-
.../sql/engine/planner/DmlPlannerTest.java | 166 ++++++++
.../engine/prepare/LeastRestrictiveTypesTest.java | 34 +-
modules/storage-api/build.gradle | 3 +
.../internal/storage/DataStorageManager.java | 1 -
.../internal/storage/engine/MvTableStorage.java | 6 +
.../internal/storage/engine/StorageEngine.java | 5 +-
.../internal/storage/index/IndexStorage.java | 26 +-
.../storage/index/SortedIndexDescriptor.java | 8 +-
.../internal/storage/util/MvPartitionStorages.java | 6 +-
.../internal/storage/TestMvTableStorageTest.java | 9 +-
.../storage/index/TestHashIndexStorageTest.java | 7 +-
.../storage/index/TestSortedIndexStorageTest.java | 8 +-
.../storage/util/MvPartitionStoragesTest.java | 10 +-
.../storage/AbstractMvTableStorageTest.java | 82 +++-
.../storage/BaseMvPartitionStorageTest.java | 5 +-
.../internal/storage/BaseMvStoragesTest.java | 1 -
.../internal/storage/impl/TestMvTableStorage.java | 18 +-
.../internal/storage/impl/TestStorageEngine.java | 7 +-
...xStorage.java => AbstractTestIndexStorage.java} | 114 ++----
.../storage/index/impl/TestHashIndexStorage.java | 108 +-----
.../storage/index/impl/TestSortedIndexStorage.java | 113 +-----
modules/storage-page-memory/build.gradle | 1 +
.../pagememory/AbstractPageMemoryTableStorage.java | 15 +-
.../PersistentPageMemoryStorageEngine.java | 22 +-
.../PersistentPageMemoryTableStorage.java | 4 +-
.../VolatilePageMemoryStorageEngine.java | 22 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 4 +-
.../index/AbstractPageMemoryIndexStorage.java | 215 +++++++++++
.../index/hash/PageMemoryHashIndexStorage.java | 136 +------
.../storage/pagememory/index/meta/IndexMeta.java | 31 +-
.../pagememory/index/meta/IndexMetaKey.java} | 26 +-
.../pagememory/index/meta/IndexMetaTree.java | 6 +-
.../UpdateLastRowIdUuidToBuiltInvokeClosure.java | 60 +++
.../pagememory/index/meta/io/IndexMetaInnerIo.java | 9 +-
.../pagememory/index/meta/io/IndexMetaIo.java | 51 ++-
.../pagememory/index/meta/io/IndexMetaLeafIo.java | 9 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 140 +------
.../mv/AbstractPageMemoryMvPartitionStorage.java | 46 +--
.../mv/PersistentPageMemoryMvPartitionStorage.java | 5 +-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 5 +-
.../PersistentPageMemoryMvTableStorageTest.java | 11 +-
.../VolatilePageMemoryMvTableStorageTest.java | 10 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 8 +-
...PersistentPageMemorySortedIndexStorageTest.java | 8 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 8 +-
.../VolatilePageMemorySortedIndexStorageTest.java | 8 +-
modules/storage-rocksdb/build.gradle | 1 +
.../internal/storage/rocksdb/GarbageCollector.java | 8 +-
.../ignite/internal/storage/rocksdb/HashIndex.java | 7 +-
.../storage/rocksdb/PartitionDataHelper.java | 40 +-
.../storage/rocksdb/RocksDbMetaStorage.java | 108 +++++-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 4 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 19 +-
.../storage/rocksdb/RocksDbStorageUtils.java | 69 ++++
.../storage/rocksdb/RocksDbTableStorage.java | 49 ++-
.../internal/storage/rocksdb/SortedIndex.java | 7 +-
.../rocksdb/index/AbstractRocksDbIndexStorage.java | 205 ++++++++++
.../rocksdb/index/RocksDbHashIndexStorage.java | 161 +-------
.../rocksdb/index/RocksDbSortedIndexStorage.java | 170 ++-------
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 12 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 15 +-
.../rocksdb/index/RocksDbHashIndexStorageTest.java | 8 +-
.../index/RocksDbSortedIndexStorageTest.java | 8 +-
modules/table/build.gradle | 2 +
.../ItAbstractInternalTableScanTest.java | 7 +-
.../ItInternalTableReadOnlyOperationsTest.java | 4 +
.../ItInternalTableReadOnlyScanTest.java | 7 +-
.../ItInternalTableReadWriteScanTest.java | 2 -
.../ignite/distributed/ItTablePersistenceTest.java | 17 +-
.../distributed/ItTxDistributedTestSingleNode.java | 19 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 24 +-
.../apache/ignite/internal/table/TableImpl.java | 139 ++++---
.../internal/table/distributed/PartitionMover.java | 3 +-
.../table/distributed/StorageUpdateHandler.java | 69 +++-
.../distributed/TableIndexStoragesSupplier.java} | 21 +-
.../internal/table/distributed/TableManager.java | 200 ++++++----
.../table/distributed/TableMessageGroup.java | 4 +
.../distributed/command/BuildIndexCommand.java} | 41 +-
.../distributed/raft/PartitionDataStorage.java | 11 +
.../table/distributed/raft/PartitionListener.java | 67 ++--
.../raft/RebalanceRaftGroupEventsListener.java | 2 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 9 +
.../SnapshotAwarePartitionDataStorage.java | 6 +
.../replicator/PartitionReplicaListener.java | 80 ----
.../org/apache/ignite/internal/table/Example.java | 4 +-
.../AbstractMvStorageUpdateHandlerTest.java | 149 ++++++++
.../internal/table/distributed/IndexBaseTest.java | 31 +-
.../table/distributed/IndexCleanupTest.java | 22 +-
.../internal/table/distributed/IndexGcTest.java | 10 +-
.../PartitionGcOnWriteConcurrentTest.java | 9 +-
.../table/distributed/PartitionGcOnWriteTest.java | 10 +-
...istentPageMemoryMvStorageUpdateHandlerTest.java | 55 +++
.../RocksDbMvStorageUpdateHandlerTest.java} | 35 +-
.../distributed/StorageUpdateHandlerTest.java | 132 +++++++
.../TableManagerDistributionZonesTest.java | 51 ++-
.../table/distributed/TableManagerTest.java | 188 +++++++--
.../TestMvStorageUpdateHandlerTest.java} | 17 +-
...latilePageMemoryMvStorageUpdateHandlerTest.java | 39 ++
.../raft/PartitionCommandListenerTest.java | 95 +++--
.../raft/snapshot/PartitionAccessImplTest.java | 16 +-
.../incoming/IncomingSnapshotCopierTest.java | 37 +-
.../PartitionReplicaListenerIndexLockingTest.java | 7 +-
.../replication/PartitionReplicaListenerTest.java | 9 +-
.../distributed/TestPartitionDataStorage.java | 6 +
.../table/impl/DummyInternalTableImpl.java | 26 +-
modules/transactions/build.gradle | 1 +
.../state/rocksdb/TxStateRocksDbTableStorage.java | 8 +-
.../state/rocksdb/RocksDbTxStateStorageTest.java | 7 +-
481 files changed, 10160 insertions(+), 6208 deletions(-)
create mode 100644
modules/api/src/testFixtures/java/org/apache/ignite/internal/testframework/TestIgnitionManager.java
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/cluster/init/ItClusterInitTest.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/cluster/AuthenticationConfigConverter.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/cluster/init/AuthenticationOptions.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/ApiClientBuilder.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/ApiClientFactory.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/rest/ApiClientFactory.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/rest/ApiClientSettings.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/rest/ApiClientSettingsBuilder.java
copy
modules/{rest/src/main/java/org/apache/ignite/internal/rest/deployment/CodeDeploymentRestFactory.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/core/rest/BasicAuthenticationInterceptor.java}
(51%)
copy modules/{api/src/main/java/org/apache/ignite/binary/BinaryObject.java =>
client/src/main/java/org/apache/ignite/internal/client/ClientChannelFactory.java}
(57%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/ClientMetricSource.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/ClientMetricsTest.java
rename modules/client/src/test/java/org/apache/ignite/client/{MetricsTest.java
=> ServerMetricsTest.java} (98%)
copy
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/{ClusterManagementConfigurationModule.java
=> NodeAttributeConfigurationSchema.java} (56%)
copy
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/{ClusterManagementConfigurationModule.java
=> NodeAttributesConfigurationSchema.java} (60%)
create mode 100644
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/topology/api/LogicalNode.java
rename modules/{api/src/main/java/org/apache/ignite/deployment =>
code-deployment/src/main/java/org/apache/ignite/internal/deployunit}/DeploymentInfo.java
(98%)
rename modules/{api/src/main/java/org/apache/ignite/deployment =>
code-deployment/src/main/java/org/apache/ignite/internal/deployunit}/DeploymentStatus.java
(96%)
copy modules/{api/src/main/java/org/apache/ignite/deployment =>
code-deployment/src/main/java/org/apache/ignite/internal/deployunit}/DeploymentUnit.java
(96%)
rename modules/{api/src/main/java/org/apache/ignite/deployment =>
code-deployment/src/main/java/org/apache/ignite/internal/deployunit}/IgniteDeployment.java
(78%)
rename modules/{api/src/main/java/org/apache/ignite/deployment =>
code-deployment/src/main/java/org/apache/ignite/internal/deployunit}/UnitStatus.java
(97%)
rename modules/{api/src/main/java/org/apache/ignite/deployment =>
code-deployment/src/main/java/org/apache/ignite/internal/deployunit}/version/UnitVersion.java
(98%)
rename modules/{api/src/main/java/org/apache/ignite/deployment =>
code-deployment/src/main/java/org/apache/ignite/internal/deployunit}/version/Version.java
(97%)
rename modules/{api/src/main/java/org/apache/ignite/deployment =>
code-deployment/src/main/java/org/apache/ignite/internal/deployunit}/version/VersionParseException.java
(96%)
rename modules/{api =>
code-deployment}/src/test/java/org/apache/ignite/deployment/version/VersionUnitTest.java
(91%)
create mode 100644
modules/distribution-zones/src/testFixtures/java/org/apache/ignite/internal/distributionzones/DistributionZonesTestUtil.java
create mode 100644
modules/index/src/main/java/org/apache/ignite/internal/index/IndexBuilder.java
delete mode 100644
modules/network-api/src/main/java/org/apache/ignite/network/ClusterLocalConfiguration.java
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Benchmarks/ManyConnectionsBenchmark.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Metrics.cs
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/PlatformBenchmarkNodeRunner.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItBuildIndexTest.java
delete mode 100644
modules/runner/src/integrationTest/sql/join/test_not_distinct_from.test_ignore
delete mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/configuration/NodeBootstrapConfiguration.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/DmlPlannerTest.java
copy
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/index/impl/{TestHashIndexStorage.java
=> AbstractTestIndexStorage.java} (55%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/AbstractPageMemoryIndexStorage.java
copy
modules/{api/src/main/java/org/apache/ignite/deployment/DeploymentUnit.java =>
storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/meta/IndexMetaKey.java}
(68%)
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/meta/UpdateLastRowIdUuidToBuiltInvokeClosure.java
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbStorageUtils.java
create mode 100644
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/AbstractRocksDbIndexStorage.java
rename
modules/{api/src/main/java/org/apache/ignite/deployment/DeploymentUnit.java =>
table/src/main/java/org/apache/ignite/internal/table/distributed/TableIndexStoragesSupplier.java}
(63%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/raft/commands/ClusterNodeMessage.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/command/BuildIndexCommand.java}
(54%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/AbstractMvStorageUpdateHandlerTest.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/PersistentPageMemoryMvStorageUpdateHandlerTest.java
copy
modules/{storage-api/src/test/java/org/apache/ignite/internal/storage/TestMvTableStorageTest.java
=>
table/src/test/java/org/apache/ignite/internal/table/distributed/RocksDbMvStorageUpdateHandlerTest.java}
(52%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/StorageUpdateHandlerTest.java
copy modules/{platforms/dotnet/Apache.Ignite.Benchmarks/Program.cs =>
table/src/test/java/org/apache/ignite/internal/table/distributed/TestMvStorageUpdateHandlerTest.java}
(68%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/VolatilePageMemoryMvStorageUpdateHandlerTest.java
