Rename PartitionCommitter close to flush

prestodb · Jan 25, 2016 · 4ed9ae5 · 4ed9ae5
1 parent c03031b
commit 4ed9ae5
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/presto-hive/src/main/java/com/facebook/presto/hive/HiveMetadata.java b/presto-hive/src/main/java/com/facebook/presto/hive/HiveMetadata.java
@@ -64,7 +64,6 @@
 
 import javax.inject.Inject;
 
-import java.io.Closeable;
 import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.util.ArrayList;
@@ -661,7 +660,7 @@ public void commitCreateTable(ConnectorSession session, ConnectorOutputTableHand
                         .map(partitionUpdate -> createPartition(table, partitionUpdate))
                         .forEach(partitionCommitter::addPartition);
             }
-            partitionCommitter.close();
+            partitionCommitter.flush();
         }
         catch (Throwable throwable) {
             partitionCommitter.abort();
@@ -707,7 +706,6 @@ public HiveInsertTableHandle beginInsert(ConnectorSession session, ConnectorTabl
     }
 
     private static class PartitionCommitter
-            implements Closeable
     {
         private final String schemaName;
         private final String tableName;
@@ -738,8 +736,7 @@ public void addPartition(Partition partition)
             }
         }
 
-        @Override
-        public void close()
+        public void flush()
         {
             if (!batch.isEmpty()) {
                 addBatch();
@@ -837,7 +834,7 @@ public void commitInsert(ConnectorSession session, ConnectorInsertTableHandle in
                     }
                 }
             }
-            partitionCommitter.close();
+            partitionCommitter.flush();
             for (CompletableFuture<?> fileRenameFuture : fileRenameFutures) {
                 MoreFutures.getFutureValue(fileRenameFuture, PrestoException.class);
             }