org.apache.druid.query.groupby.epinephelinae

Class GroupByRowProcessor

java.lang.Object

org.apache.druid.query.groupby.epinephelinae.GroupByRowProcessor

public class GroupByRowProcessor
extends Object

Constructor Summary

Constructors

Constructor and Description
GroupByRowProcessor()

Method Summary

Modifier and Type	Method and Description
static Grouper	createGrouper(Query queryParam, Sequence<Row> rows, Map<String,ValueType> rowSignature, GroupByQueryConfig config, GroupByQueryResource resource, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir, int mergeBufferSize, List<Closeable> closeOnExit, boolean wasQueryPushedDown)
static Sequence<Row>	getRowsFromGrouper(GroupByQuery query, List<String> subtotalSpec, com.google.common.base.Supplier<Grouper> grouper)

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupByRowProcessor

public GroupByRowProcessor()

Method Detail

createGrouper

public static Grouper createGrouper(Query queryParam,
                                    Sequence<Row> rows,
                                    Map<String,ValueType> rowSignature,
                                    GroupByQueryConfig config,
                                    GroupByQueryResource resource,
                                    com.fasterxml.jackson.databind.ObjectMapper spillMapper,
                                    String processingTmpDir,
                                    int mergeBufferSize,
                                    List<Closeable> closeOnExit,
                                    boolean wasQueryPushedDown)

getRowsFromGrouper

public static Sequence<Row> getRowsFromGrouper(GroupByQuery query,
                                               List<String> subtotalSpec,
                                               com.google.common.base.Supplier<Grouper> grouper)