This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-18056
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 48a33e197a Merge branch 'main' into ignite-18056
add 43859a1f7e IGNITE-17998 Sql. Close the cursor synchronously when the
session is closed (#1330)
add 396413eca8 IGNITE-18122 Track last applied term and group config in
storages (#1331)
add 135ad346da IGNITE-18082 .NET: LINQ: Add support for joins (#1347)
add 3719a715b2 IGNITE-18105 Removed ivy dependency. Fixes #1322
add e06ef7eaca IGNITE-18012 Added connect command to start CLI in REPL
mode. Fixes #1283
add 5f09e12e76 IGNITE-16975 Update jansi version to fix CLI colors (#1344)
add 96b8bba33c IGNITE-18176 Update documentation introduction (#1349)
add 3afbef5076 IGNITE-18181 Fixed race during table creation (#1351)
add a98b7439d2 IGNITE-18184 .NET: Fix flaky pooled buffer leak check
(#1352)
add 49d453c15d IGNITE-17170 Dropped deprecated package. Fixes #1328
add d8a927116d IGNITE-17982 Fixed an issue that could lead to
testFixturesAnnotationProcessor for ignite-network-annotation-processor did not
work. Fixes #1326
add 3062df341f IGNITE-18063 Use consistent IDs in assignments (#1354)
add bf86c96589 IGNITE-18193 Removed transactions dependency from
storage-api (#1355)
add 51d25d217a IGNITE-17886 Table commands migrated to use
NetworkMessage-based code generation infrastructure
add 5e89398c76 IGNITE-18049 Cursor#close() should not declare any
exceptions in throws clause (#1358)
add 6721c55044 IGNITE-18155 Add learners to
RaftGroupService#changePeersAsync (#1348)
add 24531434f0 IGNITE-18083 .NET: LINQ: Add GroupBy support (#1360)
add b3963f4f5d IGNITE-18204 Start RAFT groups of table partitions in
parallel (#1357)
add de252873c7 IGNITE-18196 .NET: LINQ: Add aggregates support (#1365)
add bd6098e7b7 IGNITE-18212 Fix parsing error on GROUP BY with alias
(#1364)
add ae3c4660ab IGNITE-17917 Unified ignite3db start scripts. Fixes #1337
add 9f1220eb31 Merge branch 'main' into ignite-18056
No new revisions were added by this update.
Summary of changes:
docs/_config.yml | 4 +-
docs/_data/toc.yaml | 2 +-
docs/_docs/index.adoc | 39 +--
docs/_docs/installation/deb-rpm.adoc | 30 ++-
docs/_docs/quick-start/getting-started-guide.adoc | 15 +-
gradle/libs.versions.toml | 5 +-
modules/cli/build.gradle | 1 -
modules/cli/pom.xml | 5 -
.../ignite/internal/cli/IntegrationTestBase.java | 9 +-
.../call/CallInitializedIntegrationTestBase.java | 3 +-
.../CliCommandTestInitializedIntegrationBase.java | 3 +-
...liCommandTestNotInitializedIntegrationBase.java | 3 +-
.../ItClusterCommandTest.java | 18 +-
.../ItConfigCommandTest.java | 32 +--
.../apache/ignite/internal/cli/CliVersionInfo.java | 2 +-
.../java/org/apache/ignite/internal/cli/Main.java | 51 +---
.../apache/ignite/internal/cli/ReplManager.java | 70 +++++
.../internal/cli/commands/TopLevelCliCommand.java | 2 +
.../cli/commands/TopLevelCliReplCommand.java | 4 +-
.../cli/commands/connect/ConnectCommand.java | 9 +-
...ConnectCommand.java => ConnectReplCommand.java} | 4 +-
.../internal/cli/commands/node/NodeUrlMixin.java | 2 +-
.../questions/ConnectToClusterQuestion.java | 3 +
.../internal/cli/commands/sql/SqlCommand.java | 2 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 2 +-
.../exception}/IgniteCliException.java | 2 +-
.../handler/IgniteCliExceptionHandler.java | 2 +-
.../internal/cli/deprecated/CommandFactory.java | 46 ----
.../ignite/internal/cli/deprecated/Table.java | 206 ---------------
.../internal/cli/deprecated/package-info.java | 22 --
.../cli/deprecated/spec/NodeEndpointOptions.java | 80 ------
.../internal/cli/deprecated/spec/package-info.java | 22 --
.../internal/cli/deprecated/ui/ProgressBar.java | 141 ----------
.../ignite/internal/cli/deprecated/ui/Spinner.java | 74 ------
.../ignite/internal/cli/AbstractCliTest.java} | 45 +++-
.../{deprecated => }/IgniteCliInterfaceTest.java | 56 +---
.../cli/commands/UrlOptionsNegativeTest.java | 6 +-
.../internal/cli/deprecated/AbstractCliTest.java | 33 ---
.../internal/cli/deprecated/package-info.java | 22 --
.../cli/deprecated/ui/ProgressBarTest.java | 80 ------
.../internal/cli/deprecated/ui/SpinnerTest.java | 78 ------
.../internal/cli/deprecated/ui/package-info.java | 22 --
.../management/ClusterManagementGroupManager.java | 4 +-
.../raft/RocksDbClusterStateStorage.java | 4 +-
.../management/raft/TestClusterStateStorage.java | 2 +-
.../org/apache/ignite/internal/util/Cursor.java | 67 +++--
.../apache/ignite/internal/util/CursorUtils.java | 4 +-
.../{ReverseIterator.java => IteratorCursor.java} | 21 +-
.../apache/ignite/internal/util/CursorTest.java | 76 ++++++
.../ignite/internal/util/CursorUtilsTest.java | 2 +-
.../CompletableFutureExceptionMatcher.java | 39 ++-
.../client/ItMetaStorageRaftGroupTest.java | 2 +-
.../server/persistence/RangeCursor.java | 2 +-
.../server/persistence/WatchCursor.java | 5 +-
.../server/SimpleInMemoryKeyValueStorage.java | 4 +-
.../internal/metastorage/MetaStorageManager.java | 17 +-
.../metastorage/MetaStorageRangeCursorTest.java | 2 +-
.../pagememory/persistence/PartitionMeta.java | 64 ++++-
.../pagememory/persistence/io/PartitionMetaIo.java | 51 +++-
.../persistence/PartitionMetaManagerTest.java | 15 +-
.../pagememory/persistence/PartitionMetaTest.java | 67 ++++-
.../persistence/checkpoint/CheckpointerTest.java | 2 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 42 ++-
.../Linq/LinqSqlGenerationTests.cs | 38 ++-
.../Linq/LinqTests.Aggregate.cs | 159 ++++++++++++
.../Apache.Ignite.Tests/Linq/LinqTests.GroupBy.cs | 151 +++++++++++
.../Apache.Ignite.Tests/Linq/LinqTests.Join.cs | 281 ++++++++++++++++++++
.../dotnet/Apache.Ignite.Tests/Linq/LinqTests.cs | 122 ++++++---
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 10 +
.../Table/KeyValueViewPrimitiveTests.cs | 28 +-
.../Apache.Ignite.Tests/Table/PocoAllColumns.cs | 1 -
.../Table/RecordViewPocoTests.cs | 3 +-
.../Table/RecordViewPrimitiveTests.cs | 28 +-
.../Internal/Common/StringBuilderExtensions.cs} | 30 ++-
.../dotnet/Apache.Ignite/Internal/Linq/DEVNOTES.md | 4 +-
.../Internal/Linq/IgniteQueryExecutor.cs | 22 +-
.../Internal/Linq/IgniteQueryModelVisitor.cs | 115 +++------
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 18 +-
.../ignite/raft/client/service/CommandClosure.java | 8 +
.../client/service/CommittedConfiguration.java | 117 +++++++++
.../raft/client/service/LeaderWithTerm.java} | 26 +-
.../raft/client/service/RaftGroupListener.java | 9 +
.../raft/client/service/RaftGroupService.java | 19 +-
modules/raft/build.gradle | 1 +
.../internal/raft/ItRaftGroupServiceTest.java | 244 ++++++++++++------
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 21 +-
.../snasphot/SnapshotInMemoryStorageFactory.java | 3 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 17 +-
.../raft/server/RaftGroupEventsListener.java | 22 +-
.../internal/raft/server/impl/JraftServerImpl.java | 38 ++-
.../raft/storage/SnapshotStorageFactory.java | 4 +-
.../storage/impl/IgniteJraftServiceFactory.java | 8 +-
.../ignite/raft/jraft/JRaftServiceFactory.java | 5 +-
.../java/org/apache/ignite/raft/jraft/Node.java | 4 +-
.../org/apache/ignite/raft/jraft/StateMachine.java | 11 +
.../jraft/core/DefaultJRaftServiceFactory.java | 4 +-
.../ignite/raft/jraft/core/FSMCallerImpl.java | 33 +++
.../apache/ignite/raft/jraft/core/NodeImpl.java | 19 +-
.../apache/ignite/raft/jraft/rpc/CliRequests.java | 6 +
.../impl/cli/ChangePeersAsyncRequestProcessor.java | 25 +-
.../storage/snapshot/SnapshotExecutorImpl.java | 2 +-
.../ignite/raft/jraft/rpc/AbstractRpcTest.java | 59 ++---
.../cli/ChangePeersAsyncRequestProcessorTest.java | 27 +-
.../org/apache/ignite/raft/TestWriteCommand.java | 0
.../ignite/raft/jraft/rpc/TestMessages.java} | 49 ++--
.../ignite/raft/messages/TestMessageGroup.java | 0
.../exception/PrimaryReplicaMissException.java | 4 +-
.../internal/rocksdb/BusyRocksIteratorAdapter.java | 2 +-
.../internal/rocksdb/RocksIteratorAdapter.java | 2 +-
.../internal/AbstractClusterIntegrationTest.java | 2 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 7 +-
.../ignite/internal/sql/api/ItCommonApiTest.java | 9 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 5 +-
.../internal/sql/engine/ItAggregatesTest.java | 29 +++
.../DistributedConfigurationStorageTest.java | 2 +-
.../internal/sql/engine/exec/ExchangeService.java | 44 ++--
.../sql/engine/exec/ExchangeServiceImpl.java | 52 ++--
.../internal/sql/engine/exec/ExecutionContext.java | 30 +--
.../sql/engine/exec/ExecutionServiceImpl.java | 100 +++++---
.../sql/engine/exec/LogicalRelImplementor.java | 12 +-
.../sql/engine/exec/MailboxRegistryImpl.java | 4 +-
.../sql/engine/exec/RemoteFragmentKey.java | 18 +-
.../sql/engine/exec/RuntimeSortedIndex.java | 2 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 80 +++---
.../internal/sql/engine/exec/rel/Outbox.java | 55 ++--
.../sql/engine/message/MessageListener.java | 6 +-
.../sql/engine/message/MessageService.java | 13 +-
.../sql/engine/message/MessageServiceImpl.java | 40 +--
.../sql/engine/metadata/ColocationGroup.java | 56 ++--
.../sql/engine/metadata/FragmentDescription.java | 4 +-
.../sql/engine/metadata/FragmentMapping.java | 10 +-
.../engine/metadata/IgniteMdFragmentMapping.java | 2 +-
.../sql/engine/metadata/MappingServiceImpl.java | 2 +-
.../sql/engine/metadata/RemoteException.java | 18 +-
.../sql/engine/prepare/AbstractMultiStepPlan.java | 2 +-
.../internal/sql/engine/prepare/Fragment.java | 8 +-
.../sql/engine/prepare/MappingQueryContext.java | 12 +-
.../sql/engine/sql/IgniteSqlConformance.java | 12 +
.../sql/engine/trait/DistributionFunction.java | 12 +-
.../ignite/internal/sql/engine/util/Commons.java | 9 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 33 +--
.../sql/engine/exec/ExecutionServiceImplTest.java | 95 ++++---
.../exec/rel/TableScanNodeExecutionTest.java | 7 +-
modules/storage-api/build.gradle | 2 -
modules/storage-api/pom.xml | 5 -
.../internal/storage/MvPartitionStorage.java | 25 +-
.../internal/storage/RaftGroupConfiguration.java | 128 ++++++++++
.../org/apache/ignite/internal/storage/RowId.java | 8 +-
.../storage/AbstractMvPartitionStorageTest.java | 47 +++-
.../storage/AbstractMvTableStorageTest.java | 7 +-
.../storage/impl/TestMvPartitionStorage.java | 27 +-
.../storage/index/impl/TestHashIndexStorage.java | 2 +-
.../storage/index/impl/TestSortedIndexStorage.java | 4 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 4 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 41 ++-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 27 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 109 +++++++-
.../rocksdb/index/RocksDbHashIndexStorage.java | 6 +-
.../rocksdb/index/RocksDbSortedIndexStorage.java | 6 +-
.../ignite/distributed/ItTablePersistenceTest.java | 69 +++--
.../distributed/ItTxDistributedTestSingleNode.java | 5 +-
.../ignite/internal/table/ItColocationTest.java | 55 ++--
.../internal/table/distributed/PartitionMover.java | 99 +++++++
.../internal/table/distributed/TableManager.java | 137 ++++------
.../table/distributed/TableMessageGroup.java | 29 +++
.../table/distributed/command/FinishTxCommand.java | 56 +---
.../HybridTimestampMessage.java} | 21 +-
.../distributed/command/PartitionCommand.java | 24 +-
.../TablePartitionIdMessage.java} | 18 +-
.../distributed/command/TxCleanupCommand.java | 42 +--
.../distributed/command/UpdateAllCommand.java | 106 +-------
.../table/distributed/command/UpdateCommand.java | 92 +------
.../distributed/raft/PartitionDataStorage.java | 33 ++-
.../table/distributed/raft/PartitionListener.java | 135 +++++++---
.../raft/RebalanceRaftGroupEventsListener.java | 43 ++--
.../raft/snapshot/PartitionSnapshotStorage.java | 30 ++-
.../snapshot/PartitionSnapshotStorageFactory.java | 23 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 42 ++-
.../snapshot/incoming/IncomingSnapshotReader.java | 4 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 55 ++--
.../snapshot/outgoing/OutgoingSnapshotReader.java | 6 +-
.../outgoing/OutgoingSnapshotsManager.java | 3 +-
.../SnapshotAwarePartitionDataStorage.java | 20 +-
.../raft/snapshot/outgoing/SnapshotMetaUtils.java | 32 +--
.../replicator/PartitionReplicaListener.java | 184 ++++++++++---
.../distributed/storage/InternalTableImpl.java | 21 +-
.../ignite/internal/utils/RebalanceUtil.java | 3 +-
.../table/distributed/PartitionMoverTest.java | 95 +++++++
.../table/distributed/TableManagerTest.java | 144 -----------
.../PartitionRaftCommandsSerializationTest.java | 121 ++++++---
.../raft/PartitionCommandListenerTest.java | 284 +++++++++++++++++----
.../raft/RebalanceRaftGroupEventsListenerTest.java | 13 +-
.../PartitionSnapshotStorageFactoryTest.java | 65 +++--
.../snapshot/PartitionSnapshotStorageTest.java | 67 +++++
.../incoming/IncomingSnapshotCopierTest.java | 39 ++-
.../incoming/IncomingSnapshotReaderTest.java} | 12 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 64 ++---
.../OutgoingSnapshotMvDataStreamingTest.java | 46 +++-
.../outgoing/OutgoingSnapshotReaderTest.java | 41 +--
.../OutgoingSnapshotTxDataStreamingTest.java | 34 +--
.../outgoing/OutgoingSnapshotsManagerTest.java | 26 +-
.../SnapshotAwarePartitionDataStorageTest.java | 36 ++-
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 37 +--
.../PartitionReplicaListenerIndexLockingTest.java | 4 +-
.../replication/PartitionReplicaListenerTest.java | 5 +-
.../table/impl/DummyInternalTableImpl.java | 10 +-
.../distributed/TestPartitionDataStorage.java | 21 +-
.../internal/tx/storage/state/TxStateStorage.java | 19 +-
.../state/rocksdb/TxStateRocksDbStorage.java | 69 +++--
.../storage/state/TxStateStorageAbstractTest.java | 42 ++-
.../tx/storage/state/test/TestTxStateStorage.java | 13 +-
.../vault/persistence/PersistentVaultService.java | 4 +-
.../vault/inmemory/InMemoryVaultService.java | 2 +-
packaging/build.gradle | 24 +-
packaging/cli/build.gradle | 18 +-
packaging/cli/start.sh | 57 +----
packaging/common/bootstrap-functions.sh | 56 ++++
packaging/{cli/start.sh => common/setup-java.sh} | 52 +---
.../config/ignite.java.util.logging.properties | 47 ----
packaging/db/build.gradle | 67 +++--
packaging/db/ignite.java.util.logging.properties | 2 +-
packaging/docker/Dockerfile | 3 +-
packaging/docker/docker-entrypoint.sh | 21 +-
packaging/linux/start.sh | 26 +-
.../{linux/deb/postUninstall.sh => zip/ignite3db} | 46 +++-
packaging/zip/ignite3db.sh | 79 ------
packaging/zip/{bootstrap-config.env => vars.env} | 25 +-
parent/pom.xml | 9 +-
228 files changed, 4678 insertions(+), 3342 deletions(-)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/{deprecated
=> commands}/ItClusterCommandTest.java (94%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/{deprecated
=> commands}/ItConfigCommandTest.java (88%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/ReplManager.java
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/connect/{ConnectCommand.java
=> ConnectReplCommand.java} (94%)
rename modules/cli/src/main/java/org/apache/ignite/internal/cli/{deprecated =>
core/exception}/IgniteCliException.java (96%)
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/deprecated/CommandFactory.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/deprecated/Table.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/deprecated/package-info.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/deprecated/spec/NodeEndpointOptions.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/deprecated/spec/package-info.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/deprecated/ui/ProgressBar.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/deprecated/ui/Spinner.java
rename
modules/cli/src/{integrationTest/java/org/apache/ignite/internal/cli/deprecated/AbstractCliIntegrationTest.java
=> test/java/org/apache/ignite/internal/cli/AbstractCliTest.java} (54%)
rename modules/cli/src/test/java/org/apache/ignite/internal/cli/{deprecated =>
}/IgniteCliInterfaceTest.java (91%)
delete mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/deprecated/AbstractCliTest.java
delete mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/deprecated/package-info.java
delete mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/deprecated/ui/ProgressBarTest.java
delete mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/deprecated/ui/SpinnerTest.java
delete mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/deprecated/ui/package-info.java
copy
modules/core/src/main/java/org/apache/ignite/internal/util/{ReverseIterator.java
=> IteratorCursor.java} (68%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/CursorTest.java
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Linq/LinqTests.Aggregate.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Linq/LinqTests.GroupBy.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Linq/LinqTests.Join.cs
copy
modules/platforms/dotnet/{Apache.Ignite.Tests/Buffers/ByteArrayPoolTests.cs =>
Apache.Ignite/Internal/Common/StringBuilderExtensions.cs} (61%)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/service/CommittedConfiguration.java
copy
modules/{network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/InstantiationException.java
=>
raft-client/src/main/java/org/apache/ignite/raft/client/service/LeaderWithTerm.java}
(64%)
rename modules/raft/src/{test =>
testFixtures}/java/org/apache/ignite/raft/TestWriteCommand.java (100%)
copy
modules/raft/src/{main/java/org/apache/ignite/raft/jraft/rpc/ActionRequest.java
=> testFixtures/java/org/apache/ignite/raft/jraft/rpc/TestMessages.java} (60%)
rename modules/raft/src/{test =>
testFixtures}/java/org/apache/ignite/raft/messages/TestMessageGroup.java (100%)
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/RaftGroupConfiguration.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/PartitionMover.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{message/HasDataRequest.java
=> command/HybridTimestampMessage.java} (65%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{message/HasDataRequest.java
=> command/TablePartitionIdMessage.java} (66%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/PartitionMoverTest.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/PartitionSnapshotStorageTest.java
copy
modules/{network/src/test/java/org/apache/ignite/internal/network/serialization/BuiltInTypeTest.java
=>
table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/incoming/IncomingSnapshotReaderTest.java}
(70%)
create mode 100644 packaging/common/bootstrap-functions.sh
copy packaging/{cli/start.sh => common/setup-java.sh} (54%)
delete mode 100644 packaging/config/ignite.java.util.logging.properties
copy packaging/{linux/deb/postUninstall.sh => zip/ignite3db} (53%)
mode change 100644 => 100755
delete mode 100755 packaging/zip/ignite3db.sh
rename packaging/zip/{bootstrap-config.env => vars.env} (62%)
