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 4c61ee327c IGNITE-19229 Schema validation during tx processing:
validators (#2872)
add 7a5b059855 IGNITE-20839 Impement compute jobs queue (#2843)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/ignite/lang/ErrorGroups.java | 6 +
.../ignite/internal/compute/ComputeComponent.java | 73 +++++-
.../internal/compute/ComputeComponentImpl.java | 221 ++++++-----------
.../ignite/internal/compute/ComputeUtils.java | 82 ++++++
.../ignite/internal/compute/ExecutionOptions.java} | 23 +-
.../configuration/ComputeConfigurationSchema.java | 7 +
.../internal/compute/message/ExecuteRequest.java | 11 +-
.../queue/BoundedPriorityBlockingQueue.java | 276 +++++++++++++++++++++
.../internal/compute/queue/ComputeExecutor.java} | 16 +-
.../compute/queue/ComputeExecutorImpl.java | 70 ++++++
.../compute/queue/PriorityQueueExecutor.java | 102 ++++++++
.../ignite/internal/compute/queue/QueueEntry.java | 101 ++++++++
.../compute/queue/QueueOverflowException.java} | 12 +-
.../internal/compute/ComputeComponentImplTest.java | 74 ++----
.../queue/BoundedPriorityBlockingQueueTest.java | 187 ++++++++++++++
.../compute/queue/PriorityQueueExecutorTest.java | 217 ++++++++++++++++
.../org/apache/ignite/internal/app/IgniteImpl.java | 6 +-
17 files changed, 1258 insertions(+), 226 deletions(-)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/ComputeUtils.java
copy
modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/meta/IndexMetaKey.java
=>
compute/src/main/java/org/apache/ignite/internal/compute/ExecutionOptions.java}
(68%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/queue/BoundedPriorityBlockingQueue.java
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/core/call/AsyncCall.java
=>
compute/src/main/java/org/apache/ignite/internal/compute/queue/ComputeExecutor.java}
(70%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/queue/ComputeExecutorImpl.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/queue/PriorityQueueExecutor.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/queue/QueueEntry.java
copy
modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationListenOnlyException.java
=>
compute/src/main/java/org/apache/ignite/internal/compute/queue/QueueOverflowException.java}
(73%)
create mode 100644
modules/compute/src/test/java/org/apache/ignite/internal/compute/queue/BoundedPriorityBlockingQueueTest.java
create mode 100644
modules/compute/src/test/java/org/apache/ignite/internal/compute/queue/PriorityQueueExecutorTest.java
