diff --git a/processing/src/main/java/io/druid/segment/data/GenericIndexedWriter.java b/processing/src/main/java/io/druid/segment/data/GenericIndexedWriter.java
index 2d6d93b07224..c91d73ffbf32 100644
--- a/processing/src/main/java/io/druid/segment/data/GenericIndexedWriter.java
+++ b/processing/src/main/java/io/druid/segment/data/GenericIndexedWriter.java
@@ -25,6 +25,7 @@
 import com.google.common.io.ByteSource;
 import com.google.common.io.ByteStreams;
 import com.google.common.io.CountingOutputStream;
+import com.google.common.io.InputSupplier;
 import com.google.common.primitives.Ints;
 
 import java.io.Closeable;
@@ -144,15 +145,15 @@ public InputStream openStream() throws IOException
         return ByteStreams.join(
             Iterables.transform(
                 Arrays.asList("meta", "header", "values"),
-                new Function<String, ByteSource>()
+                new Function<String, InputSupplier<InputStream>>()
                 {
                   @Override
-                  public ByteSource apply(final String input)
+                  public InputSupplier<InputStream> apply(final String input)
                   {
-                    return new ByteSource()
+                    return new InputSupplier<InputStream>()
                     {
                       @Override
-                      public InputStream openStream() throws IOException
+                      public InputStream getInput() throws IOException
                       {
                         return ioPeon.makeInputStream(makeFilename(input));
                       }