This is an automated email from the ASF dual-hosted git repository.
ppa pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from f37a442d0f IGNITE-18215 .NET: LINQ: Fix GroupBy with complex
expression (#1533)
add 9731365856 IGNITE-18510: Sql. Make composite publisher thread safe
(#1511)
No new revisions were added by this update.
Summary of changes:
.../sql/engine/exec/rel/IndexScanNode.java | 14 +-
.../sql/engine/util/CompositePublisher.java | 172 ----------
.../sql/engine/util/ConcatenatedPublisher.java | 375 +++++++++++++++++++++
...tePublisher.java => OrderedMergePublisher.java} | 110 +++---
.../sql/engine/util/SubscriptionUtils.java | 65 ++++
.../sql/engine/util/CompositeSubscriptionTest.java | 135 ++++----
6 files changed, 571 insertions(+), 300 deletions(-)
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/CompositePublisher.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/ConcatenatedPublisher.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/{SortingCompositePublisher.java
=> OrderedMergePublisher.java} (77%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/SubscriptionUtils.java
