public class DruidTimeseriesQueryRecordReader extends DruidQueryRecordReader<io.druid.query.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
query, results
Constructor and Description |
---|
DruidTimeseriesQueryRecordReader() |
Modifier and Type | Method and Description |
---|---|
protected io.druid.query.timeseries.TimeseriesQuery |
createQuery(String content) |
protected List<io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>> |
createResultsList(InputStream content) |
org.apache.hadoop.io.NullWritable |
getCurrentKey() |
DruidWritable |
getCurrentValue() |
float |
getProgress() |
boolean |
next(org.apache.hadoop.io.NullWritable key,
DruidWritable value) |
boolean |
nextKeyValue() |
close, createKey, createValue, getPos, initialize, initialize
protected io.druid.query.timeseries.TimeseriesQuery createQuery(String content) throws IOException
createQuery
in class DruidQueryRecordReader<io.druid.query.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
IOException
protected List<io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>> createResultsList(InputStream content) throws IOException
createResultsList
in class DruidQueryRecordReader<io.druid.query.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
IOException
public boolean nextKeyValue()
nextKeyValue
in class DruidQueryRecordReader<io.druid.query.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
public org.apache.hadoop.io.NullWritable getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class DruidQueryRecordReader<io.druid.query.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
IOException
InterruptedException
public DruidWritable getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class DruidQueryRecordReader<io.druid.query.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
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.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
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.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
IOException
Copyright © 2021 The Apache Software Foundation. All rights reserved.