Remove unused method ValueInputStream#getCheckpointType

trinodb · Aug 13, 2019 · 570d897 · 570d897
1 parent a911bba
commit 570d897
Show file tree

Hide file tree

Showing 9 changed files with 0 additions and 50 deletions.
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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -19,8 +19,6 @@
 
 public interface ValueInputStream<C extends StreamCheckpoint>
 {
-    Class<? extends C> getCheckpointType();
-
     void seekToCheckpoint(C checkpoint)
             throws IOException;