public class DruidGroupByQueryRecordReader extends DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
DruidQueryRecordReader.JsonParserIterator<R extends Comparable<R>>
query, queryResultsIterator, resultsType
Constructor and Description |
---|
DruidGroupByQueryRecordReader() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.io.NullWritable |
getCurrentKey() |
DruidWritable |
getCurrentValue() |
float |
getProgress() |
protected com.fasterxml.jackson.databind.JavaType |
getResultTypeDef() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.conf.Configuration conf) |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.conf.Configuration conf,
com.fasterxml.jackson.databind.ObjectMapper mapper,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
com.metamx.http.client.HttpClient httpClient) |
boolean |
next(org.apache.hadoop.io.NullWritable key,
DruidWritable value) |
boolean |
nextKeyValue() |
close, createKey, createValue, getPos, initialize
public void initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.conf.Configuration conf) throws IOException
initialize
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
IOException
public void initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.conf.Configuration conf, com.fasterxml.jackson.databind.ObjectMapper mapper, com.fasterxml.jackson.databind.ObjectMapper smileMapper, com.metamx.http.client.HttpClient httpClient) throws IOException
initialize
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
IOException
protected com.fasterxml.jackson.databind.JavaType getResultTypeDef()
getResultTypeDef
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
public boolean nextKeyValue()
nextKeyValue
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
public org.apache.hadoop.io.NullWritable getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
IOException
InterruptedException
public DruidWritable getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
IOException
InterruptedException
public boolean next(org.apache.hadoop.io.NullWritable key, DruidWritable value)
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable>
next
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable>
getProgress
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.