This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-17748
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard e0a972c36e WIP. Fix incorrect dependencies.
discard 7b23007a43 WIP.
add 0e3c7e63f2 IGNITE-17887 CMG RAFT commands converted to Transferable
classes (#1204)
add 8160ef31ec IGNITE-17905 Move Rest, Compute and Client configuration
schemas (#1211)
add dc248cf61d IGNITE-17907 Extract Table configuration (#1215)
add 5ff6f1ecb9 IGNITE-16226 .NET: Add KeyValueBinaryView (#1212)
add 9cf08c7a97 WIP.
add ae4b98e278 WIP. Fix incorrect dependencies.
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 (e0a972c36e)
\
N -- N -- N refs/heads/ignite-17748 (ae4b98e278)
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:
modules/client-handler/build.gradle | 3 +-
modules/client-handler/pom.xml | 23 ++
.../ignite/client/handler/ItClientHandlerTest.java | 2 +-
.../ignite/client/handler/ClientHandlerModule.java | 2 +-
.../handler/ClientInboundMessageHandler.java | 2 +-
.../ClientConnectorConfigurationSchema.java | 2 +-
.../ClientHandlerConfigurationModule.java | 1 -
.../handler/configuration}/package-info.java | 2 +-
.../ignite/client/TestClientHandlerModule.java | 2 +-
.../java/org/apache/ignite/client/TestServer.java | 2 +-
.../management/raft/ItCmgRaftServiceTest.java | 67 +++--
.../management/ClusterManagementGroupManager.java | 8 +-
.../internal/cluster/management/ClusterState.java | 106 ++++----
.../internal/cluster/management/ClusterTag.java | 61 ++---
.../network/messages/ClusterStateMessage.java | 2 -
.../network/messages/CmgMessageGroup.java | 59 +++++
.../management/raft/CmgRaftGroupListener.java | 14 +-
.../cluster/management/raft/CmgRaftService.java | 44 +++-
...inReadyCommand.java => ClusterNodeMessage.java} | 35 ++-
.../raft/commands/InitCmgStateCommand.java | 34 +--
.../management/raft/commands/JoinReadyCommand.java | 24 +-
.../raft/commands/JoinRequestCommand.java | 49 +---
.../raft/commands/NodesLeaveCommand.java | 26 +-
.../raft/commands/ReadLogicalTopologyCommand.java | 6 +-
.../management/raft/commands/ReadStateCommand.java | 6 +-
.../AbstractClusterStateStorageManagerTest.java | 28 +-
.../management/raft/CmgRaftGroupListenerTest.java | 31 ++-
modules/compute/build.gradle | 1 +
modules/compute/pom.xml | 10 +
.../internal/compute/ComputeComponentImpl.java | 2 +-
.../configuration/ComputeConfigurationModule.java | 1 -
.../configuration}/ComputeConfigurationSchema.java | 2 +-
.../internal/compute/ComputeComponentImplTest.java | 2 +-
modules/extended-api/build.gradle | 28 --
modules/extended-api/pom.xml | 72 -----
modules/index/build.gradle | 1 -
.../apache/ignite/internal/index/IndexManager.java | 22 +-
.../configuration/IndexConfigurationModule.java | 4 +-
.../ignite/internal/index/IndexManagerTest.java | 34 +--
.../internal/network/processor/MessageClass.java | 2 +
.../serialization/BaseMethodNameResolver.java | 3 +
.../serialization/MessageReaderMethodResolver.java | 18 ++
.../serialization/MessageWriterMethodResolver.java | 20 ++
.../network/serialization/MessageReader.java | 21 +-
.../network/serialization/MessageWriter.java | 16 +-
.../network/direct/DirectMessageReader.java | 13 +
.../network/direct/DirectMessageWriter.java | 11 +
.../direct/stream/DirectByteBufferStream.java | 21 ++
.../stream/DirectByteBufferStreamImplV1.java | 40 ++-
.../internal/network/AllTypesMessageGenerator.java | 5 +
.../internal/network/messages/AllTypesMessage.java | 3 +
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 9 +-
.../dotnet/Apache.Ignite.Tests/OptionTests.cs | 4 +-
.../Table/KeyValueViewBinaryTests.cs | 291 +++++++++++++++++++++
.../Table/RecordViewBinaryTests.cs | 2 +-
.../Table/RecordViewDefaultMappingTest.cs | 3 +-
.../Table/RecordViewPrimitiveTests.cs | 4 +-
.../dotnet/Apache.Ignite/ClientOperationType.cs | 5 +
.../dotnet/Apache.Ignite/Compute/ICompute.cs | 3 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 4 +-
.../Apache.Ignite/Internal/Proto/ClientOp.cs | 3 +
.../Internal/Proto/ClientOpExtensions.cs | 1 +
.../Apache.Ignite/Internal/Table/KeyValueView.cs | 166 ++++++++++++
.../Apache.Ignite/Internal/Table/RecordView.cs | 141 +++++++---
.../dotnet/Apache.Ignite/Internal/Table/Schema.cs | 8 +-
.../Internal/Table/Serialization/KvPair.cs} | 25 +-
.../Table/Serialization/ObjectSerializerHandler.cs | 2 +-
.../Table/Serialization/RecordSerializer.cs | 40 ++-
.../Serialization/TuplePairSerializerHandler.cs | 114 ++++++++
.../Table/Serialization/TupleSerializerHandler.cs | 2 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 16 +-
modules/platforms/dotnet/Apache.Ignite/Option.cs | 21 +-
.../dotnet/Apache.Ignite/RetryReadPolicy.cs | 1 +
.../dotnet/Apache.Ignite/Table/IKeyValueView.cs | 203 ++++++++++++++
.../dotnet/Apache.Ignite/Table/IRecordView.cs | 9 +-
.../platforms/dotnet/Apache.Ignite/Table/ITable.cs | 8 +-
.../internal/raft/CoreLogStorageBudgetsModule.java | 15 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 2 +-
.../EntryCountBudgetConfigurationSchema.java | 2 +-
.../LogStorageBudgetConfigurationSchema.java | 2 +-
.../configuration/RaftConfigurationModule.java | 2 -
.../configuration/RaftConfigurationSchema.java | 1 -
.../UnlimitedBudgetConfigurationSchema.java | 2 +-
.../VolatileRaftConfigurationSchema.java | 2 +-
.../storage/impl/LogStorageFactoryCreator.java | 2 +-
.../storage/impl/VolatileLogStorageFactory.java | 2 +-
.../impl/VolatileLogStorageFactoryCreator.java | 2 +-
.../raft/jraft/core/LogStorageBudgetFactory.java | 2 +-
.../raft/CoreLogStorageBudgetsModuleTest.java | 6 +-
.../apache/ignite/internal/rest/RestComponent.java | 4 +-
.../configuration/RestConfigurationModule.java | 1 -
.../configuration}/RestConfigurationSchema.java | 2 +-
.../internal/rest/configuration}/package-info.java | 2 +-
modules/runner/build.gradle | 1 -
.../storage/ItRebalanceDistributedTest.java | 20 +-
.../ignite/internal/index/ItIndexManagerTest.java | 2 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 2 +-
.../runner/app/AbstractSchemaChangeTest.java | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 2 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 8 +-
modules/schema/build.gradle | 2 +-
modules/schema/pom.xml | 5 -
.../ignite/internal/schema/SchemaManager.java | 8 +-
.../apache/ignite/internal/schema/SchemaUtils.java | 4 +-
.../configuration}/ColumnConfigurationSchema.java | 3 +-
.../ColumnTypeConfigurationSchema.java | 2 +-
.../schema/configuration}/ColumnTypeValidator.java | 2 +-
.../configuration/ColumnTypeValidatorImpl.java | 3 -
.../ConfigurationToSchemaDescriptorConverter.java | 11 +-
.../ExtendedTableConfigurationSchema.java | 3 +-
.../PrimaryKeyConfigurationSchema.java | 2 +-
.../configuration}/SchemaConfigurationSchema.java | 2 +-
.../SchemaDistributedConfigurationModule.java | 17 +-
.../configuration}/TableConfigurationSchema.java | 6 +-
.../schema/configuration}/TableValidator.java | 2 +-
.../schema/configuration/TableValidatorImpl.java | 2 -
.../configuration}/TablesConfigurationSchema.java | 6 +-
.../ColumnDefaultConfigurationSchema.java | 2 +-
.../ConstantValueDefaultConfigurationSchema.java | 4 +-
.../FunctionCallDefaultConfigurationSchema.java | 4 +-
.../NullValueDefaultConfigurationSchema.java | 4 +-
.../index}/HashIndexConfigurationSchema.java | 4 +-
.../index}/IndexColumnConfigurationSchema.java | 2 +-
.../configuration/index}/IndexValidator.java | 3 +-
.../{ => index}/IndexValidatorImpl.java | 12 +-
.../index}/SortedIndexConfigurationSchema.java | 4 +-
.../index}/TableIndexConfigurationSchema.java | 2 +-
.../schema/configuration}/package-info.java | 2 +-
.../storage}/DataStorageConfigurationSchema.java | 2 +-
.../storage}/ExistingDataStorage.java | 2 +-
.../configuration/storage}/KnownDataStorage.java | 2 +-
.../{ => storage}/KnownDataStorageValidator.java | 6 +-
.../UnknownDataStorageConfigurationSchema.java | 4 +-
.../AbstractTableIndexValidatorTest.java | 5 +-
...nfigurationToSchemaDescriptorConverterTest.java | 13 +-
.../KnownDataStorageValidatorTest.java | 7 +-
.../SchemaDistributedConfigurationModuleTest.java | 8 +-
.../configuration/TableValidatorImplTest.java | 2 -
.../schema/TestDataStorageConfigurationSchema.java | 2 +-
.../testutils/SchemaConfigurationConverter.java | 48 ++--
modules/sql-engine/build.gradle | 1 -
.../sql/engine/exec/ddl/DdlCommandHandler.java | 22 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 2 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 4 +-
.../sql/engine/exec/MockedStructuresTest.java | 41 +--
.../internal/storage/DataStorageManager.java | 16 +-
.../ignite/internal/storage/DataStorageModule.java | 2 +-
.../internal/storage/DataStorageModules.java | 6 +-
.../ExistingDataStorageValidator.java | 4 +-
...torageEngineDistributedConfigurationModule.java | 2 +-
.../internal/storage/engine/MvTableStorage.java | 10 +-
.../internal/storage/engine/StorageEngine.java | 4 +-
.../internal/storage/engine/TableStorage.java | 2 +-
.../storage/index/HashIndexDescriptor.java | 10 +-
.../storage/index/SortedIndexDescriptor.java | 12 +-
.../internal/storage/DataStorageManagerTest.java | 12 +-
.../internal/storage/DataStorageModulesTest.java | 6 +-
.../internal/storage/TestMvTableStorageTest.java | 2 +-
.../ExistingDataStorageValidatorTest.java | 4 +-
.../storage/index/TestHashIndexStorageTest.java | 4 +-
.../storage/index/TestSortedIndexStorageTest.java | 4 +-
.../storage/AbstractMvTableStorageTest.java | 6 +-
.../internal/storage/impl/TestMvTableStorage.java | 4 +-
.../internal/storage/impl/TestStorageEngine.java | 4 +-
...torageEngineDistributedConfigurationModule.java | 2 +
.../schema/TestDataStorageConfigurationSchema.java | 2 +-
.../index/AbstractHashIndexStorageTest.java | 6 +-
.../index/AbstractSortedIndexStorageTest.java | 6 +-
.../pagememory/AbstractPageMemoryTableStorage.java | 6 +-
.../PersistentPageMemoryStorageEngine.java | 4 +-
.../PersistentPageMemoryTableStorage.java | 6 +-
.../VolatilePageMemoryStorageEngine.java | 4 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 6 +-
...ntPageMemoryDataStorageConfigurationSchema.java | 2 +-
...lePageMemoryDataStorageConfigurationSchema.java | 2 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 8 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 2 +-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 2 +-
.../PersistentPageMemoryMvTableStorageTest.java | 2 +-
.../VolatilePageMemoryMvTableStorageTest.java | 2 +-
.../AbstractPageMemoryHashIndexStorageTest.java | 2 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 2 +-
...PersistentPageMemorySortedIndexStorageTest.java | 2 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 2 +-
.../VolatilePageMemorySortedIndexStorageTest.java | 2 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 2 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 2 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 2 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 4 +-
.../storage/rocksdb/RocksDbTableStorage.java | 6 +-
.../RocksDbDataStorageConfigurationSchema.java | 2 +-
.../rocksdb/RocksDbMvPartitionStorageTest.java | 4 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 2 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 2 +-
.../rocksdb/index/RocksDbHashIndexStorageTest.java | 2 +-
.../index/RocksDbSortedIndexStorageTest.java | 2 +-
modules/table/build.gradle | 1 -
.../TableDistributedConfigurationModule.java | 2 +-
.../internal/table/distributed/TableManager.java | 14 +-
.../raft/RebalanceRaftGroupEventsListener.java | 4 +-
.../TableDistributedConfigurationModuleTest.java | 2 +-
.../table/distributed/TableManagerTest.java | 11 +-
modules/transactions/build.gradle | 2 +
modules/transactions/pom.xml | 5 +
.../tx/storage/state/TxStateTableStorage.java | 2 +-
.../state/rocksdb/TxStateRocksDbTableStorage.java | 2 +-
.../state/rocksdb/TxStateRocksDbStorageTest.java | 4 +-
.../TestConcurrentHashMapTxStateTableStorage.java | 2 +-
parent/pom.xml | 6 -
pom.xml | 1 -
settings.gradle | 2 -
211 files changed, 1846 insertions(+), 892 deletions(-)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/clientconnector
=>
client-handler/src/main/java/org/apache/ignite/client/handler/configuration}/ClientConnectorConfigurationSchema.java
(96%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/clientconnector
=>
client-handler/src/main/java/org/apache/ignite/client/handler/configuration}/package-info.java
(93%)
copy
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/raft/commands/{JoinReadyCommand.java
=> ClusterNodeMessage.java} (59%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/compute =>
compute/src/main/java/org/apache/ignite/internal/compute/configuration}/ComputeConfigurationSchema.java
(96%)
delete mode 100644 modules/extended-api/build.gradle
delete mode 100644 modules/extended-api/pom.xml
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/KeyValueViewBinaryTests.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Table/KeyValueView.cs
copy
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/store/UnknownDataStorageConfigurationSchema.java
=> platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/KvPair.cs} (57%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/TuplePairSerializerHandler.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Table/IKeyValueView.cs
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
raft/src/main/java/org/apache/ignite/internal/raft/configuration}/EntryCountBudgetConfigurationSchema.java
(96%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
raft/src/main/java/org/apache/ignite/internal/raft/configuration}/LogStorageBudgetConfigurationSchema.java
(95%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
raft/src/main/java/org/apache/ignite/internal/raft/configuration}/UnlimitedBudgetConfigurationSchema.java
(95%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
raft/src/main/java/org/apache/ignite/internal/raft/configuration}/VolatileRaftConfigurationSchema.java
(95%)
rename modules/{api/src/main/java/org/apache/ignite/configuration/schemas/rest
=>
rest/src/main/java/org/apache/ignite/internal/rest/configuration}/RestConfigurationSchema.java
(96%)
rename modules/{api/src/main/java/org/apache/ignite/configuration/schemas/rest
=>
rest/src/main/java/org/apache/ignite/internal/rest/configuration}/package-info.java
(93%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/ColumnConfigurationSchema.java
(91%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/ColumnTypeConfigurationSchema.java
(96%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/ColumnTypeValidator.java
(95%)
rename
modules/{extended-api/src/main/java/org/apache/ignite/internal/configuration/schema
=>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/ExtendedTableConfigurationSchema.java
(93%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/PrimaryKeyConfigurationSchema.java
(95%)
rename
modules/{extended-api/src/main/java/org/apache/ignite/internal/configuration/schema
=>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/SchemaConfigurationSchema.java
(95%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/TableConfigurationSchema.java
(90%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/TableValidator.java
(95%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/TablesConfigurationSchema.java
(86%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/defaultvalue}/ColumnDefaultConfigurationSchema.java
(95%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/defaultvalue}/ConstantValueDefaultConfigurationSchema.java
(86%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/defaultvalue}/FunctionCallDefaultConfigurationSchema.java
(86%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/defaultvalue}/NullValueDefaultConfigurationSchema.java
(84%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/index}/HashIndexConfigurationSchema.java
(87%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/index}/IndexColumnConfigurationSchema.java
(95%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/index}/IndexValidator.java
(90%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/configuration/{
=> index}/IndexValidatorImpl.java (90%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/index}/SortedIndexConfigurationSchema.java
(87%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/index}/TableIndexConfigurationSchema.java
(96%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration}/package-info.java
(93%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/store =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage}/DataStorageConfigurationSchema.java
(94%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/store =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage}/ExistingDataStorage.java
(95%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/store =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage}/KnownDataStorage.java
(95%)
rename
modules/schema/src/main/java/org/apache/ignite/internal/schema/configuration/{
=> storage}/KnownDataStorageValidator.java (84%)
rename
modules/{api/src/main/java/org/apache/ignite/configuration/schemas/store =>
schema/src/main/java/org/apache/ignite/internal/schema/configuration/storage}/UnknownDataStorageConfigurationSchema.java
(85%)
