This is an automated email from the ASF dual-hosted git repository.
apkhmv pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from dd5e635c4be IGNITE-26051 Ignore destroyed tables in write intent
switch command (#6362)
add a584943a8d8 IGNITE-24116 Create compute task events (#6358)
No new revisions were added by this update.
Summary of changes:
.../ClientComputeExecuteColocatedRequest.java | 2 +
.../ClientComputeExecutePartitionedRequest.java | 2 +
.../compute/ClientComputeExecuteRequest.java | 5 +-
.../apache/ignite/client/fakes/FakeCompute.java | 6 +-
modules/compute/build.gradle | 5 +
.../internal/compute/events/EventMatcher.java | 202 ++++++++++++++
.../internal/compute/events/EventMatcherTest.java | 109 ++++++++
.../compute/events/ItComputeEventsTest.java | 303 +++++++++++++++++++++
.../ItEmbeddedComputeEventsTest.java} | 6 +-
.../compute/utils/MismatchesDescriptor.java | 57 ++++
.../ignite/internal/compute/ComputeComponent.java | 13 +
.../internal/compute/ComputeComponentImpl.java | 11 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 41 ++-
.../internal/compute/IgniteComputeInternal.java | 7 +
.../compute/events/ComputeEventMetadata.java | 220 +++++++++++++++
.../compute/events/ComputeEventsFactory.java | 138 ++++++++++
.../internal/compute/executor/ComputeExecutor.java | 5 +-
.../compute/executor/ComputeExecutorImpl.java | 31 ++-
.../compute/queue/PriorityQueueExecutor.java | 45 ++-
.../internal/compute/queue/QueueExecutionImpl.java | 31 ++-
.../compute/state/ComputeStateMachine.java | 5 +-
.../compute/state/InMemoryComputeStateMachine.java | 14 +-
.../internal/compute/ComputeComponentImplTest.java | 3 +-
.../internal/compute/IgniteComputeImplTest.java | 13 +-
.../compute/executor/ComputeExecutorTest.java | 10 +-
.../compute/queue/PriorityQueueExecutorTest.java | 5 +-
.../internal/eventlog/api/IgniteEventType.java | 8 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 8 +-
28 files changed, 1258 insertions(+), 47 deletions(-)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/events/EventMatcher.java
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/events/EventMatcherTest.java
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/events/ItComputeEventsTest.java
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItEmbeddedComputeErrorsTest.java
=> events/ItEmbeddedComputeEventsTest.java} (85%)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/utils/MismatchesDescriptor.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/events/ComputeEventMetadata.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/events/ComputeEventsFactory.java
