kudu-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jdcry...@apache.org
Subject kudu git commit: Set desiredBlockSize in pbToColumnSchema
Date Wed, 14 Sep 2016 17:58:10 GMT
Repository: kudu
Updated Branches:
  refs/heads/master cf38b5218 -> 21a01cff6


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 <jdcryans@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/kudu/repo
Commit: http://git-wip-us.apache.org/repos/asf/kudu/commit/21a01cff
Tree: http://git-wip-us.apache.org/repos/asf/kudu/tree/21a01cff
Diff: http://git-wip-us.apache.org/repos/asf/kudu/diff/21a01cff

Branch: refs/heads/master
Commit: 21a01cff6e0eddc82a519b80a0da3ec7a7ab57ea
Parents: cf38b52
Author: Will Berkeley <wdberkeley@gmail.com>
Authored: Tue Sep 13 18:43:27 2016 -0400
Committer: Jean-Daniel Cryans <jdcryans@apache.org>
Committed: Wed Sep 14 17:56:17 2016 +0000

----------------------------------------------------------------------
 .../src/main/java/org/apache/kudu/client/ProtobufHelper.java       | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kudu/blob/21a01cff/java/kudu-client/src/main/java/org/apache/kudu/client/ProtobufHelper.java
----------------------------------------------------------------------
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
index 174cdb3..d4ca5b8 100644
--- 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 class ProtobufHelper {
     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();
   }
 


Mime
View raw message