This is an automated email from the ASF dual-hosted git repository.
jonwei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from a87db7f Add HashJoinSegment, a virtual segment for joins. (#9111)
add 42359c9 Implement ANY aggregator (#9187)
No new revisions were added by this update.
Summary of changes:
.../apache/druid/java/util/common/StringUtils.java | 22 +++
docs/querying/aggregations.md | 55 ++++++
docs/querying/sql.md | 4 +
.../apache/druid/jackson/AggregatorsModule.java | 10 +-
.../druid/query/aggregation/AggregatorUtil.java | 6 +
.../DoubleAnyAggregator.java} | 50 ++---
.../DoubleAnyAggregatorFactory.java} | 59 +++---
.../DoubleAnyBufferAggregator.java} | 47 ++---
.../FloatAnyAggregator.java} | 45 ++---
.../FloatAnyAggregatorFactory.java} | 61 +++----
.../FloatAnyBufferAggregator.java} | 47 ++---
.../LongAnyAggregator.java} | 48 ++---
.../LongAnyAggregatorFactory.java} | 59 +++---
.../LongAnyBufferAggregator.java} | 47 ++---
.../query/aggregation/any/StringAnyAggregator.java | 82 +++++++++
.../StringAnyAggregatorFactory.java} | 65 +++----
.../aggregation/any/StringAnyBufferAggregator.java | 102 +++++++++++
.../aggregation/first/StringFirstAggregator.java | 3 +-
.../aggregation/first/StringFirstLastUtils.java | 14 --
.../aggregation/last/StringLastAggregator.java | 3 +-
...or.java => EarliestLatestAnySqlAggregator.java} | 59 ++++--
.../aggregation/builtin/SimpleSqlAggregator.java | 7 +-
.../sql/calcite/planner/DruidOperatorTable.java | 7 +-
.../apache/druid/sql/calcite/CalciteQueryTest.java | 202 +++++++++++++++++++++
24 files changed, 791 insertions(+), 313 deletions(-)
copy
processing/src/main/java/org/apache/druid/query/aggregation/{first/DoubleFirstAggregator.java
=> any/DoubleAnyAggregator.java} (55%)
copy
processing/src/main/java/org/apache/druid/query/aggregation/{DoubleMaxAggregatorFactory.java
=> any/DoubleAnyAggregatorFactory.java} (65%)
copy
processing/src/main/java/org/apache/druid/query/aggregation/{last/DoubleLastBufferAggregator.java
=> any/DoubleAnyBufferAggregator.java} (56%)
copy
processing/src/main/java/org/apache/druid/query/aggregation/{last/FloatLastAggregator.java
=> any/FloatAnyAggregator.java} (56%)
copy
processing/src/main/java/org/apache/druid/query/aggregation/{FloatMinAggregatorFactory.java
=> any/FloatAnyAggregatorFactory.java} (65%)
copy
processing/src/main/java/org/apache/druid/query/aggregation/{first/FloatFirstBufferAggregator.java
=> any/FloatAnyBufferAggregator.java} (56%)
copy
processing/src/main/java/org/apache/druid/query/aggregation/{first/LongFirstAggregator.java
=> any/LongAnyAggregator.java} (56%)
copy
processing/src/main/java/org/apache/druid/query/aggregation/{LongMaxAggregatorFactory.java
=> any/LongAnyAggregatorFactory.java} (65%)
copy
processing/src/main/java/org/apache/druid/query/aggregation/{first/LongFirstBufferAggregator.java
=> any/LongAnyBufferAggregator.java} (56%)
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/any/StringAnyAggregator.java
copy
processing/src/main/java/org/apache/druid/query/aggregation/{last/StringLastAggregatorFactory.java
=> any/StringAnyAggregatorFactory.java} (68%)
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/any/StringAnyBufferAggregator.java
rename
sql/src/main/java/org/apache/druid/sql/calcite/aggregation/builtin/{EarliestLatestSqlAggregator.java
=> EarliestLatestAnySqlAggregator.java} (77%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
