diff --git a/presto-orc/src/main/java/io/prestosql/orc/stream/BooleanInputStream.java b/presto-orc/src/main/java/io/prestosql/orc/stream/BooleanInputStream.java
index 7d9b99f2d025..3990395ee2ad 100644
--- a/presto-orc/src/main/java/io/prestosql/orc/stream/BooleanInputStream.java
+++ b/presto-orc/src/main/java/io/prestosql/orc/stream/BooleanInputStream.java
@@ -59,12 +59,6 @@ public boolean nextBit()
         return result;
     }
 
-    @Override
-    public Class<BooleanStreamCheckpoint> getCheckpointType()
-    {
-        return BooleanStreamCheckpoint.class;
-    }
-
     @Override
     public void seekToCheckpoint(BooleanStreamCheckpoint checkpoint)
             throws IOException
diff --git a/presto-orc/src/main/java/io/prestosql/orc/stream/ByteArrayInputStream.java b/presto-orc/src/main/java/io/prestosql/orc/stream/ByteArrayInputStream.java
index c746ead57cb2..afe536ae9ae7 100644
--- a/presto-orc/src/main/java/io/prestosql/orc/stream/ByteArrayInputStream.java
+++ b/presto-orc/src/main/java/io/prestosql/orc/stream/ByteArrayInputStream.java
@@ -43,12 +43,6 @@ public void next(byte[] data, int offset, int length)
         inputStream.readFully(data, offset, length);
     }
 
-    @Override
-    public Class<ByteArrayStreamCheckpoint> getCheckpointType()
-    {
-        return ByteArrayStreamCheckpoint.class;
-    }
-
     @Override
     public void seekToCheckpoint(ByteArrayStreamCheckpoint checkpoint)
             throws IOException
diff --git a/presto-orc/src/main/java/io/prestosql/orc/stream/ByteInputStream.java b/presto-orc/src/main/java/io/prestosql/orc/stream/ByteInputStream.java
index 7e951d180da6..05609c861f89 100644
--- a/presto-orc/src/main/java/io/prestosql/orc/stream/ByteInputStream.java
+++ b/presto-orc/src/main/java/io/prestosql/orc/stream/ByteInputStream.java
@@ -73,12 +73,6 @@ private void readNextBlock()
         }
     }
 
-    @Override
-    public Class<ByteStreamCheckpoint> getCheckpointType()
-    {
-        return ByteStreamCheckpoint.class;
-    }
-
     @Override
     public void seekToCheckpoint(ByteStreamCheckpoint checkpoint)
             throws IOException
diff --git a/presto-orc/src/main/java/io/prestosql/orc/stream/DecimalInputStream.java b/presto-orc/src/main/java/io/prestosql/orc/stream/DecimalInputStream.java
index 416664c9569a..304dcfab6d01 100644
--- a/presto-orc/src/main/java/io/prestosql/orc/stream/DecimalInputStream.java
+++ b/presto-orc/src/main/java/io/prestosql/orc/stream/DecimalInputStream.java
@@ -42,12 +42,6 @@ public DecimalInputStream(OrcChunkLoader chunkLoader)
         this.chunkLoader = chunkLoader;
     }
 
-    @Override
-    public Class<? extends DecimalStreamCheckpoint> getCheckpointType()
-    {
-        return DecimalStreamCheckpoint.class;
-    }
-
     @Override
     public void seekToCheckpoint(DecimalStreamCheckpoint checkpoint)
             throws IOException
diff --git a/presto-orc/src/main/java/io/prestosql/orc/stream/DoubleInputStream.java b/presto-orc/src/main/java/io/prestosql/orc/stream/DoubleInputStream.java
index 1b5fe2a8287d..d7c7b988db57 100644
--- a/presto-orc/src/main/java/io/prestosql/orc/stream/DoubleInputStream.java
+++ b/presto-orc/src/main/java/io/prestosql/orc/stream/DoubleInputStream.java
@@ -34,12 +34,6 @@ public DoubleInputStream(OrcInputStream input)
         this.input = input;
     }
 
-    @Override
-    public Class<DoubleStreamCheckpoint> getCheckpointType()
-    {
-        return DoubleStreamCheckpoint.class;
-    }
-
     @Override
     public void seekToCheckpoint(DoubleStreamCheckpoint checkpoint)
             throws IOException
diff --git a/presto-orc/src/main/java/io/prestosql/orc/stream/FloatInputStream.java b/presto-orc/src/main/java/io/prestosql/orc/stream/FloatInputStream.java
index edb71026ab05..e624e84c723a 100644
--- a/presto-orc/src/main/java/io/prestosql/orc/stream/FloatInputStream.java
+++ b/presto-orc/src/main/java/io/prestosql/orc/stream/FloatInputStream.java
@@ -34,12 +34,6 @@ public FloatInputStream(OrcInputStream input)
         this.input = input;
     }
 
-    @Override
-    public Class<FloatStreamCheckpoint> getCheckpointType()
-    {
-        return FloatStreamCheckpoint.class;
-    }
-
     @Override
     public void seekToCheckpoint(FloatStreamCheckpoint checkpoint)
             throws IOException
diff --git a/presto-orc/src/main/java/io/prestosql/orc/stream/LongInputStreamV1.java b/presto-orc/src/main/java/io/prestosql/orc/stream/LongInputStreamV1.java
index 763dfa913a1d..c4cf36dec044 100644
--- a/presto-orc/src/main/java/io/prestosql/orc/stream/LongInputStreamV1.java
+++ b/presto-orc/src/main/java/io/prestosql/orc/stream/LongInputStreamV1.java
@@ -200,12 +200,6 @@ public void next(short[] values, int items)
         }
     }
 
-    @Override
-    public Class<? extends LongStreamV1Checkpoint> getCheckpointType()
-    {
-        return LongStreamV1Checkpoint.class;
-    }
-
     @Override
     public void seekToCheckpoint(LongStreamCheckpoint checkpoint)
             throws IOException
diff --git a/presto-orc/src/main/java/io/prestosql/orc/stream/LongInputStreamV2.java b/presto-orc/src/main/java/io/prestosql/orc/stream/LongInputStreamV2.java
index 02785b01aea8..fc4cb94d43ee 100644
--- a/presto-orc/src/main/java/io/prestosql/orc/stream/LongInputStreamV2.java
+++ b/presto-orc/src/main/java/io/prestosql/orc/stream/LongInputStreamV2.java
@@ -408,12 +408,6 @@ public void next(short[] values, int items)
         }
     }
 
-    @Override
-    public Class<LongStreamV2Checkpoint> getCheckpointType()
-    {
-        return LongStreamV2Checkpoint.class;
-    }
-
     @Override
     public void seekToCheckpoint(LongStreamCheckpoint checkpoint)
             throws IOException
diff --git a/presto-orc/src/main/java/io/prestosql/orc/stream/ValueInputStream.java b/presto-orc/src/main/java/io/prestosql/orc/stream/ValueInputStream.java
index 9fbafff2fc77..eec5235f6fe7 100644
--- a/presto-orc/src/main/java/io/prestosql/orc/stream/ValueInputStream.java
+++ b/presto-orc/src/main/java/io/prestosql/orc/stream/ValueInputStream.java
@@ -19,8 +19,6 @@
 
 public interface ValueInputStream<C extends StreamCheckpoint>
 {
-    Class<? extends C> getCheckpointType();
-
     void seekToCheckpoint(C checkpoint)
             throws IOException;