public class DruidSelectQueryRecordReader extends DruidQueryRecordReader<io.druid.query.select.SelectQuery,io.druid.query.Result<io.druid.query.select.SelectResultValue>>
DruidQueryRecordReader.JsonParserIterator<R extends Comparable<R>>
query, queryResultsIterator, resultsType
Constructor and Description |
---|
DruidSelectQueryRecordReader() |
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.select.SelectQuery,io.druid.query.Result<io.druid.query.select.SelectResultValue>>
public boolean nextKeyValue() throws IOException
nextKeyValue
in class DruidQueryRecordReader<io.druid.query.select.SelectQuery,io.druid.query.Result<io.druid.query.select.SelectResultValue>>
IOException
public org.apache.hadoop.io.NullWritable getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class DruidQueryRecordReader<io.druid.query.select.SelectQuery,io.druid.query.Result<io.druid.query.select.SelectResultValue>>
IOException
InterruptedException
public DruidWritable getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class DruidQueryRecordReader<io.druid.query.select.SelectQuery,io.druid.query.Result<io.druid.query.select.SelectResultValue>>
IOException
InterruptedException
public boolean next(org.apache.hadoop.io.NullWritable key, DruidWritable value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable>
next
in class DruidQueryRecordReader<io.druid.query.select.SelectQuery,io.druid.query.Result<io.druid.query.select.SelectResultValue>>
IOException
public float getProgress()
getProgress
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable>
getProgress
in class DruidQueryRecordReader<io.druid.query.select.SelectQuery,io.druid.query.Result<io.druid.query.select.SelectResultValue>>
Copyright © 2022 The Apache Software Foundation. All rights reserved.