public class DruidGroupByQueryRecordReader extends DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
query, results
Constructor and Description |
---|
DruidGroupByQueryRecordReader() |
Modifier and Type | Method and Description |
---|---|
protected io.druid.query.groupby.GroupByQuery |
createQuery(String content) |
protected List<io.druid.data.input.Row> |
createResultsList(InputStream content) |
org.apache.hadoop.io.NullWritable |
getCurrentKey() |
DruidWritable |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.conf.Configuration conf) |
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
protected io.druid.query.groupby.GroupByQuery createQuery(String content) throws IOException
createQuery
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
IOException
protected List<io.druid.data.input.Row> createResultsList(InputStream content) throws IOException
createResultsList
in class DruidQueryRecordReader<io.druid.query.groupby.GroupByQuery,io.druid.data.input.Row>
IOException
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 © 2021 The Apache Software Foundation. All rights reserved.