Package org.apache.druid.query.groupby.epinephelinae

Class GroupByResultMergeFn

java.lang.Object

org.apache.druid.query.groupby.epinephelinae.GroupByResultMergeFn

All Implemented Interfaces:

BiFunction<ResultRow,ResultRow,ResultRow>, BinaryOperator<ResultRow>

public class GroupByResultMergeFn
extends Object
implements BinaryOperator<ResultRow>

Class that knows how to merge aggregator data from two groupBy ResultRow objects that have the same time and dimensions. This code runs on Brokers as well as data servers, like Historicals. Used by GroupingEngine.mergeResults(org.apache.druid.query.QueryRunner<org.apache.druid.query.groupby.ResultRow>, org.apache.druid.query.groupby.GroupByQuery, org.apache.druid.query.context.ResponseContext).

Constructor Summary

Constructors

Constructor	Description
GroupByResultMergeFn(GroupByQuery query)

Method Summary

Modifier and Type	Method	Description
ResultRow	apply(ResultRow arg1, ResultRow arg2)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiFunction

andThen

Constructor Details

GroupByResultMergeFn

public GroupByResultMergeFn(GroupByQuery query)

Method Details

apply

@Nullable
public ResultRow apply(@Nullable
 ResultRow arg1,
 @Nullable
 ResultRow arg2)

Specified by:

apply in interface BiFunction<ResultRow,ResultRow,ResultRow>