diff --git a/presto-main/src/main/java/io/prestosql/operator/PartitionedConsumption.java b/presto-main/src/main/java/io/prestosql/operator/PartitionedConsumption.java
index cd69da644924..9ba07c684be3 100644
--- a/presto-main/src/main/java/io/prestosql/operator/PartitionedConsumption.java
+++ b/presto-main/src/main/java/io/prestosql/operator/PartitionedConsumption.java
@@ -46,12 +46,12 @@ public final class PartitionedConsumption<T>
     @Nullable
     private List<Partition<T>> partitions;
 
-    public PartitionedConsumption(int consumersCount, Iterable<Integer> partitionNumbers, IntFunction<ListenableFuture<T>> loader, IntConsumer disposer)
+    PartitionedConsumption(int consumersCount, Iterable<Integer> partitionNumbers, IntFunction<ListenableFuture<T>> loader, IntConsumer disposer)
     {
         this(consumersCount, immediateFuture(null), partitionNumbers, loader, disposer);
     }
 
-    public PartitionedConsumption(
+    private PartitionedConsumption(
             int consumersCount,
             ListenableFuture<?> activator,
             Iterable<Integer> partitionNumbers,
@@ -83,7 +83,7 @@ private List<Partition<T>> createPartitions(
         return partitions.build();
     }
 
-    public Iterator<Partition<T>> beginConsumption()
+    Iterator<Partition<T>> beginConsumption()
     {
         Queue<Partition<T>> partitions = new ArrayDeque<>(requireNonNull(this.partitions, "partitions is already null"));
         if (consumed.incrementAndGet() >= consumersCount) {