public class DruidTimeseriesQueryRecordReader extends DruidQueryRecordReader<io.druid.query.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
DruidQueryRecordReader.JsonParserIterator<R extends Comparable<R>>
query, queryResultsIterator, resultsType
Constructor and Description |
---|
DruidTimeseriesQueryRecordReader() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.io.NullWritable |
getCurrentKey() |
DruidWritable |
getCurrentValue() |
float |
getProgress() |
protected com.fasterxml.jackson.databind.JavaType |
getResultTypeDef() |
boolean |
next(org.apache.hadoop.io.NullWritable key,
DruidWritable value) |
boolean |
nextKeyValue() |
close, createKey, createValue, getPos, initialize, initialize, initialize
protected com.fasterxml.jackson.databind.JavaType getResultTypeDef()
getResultTypeDef
in class DruidQueryRecordReader<io.druid.query.timeseries.TimeseriesQuery,io.druid.query.Result<io.druid.query.timeseries.TimeseriesResultValue>>
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 © 2022 The Apache Software Foundation. All rights reserved.