Correct parameter name

trinodb · Jul 25, 2020 · 0eace40 · 0eace40
1 parent 74edaa3
commit 0eace40
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/presto-product-tests/src/main/java/io/prestosql/tests/hive/BucketingType.java b/presto-product-tests/src/main/java/io/prestosql/tests/hive/BucketingType.java
@@ -24,7 +24,7 @@ public enum BucketingType
 {
     NONE {
         @Override
-        public String getHiveClustering(String columnNames, int buckets)
+        public String getHiveClustering(String columnName, int buckets)
         {
             return "";
         }
@@ -38,9 +38,9 @@ public List<String> getHiveTableProperties()
 
     BUCKETED_DEFAULT {
         @Override
-        public String getHiveClustering(String columnNames, int buckets)
+        public String getHiveClustering(String columnName, int buckets)
         {
-            return defaultHiveClustering(columnNames, buckets);
+            return defaultHiveClustering(columnName, buckets);
         }
 
         @Override
@@ -52,9 +52,9 @@ public List<String> getHiveTableProperties()
 
     BUCKETED_V1 {
         @Override
-        public String getHiveClustering(String columnNames, int buckets)
+        public String getHiveClustering(String columnName, int buckets)
         {
-            return defaultHiveClustering(columnNames, buckets);
+            return defaultHiveClustering(columnName, buckets);
         }
 
         @Override
@@ -66,9 +66,9 @@ public List<String> getHiveTableProperties()
 
     BUCKETED_V2 {
         @Override
-        public String getHiveClustering(String columnNames, int buckets)
+        public String getHiveClustering(String columnName, int buckets)
         {
-            return defaultHiveClustering(columnNames, buckets);
+            return defaultHiveClustering(columnName, buckets);
         }
 
         @Override
@@ -83,9 +83,9 @@ public List<String> getHiveTableProperties()
 
     public abstract List<String> getHiveTableProperties();
 
-    private static String defaultHiveClustering(String columnNames, int buckets)
+    private static String defaultHiveClustering(String columnName, int buckets)
     {
-        requireNonNull(columnNames, "columnNames is null");
-        return format("CLUSTERED BY(%s) INTO %s BUCKETS", columnNames, buckets);
+        requireNonNull(columnName, "columnName is null");
+        return format("CLUSTERED BY(%s) INTO %s BUCKETS", columnName, buckets);
     }
 }