This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-22270
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 67b49c1017 minor.
discard 689012bba3 minor.
discard ab7dfa3483 minor.
discard 244715eb45 revert changes
discard 2ef09151d5 Styles
discard 5420843415 minor.
discard 0fa01f82e1 Get rid of checked MarshallerException
discard 1ad64781d2 Get rid of TupleMarshallerException
discard 65f33cf369 Introduce CatalogMarshallerException for catalog
serialization issues.
add 9961bc8ba7 IGNITE-22480 Sql. Avoid compiling literal-only expressions
when assembling a row for insert (#3922)
add f7b371d89e IGNITE-22524 .NET: Add JobDescriptor to Compute API (#3954)
add 6f23b0d7c9 IGNITE-22537 Unnecessary calls toString() call for RAFT
command make latency longer (#3955)
add d7141dfebc IGNITE-22276 Add index columns validation for
TableDefinition (#3918)
add a5c06704c4 Bump org.openapi.generator from 7.5.0 to 7.6.0 (#3793)
add adf91949fc IGNITE-22421: Sql. Interval type. DDL statements should
return a proper error (#3936)
add 3d83c35107 IGNITE-22435 Add JobTarget interface (#3950)
add d736a8bc53 IGNITE-22545 Get rid of
PageMemoryProfileConfigurationSchema#memoryAllocator (#3958)
add 82ce4a3ab0 IGNITE-22213 Enable processing of client requests only
after all components have started (#3951)
add c8657b8992 IGNITE-22550 Get rid of
RocksDbProfileConfigurationSchema#numShardBits (#3960)
add 75400bbe28 IGNITE-22231 Implement zone based replicas start on the
zone creation (#3858)
add 1bd9e5dc2c Introduce CatalogMarshallerException for catalog
serialization issues.
add 0ab5bbf6d2 Get rid of TupleMarshallerException
add 6bb6d06c81 Get rid of checked MarshallerException
add 339e68f37e wip. revert this.
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 (67b49c1017)
\
N -- N -- N refs/heads/ignite-22270 (339e68f37e)
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:
.../config/storage/persistent.adoc | 1 -
.../config/storage/rocksdb.adoc | 1 -
.../config/storage/volatile.adoc | 1 -
docs/_docs/general-tips.adoc | 3 -
gradle/libs.versions.toml | 2 +-
.../catalog/definitions/TableDefinition.java | 8 +
.../apache/ignite/compute/AnyNodeJobTarget.java} | 31 +-
.../apache/ignite/compute/ColocatedJobTarget.java | 59 ++
.../org/apache/ignite/compute/IgniteCompute.java | 136 +---
.../java/org/apache/ignite/compute/JobTarget.java | 109 +++
.../apache/ignite/compute/task/MapReduceJob.java | 3 +-
.../apache/ignite/lang/MarshallerException.java | 2 +
.../catalog/sql/InvalidDefinitionTest.java | 26 +
.../commands/AlterTableAddColumnCommand.java | 1 +
.../internal/catalog/commands/CatalogUtils.java | 12 +
.../catalog/commands/CreateTableCommand.java | 2 +
.../ignite/internal/catalog/CatalogTableTest.java | 8 +-
...AlterTableAlterColumnCommandValidationTest.java | 64 +-
.../commands/CreateTableCommandValidationTest.java | 59 ++
.../apache/ignite/client/handler/TestServer.java | 1 +
.../ignite/client/handler/ClientHandlerModule.java | 13 +-
.../apache/ignite/client/ClientOperationType.java | 4 +-
.../internal/client/compute/ClientCompute.java | 112 ++-
.../apache/ignite/client/AbstractClientTest.java | 9 +-
.../apache/ignite/client/ClientComputeTest.java | 24 +-
.../org/apache/ignite/client/ConnectionTest.java | 69 ++
.../client/ObservableTimestampPropagationTest.java | 2 +-
.../ignite/client/PartitionAwarenessTest.java | 9 +-
.../java/org/apache/ignite/client/TestServer.java | 22 +-
.../apache/ignite/client/fakes/FakeCompute.java | 63 +-
.../ignite/internal/compute/ItComputeBaseTest.java | 64 +-
.../internal/compute/ItComputeErrorsBaseTest.java | 8 +-
.../internal/compute/ItComputeTestEmbedded.java | 36 +-
.../internal/compute/ItComputeTestStandalone.java | 14 +-
.../internal/compute/ItExecutionsCleanerTest.java | 4 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 4 +-
.../internal/compute/ItWorkerShutdownTest.java | 10 +-
.../threading/ItComputeApiThreadingTest.java | 28 +-
.../internal/compute/AntiHijackIgniteCompute.java | 53 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 124 ++--
.../internal/compute/IgniteComputeImplTest.java | 21 +-
.../internal/replicator/ZonePartitionId.java | 122 ++++
.../distributionzones/rebalance/RebalanceUtil.java | 62 ++
modules/index/build.gradle | 2 +
.../internal/index/ItBuildIndexOneNodeTest.java | 2 +-
.../ignite/internal/index/ItBuildIndexTest.java | 2 +-
.../index/ItDropIndexMultipleNodesTest.java | 2 +-
.../index/ItRwTransactionAndIndexesTest.java | 2 +-
.../ignite/internal/index/IndexBuildTask.java | 9 +-
.../apache/ignite/internal/index/IndexBuilder.java | 4 +-
.../ignite/internal/index/IndexBuilderTest.java | 2 +-
.../PageMemoryLocalConfigurationModule.java | 7 +-
...istentPageMemoryProfileConfigurationSchema.java | 4 -
.../UnsafeMemoryAllocatorConfigurationSchema.java | 30 -
...latilePageMemoryProfileConfigurationSchema.java | 5 -
.../pagememory/inmemory/VolatilePageMemory.java | 5 -
.../persistence/PersistentPageMemory.java | 5 -
.../{index => partition-replicator}/build.gradle | 87 ++-
.../replicator/ItReplicaLifecycleTest.java | 808 +++++++++++++++++++++
.../replicator/utils/TestPlacementDriver.java | 94 +++
.../PartitionReplicaLifecycleManager.java | 424 +++++++++++
.../replicator/ZonePartitionRaftListener.java | 57 ++
.../replicator/ZonePartitionReplicaListener.java | 47 ++
.../marshaller/PartitionCommandsMarshaller.java} | 26 +-
.../PartitionCommandsMarshallerImpl.java | 4 +-
.../ThreadLocalPartitionCommandsMarshaller.java | 58 ++
.../network/PartitionReplicationMessageGroup.java} | 83 ++-
.../replicator/network}/TimedBinaryRow.java | 4 +-
.../network}/command/BuildIndexCommand.java | 6 +-
.../network}/command/CatalogVersionAware.java | 4 +-
.../network}/command/FinishTxCommand.java | 6 +-
.../network}/command/PartitionCommand.java | 2 +-
.../network}/command/TablePartitionIdMessage.java | 4 +-
.../network}/command/TimedBinaryRowMessage.java | 8 +-
.../network}/command/UpdateAllCommand.java | 8 +-
.../replicator/network}/command/UpdateCommand.java | 6 +-
.../network}/command/WriteIntentSwitchCommand.java | 6 +-
.../network}/disaster/LocalPartitionStateEnum.java | 4 +-
.../disaster}/LocalPartitionStateMessage.java | 7 +-
.../disaster}/LocalPartitionStatesRequest.java | 4 +-
.../disaster}/LocalPartitionStatesResponse.java | 4 +-
.../replicator/network}/message/DataPresence.java | 2 +-
.../network}/message/HasDataRequest.java | 6 +-
.../network}/message/HasDataResponse.java | 6 +-
.../network/raft}/SnapshotMetaRequest.java | 6 +-
.../network/raft}/SnapshotMetaResponse.java | 6 +-
.../network/raft}/SnapshotMvDataRequest.java | 6 +-
.../network/raft}/SnapshotMvDataResponse.java | 13 +-
.../network/raft}/SnapshotRequestMessage.java | 2 +-
.../network/raft}/SnapshotTxDataRequest.java | 6 +-
.../network/raft}/SnapshotTxDataResponse.java | 6 +-
.../network/replication}/BinaryRowMessage.java | 6 +-
.../network/replication}/BinaryTupleMessage.java | 6 +-
.../replication}/BuildIndexReplicaRequest.java | 6 +-
.../replication}/MultipleRowPkReplicaRequest.java | 3 +-
.../replication}/MultipleRowReplicaRequest.java | 3 +-
.../ReadOnlyDirectMultiRowReplicaRequest.java | 6 +-
.../ReadOnlyDirectSingleRowReplicaRequest.java | 6 +-
.../ReadOnlyMultiRowPkReplicaRequest.java | 6 +-
.../replication}/ReadOnlyReplicaRequest.java | 2 +-
.../ReadOnlyScanRetrieveBatchReplicaRequest.java | 6 +-
.../ReadOnlySingleRowPkReplicaRequest.java | 6 +-
.../ReadWriteMultiRowPkReplicaRequest.java | 6 +-
.../ReadWriteMultiRowReplicaRequest.java | 6 +-
.../replication}/ReadWriteReplicaRequest.java | 4 +-
.../ReadWriteScanRetrieveBatchReplicaRequest.java | 6 +-
.../ReadWriteSingleRowPkReplicaRequest.java | 6 +-
.../ReadWriteSingleRowReplicaRequest.java | 6 +-
.../ReadWriteSwapRowReplicaRequest.java | 6 +-
.../network/replication}/RequestType.java | 2 +-
.../replication}/ScanCloseReplicaRequest.java | 6 +-
.../ScanRetrieveBatchReplicaRequest.java | 2 +-
.../replication}/SingleRowPkReplicaRequest.java | 3 +-
.../replication}/SingleRowReplicaRequest.java | 3 +-
.../replication}/SwapRowReplicaRequest.java | 3 +-
.../snapshot/FailFastSnapshotStorageFactory.java | 84 +++
.../Apache.Ignite.Tests/BasicAuthenticatorTests.cs | 4 +-
.../Compute/ComputeClusterAwarenessTests.cs | 11 +-
.../Compute/ComputeTestExtensions.cs | 65 --
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 127 ++--
.../PartitionAwarenessRealClusterTests.cs | 4 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 9 +-
.../Proto/ColocationHashTests.cs | 7 +-
.../Table/SchemaSynchronizationTest.cs | 7 +-
.../dotnet/Apache.Ignite/Compute/ICompute.cs | 32 +-
.../dotnet/Apache.Ignite/Compute/JobDescriptor.cs} | 23 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 93 ++-
.../datareplication/ReplicaLifecycleManager.java | 58 --
.../apache/ignite/internal/replicator/Replica.java | 275 +------
.../replicator/{Replica.java => ReplicaImpl.java} | 31 +-
.../ignite/internal/replicator/ReplicaManager.java | 151 +++-
.../replicator/ZonePartitionReplicaImpl.java | 70 ++
.../replicator/PlacementDriverReplicaSideTest.java | 2 +-
modules/rest/build.gradle | 1 +
.../rest/compute/ItComputeControllerTest.java | 3 +-
modules/runner/build.gradle | 3 +-
.../runner/app/ItIgniteNodeRestartTest.java | 4 +-
.../runner/app/client/ItThinClientComputeTest.java | 110 +--
.../client/ItThinClientPartitionAwarenessTest.java | 5 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 22 +-
modules/sql-engine/build.gradle | 1 +
.../internal/sql/engine/ItCreateTableDdlTest.java | 30 +
.../internal/sql/engine/exec/ExchangeService.java | 2 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 2 +-
.../sql/engine/exec/UpdatableTableImpl.java | 10 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 62 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 2 +-
.../internal/sql/engine/exec/rel/Outbox.java | 6 +-
.../sql/engine/message/QueryBatchMessage.java | 2 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 13 +
.../engine/exec/exp/ExpressionFactoryImplTest.java | 93 ++-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 67 ++
.../pruning/PartitionPruningPredicateSelfTest.java | 80 +-
.../internal/sql/engine/util/SqlTestUtils.java | 76 ++
...yStorageEngineLocalConfigurationModuleTest.java | 7 +-
.../storage/rocksdb/RocksDbStorageProfile.java | 2 +-
.../schema/RocksDbProfileConfigurationSchema.java | 5 -
modules/table/build.gradle | 4 +-
.../ItInternalTableReadOnlyOperationsTest.java | 4 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 14 +-
.../disaster/ItDisasterRecoverySystemViewTest.java | 2 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 2 +-
.../rebalance/ItRebalanceDistributedTest.java | 11 +-
.../ignite/internal/table/ItColocationTest.java | 16 +-
.../table/ItTransactionPrimaryChangeTest.java | 2 +-
.../internal/table/ItTransactionRecoveryTest.java | 2 +-
.../ignite/internal/table/RecordViewImpl.java | 70 +-
.../PartitionReplicatorNodeRecovery.java | 12 +-
.../table/distributed/StorageUpdateHandler.java | 2 +-
.../disaster/DisasterRecoveryManager.java | 19 +-
.../distributed/disaster/LocalPartitionState.java | 2 +
.../LocalPartitionStateEnumWithLogIndex.java | 7 +-
.../disaster/LocalPartitionStateMessageByNode.java | 2 +-
.../disaster/PartitionStatesMetricSource.java | 11 +-
.../table/distributed/raft/PartitionListener.java | 16 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 16 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 20 +-
.../outgoing/OutgoingSnapshotsManager.java | 18 +-
.../replicator/PartitionReplicaListener.java | 59 +-
.../distributed/replicator/ReplicatorUtils.java | 2 +-
.../schema/PartitionCommandsMarshallerImpl.java | 2 +-
.../distributed/storage/InternalTableImpl.java | 40 +-
.../internal/table/distributed/IndexBaseTest.java | 7 +-
.../table/distributed/StorageCleanupTest.java | 2 +-
.../distributed/StorageUpdateHandlerTest.java | 2 +-
.../distributed/TableManagerRecoveryTest.java | 3 +-
.../PartitionRaftCommandsSerializationTest.java | 16 +-
.../raft/PartitionCommandListenerTest.java | 20 +-
.../incoming/IncomingSnapshotCopierTest.java | 16 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 8 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 8 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 8 +-
.../PartitionReplicaListenerIndexLockingTest.java | 8 +-
.../replication/PartitionReplicaListenerTest.java | 42 +-
.../replicator/ReplicatorUtilsTest.java | 2 +-
.../replicator/action/RequestTypeTest.java | 13 +-
.../CheckCatalogVersionOnActionRequestTest.java | 4 +-
.../PartitionCommandsMarshallerImplTest.java | 14 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../replicator/action/RequestTypes.java | 2 +-
.../ignite/internal/table/TxAbstractTest.java | 3 +-
modules/workers/build.gradle | 1 +
.../worker/ItCriticalWorkerMonitoringTest.java | 10 +-
settings.gradle | 4 +-
204 files changed, 3798 insertions(+), 1837 deletions(-)
rename
modules/{page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/MemoryAllocatorConfigurationSchema.java
=> api/src/main/java/org/apache/ignite/compute/AnyNodeJobTarget.java} (57%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/ColocatedJobTarget.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/JobTarget.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/replicator/ZonePartitionId.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/UnsafeMemoryAllocatorConfigurationSchema.java
copy modules/{index => partition-replicator}/build.gradle (63%)
create mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItReplicaLifecycleTest.java
create mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/utils/TestPlacementDriver.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/PartitionReplicaLifecycleManager.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/ZonePartitionRaftListener.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/ZonePartitionReplicaListener.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/message/HasDataResponse.java
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/marshaller/PartitionCommandsMarshaller.java}
(53%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/schema
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/marshaller}/PartitionCommandsMarshallerImpl.java
(93%)
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/marshaller/ThreadLocalPartitionCommandsMarshaller.java
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/TableMessageGroup.java
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/PartitionReplicationMessageGroup.java}
(56%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/TimedBinaryRow.java
(92%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/BuildIndexCommand.java
(89%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/CatalogVersionAware.java
(88%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/FinishTxCommand.java
(87%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/PartitionCommand.java
(95%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/TablePartitionIdMessage.java
(88%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/TimedBinaryRowMessage.java
(83%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/UpdateAllCommand.java
(87%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/UpdateCommand.java
(90%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/WriteIntentSwitchCommand.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/disaster/LocalPartitionStateEnum.java
(93%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster}/LocalPartitionStateMessage.java
(81%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster}/LocalPartitionStatesRequest.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster}/LocalPartitionStatesResponse.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/message/DataPresence.java
(94%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/message/HasDataRequest.java
(83%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/message/HasDataResponse.java
(84%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotMetaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotMetaResponse.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotMvDataRequest.java
(84%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotMvDataResponse.java
(81%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotRequestMessage.java
(93%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotTxDataRequest.java
(83%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotTxDataResponse.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/BinaryRowMessage.java
(84%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/BinaryTupleMessage.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/BuildIndexReplicaRequest.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/MultipleRowPkReplicaRequest.java
(88%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/MultipleRowReplicaRequest.java
(91%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyDirectMultiRowReplicaRequest.java
(81%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyDirectSingleRowReplicaRequest.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyMultiRowPkReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyReplicaRequest.java
(93%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyScanRetrieveBatchReplicaRequest.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlySingleRowPkReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteMultiRowPkReplicaRequest.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteMultiRowReplicaRequest.java
(85%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteReplicaRequest.java
(89%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteScanRetrieveBatchReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteSingleRowPkReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteSingleRowReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteSwapRowReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/action
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/RequestType.java
(96%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ScanCloseReplicaRequest.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ScanRetrieveBatchReplicaRequest.java
(97%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/SingleRowPkReplicaRequest.java
(88%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/SingleRowReplicaRequest.java
(90%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/SwapRowReplicaRequest.java
(90%)
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/snapshot/FailFastSnapshotStorageFactory.java
delete mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Compute/ComputeTestExtensions.cs
rename modules/{replica-lifecycle/build.gradle =>
platforms/dotnet/Apache.Ignite/Compute/JobDescriptor.cs} (63%)
delete mode 100644
modules/replica-lifecycle/src/main/java/org/apache/ignite/internal/datareplication/ReplicaLifecycleManager.java
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/{Replica.java
=> ReplicaImpl.java} (95%)
create mode 100644
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ZonePartitionReplicaImpl.java
