This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-18171
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 4bab16c142 wip. Rewrite dynamic tests to parameterized.
discard e95a4a992a wip.
discard 7386aafb18 wip.
discard 2d94efe187 Wip.
discard a1bb57677b Added test template.
add 0dee58379b IGNITE-17132 [Native Persistence 3.0] Implement partition
destruction for persistent PageMemory (#1325)
add 6a2a2e6a2d IGNITE-18172 Added learners' assignments to the rebalance
algorithm (#1366)
add 8e864e6a32 IGNITE-18246 .NET: LINQ: Add support for Intersect, Union,
Except (#1386)
add 8a7198d1bc IGNITE-18229 Added JmxExporter to META-INF.services. Fixes
#1367
add e9ea7bd0bb IGNITE-17959 Added retrying in ReplicaService for a case
when an operation throws ReplicaUnavailableException in ReplicaManager. (#1369)
add c5ea2032db IGNITE-18276 Return topology version in
CMGManager.logicalTopology (#1388)
add 361f8965f5 IGNITE-18261 Use RAFT learners to get updates of logical
topology on non-CMG nodes (#1384)
add ca97d097f6 IGNITE-18218 Add documentation for cluster init (#1387)
add 7d25ae46d5 IGNITE-18250 Marked integration test folder as test source
root. Fixes #1389
add dcefab8f0f IGNITE-18295 Do not swallow exceptions in
DefaultMessagingService#onMessage() (#1394)
add d980d03bc1 IGNITE-18148 CLI Added more dynamic completers. Fixes #1363
add 5ea38a55a5 IGNITE-18205 Sql. Allow hash output distribution for
aggregations (#1381)
add 1c975f5675 IGNITE-18298 .NET: Enable Java assertions in tests (#1396)
add 08763d0de1 IGNITE-18123 .NET: LINQ: Improve Skip and Take (offset /
limit) support (#1395)
add 3757086e34 Added test template.
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 (4bab16c142)
\
N -- N -- N refs/heads/ignite-18171 (3757086e34)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
build.gradle | 6 +-
buildscripts/java-integration-test.gradle | 9 +
.../includes/ignite-cli-download-windows.adoc | 2 +-
docs/_docs/quick-start/getting-started-guide.adoc | 8 +-
.../ignite/internal/affinity/AffinityUtils.java | 57 +-
.../ignite/internal/affinity/Assignment.java | 96 ++++
.../internal/affinity/AffinityServiceTest.java | 9 +-
.../ignite/internal/cli/commands/BaseCommand.java | 13 +-
.../ignite/internal/cli/commands/Options.java | 215 ++++++++
.../internal/cli/commands/OptionsConstants.java | 62 ---
.../ignite/internal/cli/commands/ProfileMixin.java | 6 +-
.../internal/cli/commands/TopLevelCliCommand.java | 5 +-
.../profile/CliConfigProfileCreateCommand.java | 11 +-
.../cli/commands/cluster/ClusterUrlMixin.java | 8 +-
.../commands/cluster/init/ClusterInitOptions.java | 26 +-
.../cluster/topology/LogicalTopologyCommand.java | 5 +-
.../topology/LogicalTopologyReplCommand.java | 5 +-
.../cluster/topology/PhysicalTopologyCommand.java | 5 +-
.../topology/PhysicalTopologyReplCommand.java | 5 +-
.../cli/commands/connect/ConnectCommand.java | 4 +-
.../cli/commands/connect/ConnectReplCommand.java | 4 +-
.../internal/cli/commands/node/NodeUrlMixin.java | 15 +-
.../internal/cli/commands/sql/SqlCommand.java | 17 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 16 +-
.../cli/core/repl/completer/CompleterConf.java | 145 ++++++
.../{CompleterFilter.java => DummyCompleter.java} | 13 +-
.../cli/core/repl/completer/DynamicCompleter.java | 11 +-
.../completer/DynamicCompleterActivationPoint.java | 71 ++-
.../repl/completer/DynamicCompleterFactory.java | 90 +---
.../repl/completer/DynamicCompleterFilter.java | 40 +-
.../repl/completer/DynamicCompleterRegistry.java | 113 ++--
.../repl/completer/NodeNameDynamicCompleter.java | 61 ---
.../cli/core/repl/completer/NodeUrlProvider.java | 5 +-
.../ClusterConfigDynamicCompleterFactory.java | 71 +++
.../{ => hocon}/HoconDynamicCompleter.java | 30 +-
.../hocon/NodeConfigDynamicCompleterFactory.java | 70 +++
.../node/NodeNameDynamicCompleterFactory.java} | 31 +-
.../StringDynamicCompleter.java} | 41 +-
.../core/repl/executor/IgnitePicocliCommands.java | 12 +-
.../cli/core/repl/executor/ReplExecutor.java | 1 +
.../completer/DynamicCompleterRegistryTest.java | 233 ++++++++-
.../repl/completer/HoconDynamicCompleterTest.java | 5 +-
...erTest.java => StringDynamicCompleterTest.java} | 42 +-
.../cluster/management/ItClusterManagerTest.java | 52 +-
.../internal/cluster/management/MockNode.java | 6 +
.../management/raft/ItCmgRaftServiceTest.java | 34 +-
.../management/ClusterManagementGroupManager.java | 85 ++-
.../management/raft/CmgRaftGroupListener.java | 17 +-
.../cluster/management/raft/CmgRaftService.java | 49 +-
.../raft/responses/LogicalTopologyResponse.java | 9 +-
.../management/rest/TopologyController.java | 4 +
.../management/topology/LogicalTopology.java | 5 +-
.../management/topology/LogicalTopologyImpl.java | 5 +-
.../management/raft/CmgRaftGroupListenerTest.java | 70 ++-
.../topology/LogicalTopologyImplTest.java | 26 +-
...nite.internal.metrics.exporters.MetricExporter} | 3 +-
.../ignite/network/DefaultMessagingService.java | 22 +-
.../ItBplusTreePersistentPageMemoryTest.java | 2 +-
...BplusTreeReuseListPersistentPageMemoryTest.java | 2 +-
.../persistence/PartitionMetaManager.java | 10 +-
.../persistence/PartitionProcessingCounter.java | 85 +++
.../persistence/PartitionProcessingCounterMap.java | 84 +++
.../persistence/checkpoint/CheckpointManager.java | 32 +-
.../checkpoint/CheckpointPagesWriter.java | 119 +++--
.../checkpoint/CheckpointPagesWriterFactory.java | 8 -
.../checkpoint/CheckpointProgressImpl.java | 44 +-
.../checkpoint/CheckpointTimeoutLock.java | 10 +-
.../persistence/checkpoint/Checkpointer.java | 83 ++-
.../persistence/compaction/Compactor.java | 220 +++++---
.../persistence/store/FilePageStore.java | 17 +
.../persistence/store/FilePageStoreManager.java | 290 ++++++-----
.../persistence/store/GroupPageStoresMap.java | 86 +++-
.../store/LongOperationAsyncExecutor.java | 35 +-
.../persistence/PartitionMetaManagerTest.java | 17 +
.../PartitionProcessingCounterMapTest.java | 79 +++
.../PartitionProcessingCounterTest.java} | 52 +-
.../PersistentPageMemoryNoLoadTest.java | 19 +-
.../checkpoint/CheckpointManagerTest.java | 13 +-
.../checkpoint/CheckpointPagesWriterTest.java | 7 -
.../checkpoint/CheckpointProgressImplTest.java | 48 ++
.../checkpoint/CheckpointTestUtils.java | 8 +-
.../checkpoint/CheckpointTimeoutLockTest.java | 24 +-
.../persistence/checkpoint/CheckpointerTest.java | 65 ++-
.../persistence/compaction/CompactorTest.java | 23 +-
.../store/FilePageStoreManagerTest.java | 240 ++++++---
.../persistence/store/GroupPageStoresMapTest.java | 238 ++++++---
.../store/LongOperationAsyncExecutorTest.java | 93 +---
.../dotnet/Apache.Ignite.Tests/JavaServer.cs | 3 +-
.../Linq/LinqSqlGenerationTests.cs | 62 +++
.../Apache.Ignite.Tests/Linq/LinqTests.GroupBy.cs | 40 ++
.../Linq/LinqTests.UnionIntersectExcept.cs | 159 ++++++
.../dotnet/Apache.Ignite.Tests/Linq/LinqTests.cs | 86 +++-
.../Internal/Common/StringBuilderExtensions.cs | 18 +
.../Internal/Linq/IgniteQueryExecutor.cs | 11 +
.../Internal/Linq/IgniteQueryModelVisitor.cs | 159 +++---
.../Table/Serialization/ReflectionUtils.cs | 11 +-
.../dotnet/Apache.Ignite/Sql/IResultSet.cs | 2 +
.../java/org/apache/ignite/internal/raft/Loza.java | 70 ++-
.../raft/server/RaftGroupEventsListener.java | 2 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 2 +-
.../ignite/internal/replicator/ReplicaManager.java | 114 ++--
.../ignite/internal/replicator/ReplicaService.java | 67 ++-
...plicaResponse.java => AwaitReplicaRequest.java} | 21 +-
...eSyncRequest.java => AwaitReplicaResponse.java} | 6 +-
.../replicator/message/ReplicaMessageGroup.java | 6 +
modules/runner/build.gradle | 2 +
.../storage/ItRebalanceDistributedTest.java | 10 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 1 -
.../runner/app/ItIgniteNodeRestartTest.java | 4 -
.../internal/sql/engine/ItAggregatesTest.java | 35 ++
.../internal/sql/engine/ItIndexSpoolTest.java | 2 -
.../sql/engine/exec/LogicalRelImplementor.java | 8 +-
.../sql/engine/prepare/IgniteRelShuttle.java | 8 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 4 +-
.../internal/sql/engine/rel/IgniteRelVisitor.java | 8 +-
...Base.java => IgniteColocatedAggregateBase.java} | 29 +-
...gate.java => IgniteColocatedHashAggregate.java} | 10 +-
...gate.java => IgniteColocatedSortAggregate.java} | 10 +-
.../engine/rel/logical/IgniteLogicalIndexScan.java | 6 +-
.../engine/rule/HashAggregateConverterRule.java | 20 +-
.../engine/rule/SortAggregateConverterRule.java | 20 +-
.../engine/rule/logical/LogicalOrToUnionRule.java | 2 +-
.../engine/rule/logical/ProjectScanMergeRule.java | 4 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 10 +-
.../sql/engine/schema/TableDescriptorImpl.java | 23 +-
.../sql/engine/trait/DistributionTrait.java | 4 +-
.../sql/engine/trait/IgniteDistributions.java | 4 +-
.../internal/sql/engine/trait/TraitUtils.java | 7 +-
.../ignite/internal/sql/engine/util/Commons.java | 58 ++-
.../ignite/internal/sql/engine/util/RexUtils.java | 4 +-
.../sql/engine/exec/MockedStructuresTest.java | 2 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 8 +-
.../exec/rel/HashAggregateExecutionTest.java | 2 +-
.../exec/rel/SortAggregateExecutionTest.java | 2 +-
.../sql/engine/planner/AbstractPlannerTest.java | 15 +
.../planner/AggregateDistinctPlannerTest.java | 26 +-
.../sql/engine/planner/AggregatePlannerTest.java | 68 ++-
.../engine/planner/JoinColocationPlannerTest.java | 2 +
.../internal/sql/engine/planner/PlannerTest.java | 4 +
.../engine/planner/SortAggregatePlannerTest.java | 95 +++-
...eException.java => StorageClosedException.java} | 12 +-
.../internal/storage/engine/MvTableStorage.java | 8 +-
.../storage/AbstractMvTableStorageTest.java | 147 +++++-
.../internal/storage/BaseMvStoragesTest.java | 23 +
.../storage/impl/TestMvPartitionStorage.java | 63 ++-
.../internal/storage/impl/TestMvTableStorage.java | 67 ++-
.../index/AbstractHashIndexStorageTest.java | 2 +
.../storage/index/impl/TestHashIndexStorage.java | 32 +-
.../storage/index/impl/TestSortedIndexStorage.java | 54 +-
.../pagememory/AbstractPageMemoryTableStorage.java | 107 ++--
.../PersistentPageMemoryStorageEngine.java | 3 -
.../PersistentPageMemoryTableStorage.java | 123 +++--
.../pagememory/VolatilePageMemoryTableStorage.java | 22 +-
.../index/hash/PageMemoryHashIndexStorage.java | 116 ++++-
.../index/sorted/PageMemorySortedIndexStorage.java | 132 ++++-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 474 +++++++++++------
.../mv/PersistentPageMemoryMvPartitionStorage.java | 104 +++-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 25 +
.../PersistentPageMemoryMvTableStorageTest.java | 25 +-
.../VolatilePageMemoryMvTableStorageTest.java | 19 +-
.../AbstractPageMemoryHashIndexStorageTest.java | 7 -
...PersistentPageMemoryMvPartitionStorageTest.java | 3 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 3 +-
.../storage/rocksdb/RocksDbTableStorage.java | 50 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 17 +-
.../distributed/ItTxDistributedTestSingleNode.java | 136 +++--
.../ignite/distributed/ReplicaUnavailableTest.java | 180 +++++++
.../internal/table/distributed/TableManager.java | 572 ++++++++++-----------
.../raft/RebalanceRaftGroupEventsListener.java | 102 ++--
.../distributed/raft/snapshot/PartitionAccess.java | 4 +-
.../raft/snapshot/PartitionAccessImpl.java | 8 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 6 +-
.../distributed/replicator/LeaderOrTxState.java | 15 +-
.../replicator/PartitionReplicaListener.java | 9 +-
.../distributed/replicator/PlacementDriver.java | 35 +-
.../ignite/internal/utils/RebalanceUtil.java | 101 +---
.../table/distributed/TableManagerTest.java | 34 +-
.../PartitionReplicaListenerIndexLockingTest.java | 4 +-
.../replication/PartitionReplicaListenerTest.java | 96 ++--
.../table/impl/DummyInternalTableImpl.java | 1 -
.../ignite/internal/tx/impl/HeapLockManager.java | 2 +-
181 files changed, 5928 insertions(+), 2505 deletions(-)
create mode 100644
modules/affinity/src/main/java/org/apache/ignite/internal/affinity/Assignment.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/Options.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/OptionsConstants.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/completer/CompleterConf.java
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/completer/{CompleterFilter.java
=> DummyCompleter.java} (78%)
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/completer/NodeNameDynamicCompleter.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/completer/hocon/ClusterConfigDynamicCompleterFactory.java
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/completer/{
=> hocon}/HoconDynamicCompleter.java (73%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/completer/hocon/NodeConfigDynamicCompleterFactory.java
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/{executor/ReplExecutorProvider.java
=> completer/node/NodeNameDynamicCompleterFactory.java} (55%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/completer/{LazyDynamicCompleter.java
=> node/StringDynamicCompleter.java} (50%)
rename
modules/cli/src/test/java/org/apache/ignite/internal/cli/core/repl/completer/{NodeNameDynamicCompleterTest.java
=> StringDynamicCompleterTest.java} (53%)
copy
modules/{page-memory/src/main/resources/META-INF/services/org.apache.ignite.internal.pagememory.io.PageIoModule
=>
metrics/src/main/resources/META-INF/services/org.apache.ignite.internal.metrics.exporters.MetricExporter}
(92%)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PartitionProcessingCounter.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PartitionProcessingCounterMap.java
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/PartitionProcessingCounterMapTest.java
copy
modules/{raft/src/test/java/org/apache/ignite/raft/jraft/entity/BallotTest.java
=>
page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/PartitionProcessingCounterTest.java}
(54%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Linq/LinqTests.UnionIntersectExcept.cs
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/{ErrorReplicaResponse.java
=> AwaitReplicaRequest.java} (59%)
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/{ReplicaSafeTimeSyncRequest.java
=> AwaitReplicaResponse.java} (83%)
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/{IgniteSingleAggregateBase.java
=> IgniteColocatedAggregateBase.java} (73%)
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/{IgniteSingleHashAggregate.java
=> IgniteColocatedHashAggregate.java} (83%)
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/agg/{IgniteSingleSortAggregate.java
=> IgniteColocatedSortAggregate.java} (89%)
copy
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/{StorageException.java
=> StorageClosedException.java} (78%)
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/distributed/ReplicaUnavailableTest.java
