@Override public DruidWritable getCurrentValue() throws IOException, InterruptedException {
    // Create new value
    DruidWritable value = new DruidWritable(true);
    value.setCompactedValue(compactedValues.next());
    return value;
  }
Record reader for results for Druid ScanQuery.
druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidScanQueryRecordReader.java