This is an automated email from the ASF dual-hosted git repository.
ptupitsyn pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 8ec31d2897 IGNITE-23949 Sql. Disable unsupported ASOF join (#5029)
add d5957d024d IGNITE-24174 Unify Compute API (#5016)
No new revisions were added by this update.
Summary of changes:
...Target.java => AllNodesBroadcastJobTarget.java} | 11 +-
.../apache/ignite/compute/BroadcastExecution.java} | 23 +-
.../apache/ignite/compute/BroadcastJobTarget.java | 66 ++++++
.../org/apache/ignite/compute/IgniteCompute.java | 236 ++++++++++++---------
.../org/apache/ignite/compute/JobExecution.java | 17 +-
.../apache/ignite/compute/task/MapReduceJob.java | 2 +-
.../apache/ignite/compute/task/TaskExecution.java | 9 -
.../compute/BroadcastJobExecutionImpl.java | 62 ++++++
.../ignite/internal/compute/FailedExecution.java | 10 +-
.../internal/compute/JobTaskStatusMapper.java | 26 ++-
.../ClientComputeExecuteColocatedRequest.java | 9 +-
.../compute/ClientComputeExecuteRequest.java | 30 ++-
.../apache/ignite/client/ClientOperationType.java | 4 +-
.../internal/client/compute/ClientCompute.java | 171 ++++++++++-----
.../client/compute/ClientJobExecution.java | 43 ++--
.../client/compute/ClientTaskExecution.java | 1 -
.../internal/client/compute/SubmitResult.java | 9 +-
.../internal/client/compute/SubmitTaskResult.java | 5 +-
.../apache/ignite/client/ClientComputeTest.java | 71 +++----
.../apache/ignite/client/ServerMetricsTest.java | 6 +-
.../apache/ignite/client/fakes/FakeCompute.java | 97 +++++----
.../ignite/internal/compute/ItComputeBaseTest.java | 227 ++++++++++++--------
.../internal/compute/ItComputeErrorsBaseTest.java | 38 ++--
.../internal/compute/ItComputeTestEmbedded.java | 80 ++++---
.../internal/compute/ItExecutionsCleanerTest.java | 32 ++-
.../compute/ItFailoverCandidateNotFoundTest.java | 7 +-
.../ignite/internal/compute/ItMapReduceTest.java | 74 ++++---
.../internal/compute/ItWorkerShutdownTest.java | 59 ++++--
.../threading/ItComputeApiThreadingTest.java | 39 ++--
.../compute/utils/TestingJobExecution.java | 48 ++---
...tion.java => AntiHijackBroadcastExecution.java} | 31 ++-
.../internal/compute/AntiHijackIgniteCompute.java | 91 ++++----
.../internal/compute/AntiHijackJobExecution.java | 9 +-
...rSelector.java => CancellableJobExecution.java} | 16 +-
...Selector.java => CancellableTaskExecution.java} | 16 +-
.../ignite/internal/compute/ComputeComponent.java | 8 +-
.../internal/compute/ComputeComponentImpl.java | 28 ++-
.../internal/compute/ComputeJobFailover.java | 22 +-
.../internal/compute/DelegatingJobExecution.java | 14 +-
.../ignite/internal/compute/ExecutionManager.java | 6 +-
.../internal/compute/FailSafeJobExecution.java | 14 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 215 +++++++++++--------
.../internal/compute/IgniteComputeInternal.java | 12 +-
.../compute/JobExecutionFutureWrapper.java | 59 ------
.../internal/compute/JobExecutionWrapper.java | 9 +-
.../internal/compute/RemoteExecutionContext.java | 3 +-
.../compute/ResultUnmarshallingJobExecution.java | 9 +-
.../internal/compute/TaskExecutionWrapper.java | 5 -
.../compute/TaskToJobExecutionWrapper.java | 28 ++-
.../compute/executor/ComputeExecutorImpl.java | 10 +-
.../compute/executor/JobExecutionInternal.java | 12 +-
.../compute/messaging/RemoteJobExecution.java | 9 +-
.../compute/task/AntiHijackTaskExecution.java | 5 -
.../compute/task/DelegatingTaskExecution.java | 3 +-
.../ignite/internal/compute/task/JobSubmitter.java | 10 +-
.../compute/task/TaskExecutionInternal.java | 26 +--
.../internal/compute/ComputeComponentImplTest.java | 27 ++-
.../internal/compute/IgniteComputeImplTest.java | 43 ++--
.../compute/executor/ComputeExecutorTest.java | 7 +-
.../matchers/BroadcastExecutionMatcher.java | 73 +++++++
.../matchers/JobExecutionMatcher.java | 135 ++++++++++++
.../ignite/internal/rebalance/ItRebalanceTest.java | 34 ++-
.../rest/compute/ItComputeControllerTest.java | 6 +-
.../ignite/internal/app/AsyncApiOperation.java | 14 +-
.../app/ItInProcessRestartApiReferencesTest.java | 5 +-
.../ignite/internal/app/SyncApiOperation.java | 12 +-
.../app/client/ItAbstractThinClientTest.java | 64 ++++++
.../client/ItThinClientComputeMarshallingTest.java | 34 +--
.../runner/app/client/ItThinClientComputeTest.java | 223 ++++++++++---------
...tThinClientComputeTypeCheckMarshallingTest.java | 8 +-
.../app/compute/ItEmbeddedMarshallingTest.java | 41 ++--
.../org/apache/ignite/internal/app/IgniteImpl.java | 2 +-
.../restart/RestartProofIgniteCompute.java | 69 ++++--
.../internal/ClusterPerTestIntegrationTest.java | 9 +
.../sql/engine/ItComputeSystemViewTest.java | 55 +++--
.../sql/engine/kill/ItSqlKillCommandTest.java | 32 ++-
76 files changed, 1912 insertions(+), 1163 deletions(-)
copy
modules/api/src/main/java/org/apache/ignite/compute/{AnyNodeJobTarget.java =>
AllNodesBroadcastJobTarget.java} (76%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/streamer/StreamerPartitionAwarenessProvider.java
=> api/src/main/java/org/apache/ignite/compute/BroadcastExecution.java} (59%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/BroadcastJobTarget.java
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/internal/compute/BroadcastJobExecutionImpl.java
rename modules/{compute =>
client-common}/src/main/java/org/apache/ignite/internal/compute/FailedExecution.java
(88%)
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{AntiHijackJobExecution.java
=> AntiHijackBroadcastExecution.java} (64%)
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{NextWorkerSelector.java
=> CancellableJobExecution.java} (61%)
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{NextWorkerSelector.java
=> CancellableTaskExecution.java} (61%)
delete mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/JobExecutionFutureWrapper.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/matchers/BroadcastExecutionMatcher.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/matchers/JobExecutionMatcher.java
