This is an automated email from the ASF dual-hosted git repository.
anovikov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 2bf1e14b392 IGNITE-27311 Fix client KeyValueView DataStreamer column
order mixup (#7205)
add 97c064c39c0 IGNITE-27012 Improve partition API (#7091)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/ignite/table/Table.java | 9 ++
.../apache/ignite/table/partition/Partition.java | 9 +-
.../table/partition/PartitionDistribution.java | 137 +++++++++++++++++++++
.../ignite/table/partition/PartitionManager.java | 49 +-------
...ClientStreamerWithReceiverBatchSendRequest.java | 2 +-
...blePartitionPrimaryReplicasNodesGetRequest.java | 7 +-
.../apache/ignite/client/ClientOperationType.java | 4 +-
.../internal/client/compute/ClientCompute.java | 9 +-
.../client/table/ClientPartitionManager.java | 73 ++++++++++-
.../ignite/internal/client/table/ClientTable.java | 6 +
...t.java => ClientPartitionDistributionTest.java} | 16 +--
.../ignite/internal/compute/ItComputeBaseTest.java | 31 +++--
.../internal/compute/utils/InteractiveJobs.java | 3 +-
.../ignite/internal/compute/GetPartitionJob.java | 7 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 2 +-
.../compute/PartitionNextWorkerSelector.java | 3 +-
.../internal/table/partition/HashPartition.java | 3 +-
.../ignite/internal/app/AsyncApiOperation.java | 10 ++
.../org/apache/ignite/internal/app/References.java | 3 +
.../ignite/internal/app/SyncApiOperation.java | 16 +++
.../runner/app/PlatformTestNodeRunner.java | 5 +-
.../app/client/ItThinClientTransactionsTest.java | 50 ++++----
...ClientTransactionsWithBrokenReplicatorTest.java | 13 +-
.../ItThinClientTransactionsWithReplicasTest.java | 4 +-
.../streamer/ItAbstractDataStreamerTest.java | 4 +-
...va => ItAbstractPartitionDistributionTest.java} | 62 ++++++++--
... => ItStandalonePartitionDistributionTest.java} | 8 +-
... => ItThinClientPartitionDistributionTest.java} | 8 +-
.../restart/RestartProofPartitionManager.java | 52 +++++++-
.../ignite/internal/restart/RestartProofTable.java | 8 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 21 ++--
...> ItPartitionDistributionApiThreadingTest.java} | 42 ++++---
.../apache/ignite/internal/table/TableImpl.java | 6 +
.../table/distributed/PublicApiThreadingTable.java | 6 +
.../table/partition/HashPartitionManagerImpl.java | 84 +++++++++++--
.../PublicApiThreadingPartitionManager.java | 58 +++++++--
.../readonly/ItReadOnlyTxAndLowWatermarkTest.java | 12 +-
37 files changed, 631 insertions(+), 211 deletions(-)
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/partition/PartitionDistribution.java
rename
modules/client/src/test/java/org/apache/ignite/client/{ClientPartitionManagerTest.java
=> ClientPartitionDistributionTest.java} (82%)
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/partition/{ItAbstractPartitionManagerTest.java
=> ItAbstractPartitionDistributionTest.java} (66%)
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/partition/{ItStandalonePartitionManagerTest.java
=> ItStandalonePartitionDistributionTest.java} (80%)
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/partition/{ItThinClientPartitionManagerTest.java
=> ItThinClientPartitionDistributionTest.java} (81%)
rename
modules/table/src/integrationTest/java/org/apache/ignite/internal/threading/{ItPartitionManagerApiThreadingTest.java
=> ItPartitionDistributionApiThreadingTest.java} (70%)
