This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git.
from 17f66a2 IGNITE-9216 Uncomment tests in IgniteCacheTestSuite.
add a020b5e IGNITE-12609: SQL: GridReduceQueryExecutor refactoring.
(#7361)
No new revisions were added by this update.
Summary of changes:
.../apache/ignite/internal/util/lang/GridFunc.java | 3 +
.../cache/query/GridCacheTwoStepQuery.java | 18 +-
.../query/h2/H2JavaObjectSerializer.java} | 33 +-
.../processors/query/h2/IgniteH2Indexing.java | 12 +-
.../query/h2/sql/GridSqlQuerySplitter.java | 2 +
.../h2/twostep/AbstractReduceIndexAdapter.java | 128 +++++
.../query/h2/twostep/AbstractReducer.java | 367 ++++++++++++++
.../query/h2/twostep/GridMapQueryExecutor.java | 2 +-
.../query/h2/twostep/GridReduceQueryExecutor.java | 532 ++++++++++++---------
.../query/h2/twostep/ReduceBlockList.java | 5 +-
.../query/h2/twostep/ReduceIndexIterator.java | 10 +-
.../query/h2/twostep/ReducePartitionMapResult.java | 15 +-
.../query/h2/twostep/ReducePartitionMapper.java | 222 ++++++---
.../query/h2/twostep/ReduceQueryRun.java | 59 ++-
.../processors/query/h2/twostep/ReduceTable.java | 11 +-
.../processors/query/h2/twostep/Reducer.java | 106 ++++
.../query/h2/twostep/SortedReduceIndexAdapter.java | 67 +++
.../{ReduceIndexSorted.java => SortedReducer.java} | 356 +++++++++++---
.../h2/twostep/UnsortedReduceIndexAdapter.java | 61 +++
...duceIndexUnsorted.java => UnsortedReducer.java} | 146 ++++--
.../query/h2/twostep/msg/GridH2QueryRequest.java | 31 ++
.../query/IgniteSqlSplitterSelfTest.java | 6 +-
.../internal/processors/query/KillQueryTest.java | 4 +-
.../h2/twostep/RetryCauseMessageSelfTest.java | 8 +-
.../IgniteBinaryCacheQueryTestSuite.java | 3 -
25 files changed, 1709 insertions(+), 498 deletions(-)
copy
modules/{core/src/main/java/org/apache/ignite/internal/processors/platform/plugin/PlatformPluginProcessor.java
=>
indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/H2JavaObjectSerializer.java}
(52%)
create mode 100644
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/AbstractReduceIndexAdapter.java
create mode 100644
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/AbstractReducer.java
create mode 100644
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/Reducer.java
create mode 100644
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/SortedReduceIndexAdapter.java
rename
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/{ReduceIndexSorted.java
=> SortedReducer.java} (54%)
create mode 100644
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/UnsortedReduceIndexAdapter.java
rename
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/{ReduceIndexUnsorted.java
=> UnsortedReducer.java} (53%)
