This is an automated email from the ASF dual-hosted git repository.
mpochatkin pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 4d95d1501d IGNITE-24017 Sql. StorageScanNode SubscriberImpl onNext can
be called after subscription is cancelled (#5031)
add 917571344a IGNITE-23601 Add broadcast partitioned compute method
(#5056)
No new revisions were added by this update.
Summary of changes:
.../apache/ignite/compute/BroadcastJobTarget.java | 11 ++
.../apache/ignite/compute/JobExecutionContext.java | 10 ++
.../org/apache/ignite/compute/TableJobTarget.java} | 20 ++--
.../internal/client/compute/ClientCompute.java | 1 +
.../apache/ignite/client/fakes/FakeCompute.java | 2 +-
modules/compute/jobs.gradle | 1 +
.../ignite/internal/compute/ItComputeBaseTest.java | 36 +++++++
.../ignite/internal/compute/GetPartitionJob.java} | 9 +-
.../ignite/internal/compute/ExecutionOptions.java | 25 ++++-
.../ignite/internal/compute/IgniteComputeImpl.java | 111 +++++++++++++++------
.../internal/compute/JobExecutionContextImpl.java | 14 ++-
.../compute/executor/ComputeExecutorImpl.java | 2 +-
.../compute/JobExecutionContextImplTest.java | 4 +-
13 files changed, 191 insertions(+), 55 deletions(-)
copy
modules/{catalog-dsl/src/main/java/org/apache/ignite/internal/catalog/sql/TableZoneId.java
=> api/src/main/java/org/apache/ignite/compute/TableJobTarget.java} (70%)
copy
modules/compute/src/{unit1/java/org/apache/ignite/internal/compute/UnitJob.java
=> jobs/java/org/apache/ignite/internal/compute/GetPartitionJob.java} (76%)
