io.druid.query.groupby.epinephelinae

Class GroupByRowProcessor

java.lang.Object

io.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 Sequence<Row>	process(Query queryParam, Sequence<Row> rows, Map<String,ValueType> rowSignature, GroupByQueryConfig config, GroupByQueryResource resource, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir, int mergeBufferSize)

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

process

public static Sequence<Row> process(Query queryParam,
                                    Sequence<Row> rows,
                                    Map<String,ValueType> rowSignature,
                                    GroupByQueryConfig config,
                                    GroupByQueryResource resource,
                                    com.fasterxml.jackson.databind.ObjectMapper spillMapper,
                                    String processingTmpDir,
                                    int mergeBufferSize)