public class DruidQueryBasedInputFormat extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,DruidWritable> implements org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,DruidWritable>, VectorizedInputFormatInterface
Constructor and Description |
---|
DruidQueryBasedInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable> |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
static DruidQueryRecordReader |
getDruidQueryReader(String druidQueryType) |
protected HiveDruidSplit[] |
getInputSplits(org.apache.hadoop.conf.Configuration conf) |
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable> |
getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
org.apache.hadoop.mapred.InputSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf job,
int numSplits) |
List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext context) |
VectorizedSupport.Support[] |
getSupportedFeatures() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSupportedFeatures
public static DruidQueryRecordReader getDruidQueryReader(String druidQueryType)
public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits) throws IOException
getSplits
in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,DruidWritable>
IOException
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context) throws IOException, InterruptedException
getSplits
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,DruidWritable>
IOException
InterruptedException
protected HiveDruidSplit[] getInputSplits(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable> getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) throws IOException
getRecordReader
in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,DruidWritable>
IOException
public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,DruidWritable>
IOException
InterruptedException
public VectorizedSupport.Support[] getSupportedFeatures()
getSupportedFeatures
in interface VectorizedInputFormatInterface
Copyright © 2023 The Apache Software Foundation. All rights reserved.