Package | Description |
---|---|
org.apache.hadoop.hive.druid.io | |
org.apache.hadoop.hive.druid.serde |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable> |
DruidQueryBasedInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,DruidWritable> |
DruidQueryBasedInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
org.apache.hadoop.mapred.RecordWriter<K,DruidWritable> |
DruidOutputFormat.getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
String name,
org.apache.hadoop.util.Progressable progress) |
Modifier and Type | Method and Description |
---|---|
void |
DruidRecordWriter.write(org.apache.hadoop.io.NullWritable key,
DruidWritable value) |
Modifier and Type | Method and Description |
---|---|
DruidWritable |
DruidQueryRecordReader.createValue() |
DruidWritable |
DruidSelectQueryRecordReader.getCurrentValue() |
abstract DruidWritable |
DruidQueryRecordReader.getCurrentValue() |
DruidWritable |
DruidTimeseriesQueryRecordReader.getCurrentValue() |
DruidWritable |
DruidGroupByQueryRecordReader.getCurrentValue() |
DruidWritable |
DruidTopNQueryRecordReader.getCurrentValue() |
Modifier and Type | Method and Description |
---|---|
boolean |
DruidSelectQueryRecordReader.next(org.apache.hadoop.io.NullWritable key,
DruidWritable value) |
abstract boolean |
DruidQueryRecordReader.next(org.apache.hadoop.io.NullWritable key,
DruidWritable value) |
boolean |
DruidTimeseriesQueryRecordReader.next(org.apache.hadoop.io.NullWritable key,
DruidWritable value) |
boolean |
DruidGroupByQueryRecordReader.next(org.apache.hadoop.io.NullWritable key,
DruidWritable value) |
boolean |
DruidTopNQueryRecordReader.next(org.apache.hadoop.io.NullWritable key,
DruidWritable value) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.