diff --git a/processing/src/main/java/io/druid/segment/IndexMerger.java b/processing/src/main/java/io/druid/segment/IndexMerger.java index e21ae50e8f4..5d670c77946 100644 --- a/processing/src/main/java/io/druid/segment/IndexMerger.java +++ b/processing/src/main/java/io/druid/segment/IndexMerger.java @@ -463,8 +463,6 @@ public class IndexMerger } } - - final Interval dataInterval; File v8OutDir = new File(outDir, "v8-tmp"); v8OutDir.mkdirs(); @@ -491,7 +489,6 @@ public class IndexMerger maxTime = JodaUtils.maxDateTime(maxTime, index.getDataInterval().getEnd()); } - dataInterval = new Interval(minTime, maxTime); serializerUtils.writeString(channel, String.format("%s/%s", minTime, maxTime)); serializerUtils.writeString(channel, mapper.writeValueAsString(bitmapSerdeFactory)); } @@ -898,14 +895,6 @@ public class IndexMerger throw new IOException(String.format("Unable to delete temporary dir[%s]", smooshDir)); } - createIndexDrdFile( - IndexIO.V8_VERSION, - v8OutDir, - GenericIndexed.fromIterable(mergedDimensions, GenericIndexed.stringStrategy), - GenericIndexed.fromIterable(mergedMetrics, GenericIndexed.stringStrategy), - dataInterval - ); - IndexIO.DefaultIndexIOHandler.convertV8toV9(v8OutDir, outDir); FileUtils.deleteDirectory(v8OutDir); @@ -925,37 +914,6 @@ public class IndexMerger return Lists.newArrayList(retVal); } - public static void createIndexDrdFile( - byte versionId, - File inDir, - GenericIndexed availableDimensions, - GenericIndexed availableMetrics, - Interval dataInterval - ) throws IOException - { - File indexFile = new File(inDir, "index.drd"); - - FileChannel channel = null; - try { - channel = new FileOutputStream(indexFile).getChannel(); - channel.write(ByteBuffer.wrap(new byte[]{versionId})); - - availableDimensions.writeToChannel(channel); - availableMetrics.writeToChannel(channel); - serializerUtils.writeString( - channel, String.format("%s/%s", dataInterval.getStart(), dataInterval.getEnd()) - ); - serializerUtils.writeString( - channel, mapper.writeValueAsString(bitmapSerdeFactory) - ); - } - finally { - CloseQuietly.close(channel); - channel = null; - } - IndexIO.checkFileSize(indexFile); - } - private static class DimValueConverter { private final Indexed dimSet;