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 e034ed0e9b Bump com.netflix.nebula.ospackage from 11.8.1 to 11.9.0
(#3682)
add cb34325ecc IGNITE-22064 General MapReduce API (#3665)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/ignite/compute/ComputeJob.java | 5 +-
.../org/apache/ignite/compute/IgniteCompute.java | 61 ++++-
.../apache/ignite/compute/JobExecutionContext.java | 5 +
.../org/apache/ignite/compute/TaskExecution.java | 51 ++++
.../ignite/compute/task/ComputeJobRunner.java | 215 +++++++++++++++
.../apache/ignite/compute/task/MapReduceTask.java | 50 ++++
.../ignite/compute/task/TaskExecutionContext.java} | 15 +-
.../internal/client/compute/ClientCompute.java | 38 +--
.../client/compute/task/ClientTaskExecution.java} | 34 ++-
.../apache/ignite/client/fakes/FakeCompute.java | 37 +--
.../ignite/internal/compute/ItComputeBaseTest.java | 44 +++
.../internal/compute/ItComputeTestEmbedded.java | 6 -
.../ignite/internal/compute/ItMapReduceTest.java | 296 +++++++++++++++++++++
.../internal/compute/utils/InteractiveJobs.java | 34 ++-
.../internal/compute/utils/InteractiveTasks.java | 248 +++++++++++++++++
.../apache/ignite/internal/compute/MapReduce.java | 59 ++++
.../internal/compute/AntiHijackIgniteCompute.java | 12 +
.../internal/compute/AntiHijackJobExecution.java | 2 +-
.../ignite/internal/compute/ComputeComponent.java | 35 ++-
.../internal/compute/ComputeComponentImpl.java | 61 ++++-
.../ignite/internal/compute/ComputeUtils.java | 53 +++-
.../ignite/internal/compute/ExecutionManager.java | 15 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 54 ++--
...rkerSelector.java => TaskExecutionWrapper.java} | 29 +-
.../internal/compute/executor/ComputeExecutor.java | 7 +-
.../compute/executor/ComputeExecutorImpl.java | 14 +
.../compute/messaging/ComputeMessaging.java | 16 +-
.../compute/task/AntiHijackTaskExecution.java | 49 ++++
.../DelegatingTaskExecution.java} | 29 +-
.../internal/compute/task/JobSubmitter.java} | 16 +-
.../compute/task/TaskExecutionInternal.java | 294 ++++++++++++++++++++
31 files changed, 1707 insertions(+), 177 deletions(-)
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/TaskExecution.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/task/ComputeJobRunner.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/task/MapReduceTask.java
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/event/EventPublisher.java
=> api/src/main/java/org/apache/ignite/compute/task/TaskExecutionContext.java}
(77%)
copy
modules/{compute/src/main/java/org/apache/ignite/internal/compute/FailedExecution.java
=>
client/src/main/java/org/apache/ignite/internal/client/compute/task/ClientTaskExecution.java}
(62%)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/ItMapReduceTest.java
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/utils/InteractiveTasks.java
create mode 100644
modules/compute/src/jobs/java/org/apache/ignite/internal/compute/MapReduce.java
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{NextWorkerSelector.java
=> TaskExecutionWrapper.java} (55%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/task/AntiHijackTaskExecution.java
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{DelegatingJobExecution.java
=> task/DelegatingTaskExecution.java} (59%)
copy modules/{api/src/main/java/org/apache/ignite/lang/LoggerFactory.java =>
compute/src/main/java/org/apache/ignite/internal/compute/task/JobSubmitter.java}
(68%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/task/TaskExecutionInternal.java
