Set desiredBlockSize in pbToColumnSchema

pbToColumnSchema forgets to set desiredBlockSize; this fixes it. Change-Id: I918a483b6e4bf84db6e6d97e47768f999f6ab880 Reviewed-on: http://gerrit.cloudera.org:8080/4407 Tested-by: Kudu Jenkins Reviewed-by: Jean-Daniel Cryans <[email protected]>
jhx1008 · Sep 14, 2016 · 21a01cf · 21a01cf
1 parent cf38b52
commit 21a01cf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/java/kudu-client/src/main/java/org/apache/kudu/client/ProtobufHelper.java b/java/kudu-client/src/main/java/org/apache/kudu/client/ProtobufHelper.java
@@ -86,12 +86,14 @@ public static ColumnSchema pbToColumnSchema(Common.ColumnSchemaPB pb) {
     ColumnSchema.Encoding encoding = ColumnSchema.Encoding.valueOf(pb.getEncoding().name());
     ColumnSchema.CompressionAlgorithm compressionAlgorithm =
         ColumnSchema.CompressionAlgorithm.valueOf(pb.getCompression().name());
+    int desiredBlockSize = pb.getCfileBlockSize();
     return new ColumnSchema.ColumnSchemaBuilder(pb.getName(), type)
                            .key(pb.getIsKey())
                            .nullable(pb.getIsNullable())
                            .defaultValue(defaultValue)
                            .encoding(encoding)
                            .compressionAlgorithm(compressionAlgorithm)
+                           .desiredBlockSize(desiredBlockSize)
                            .build();
   }