Update Java examples for 0.9.0
Project: http://git-wip-us.apache.org/repos/asf/kudu/repo Commit: http://git-wip-us.apache.org/repos/asf/kudu/commit/5d3e245c Tree: http://git-wip-us.apache.org/repos/asf/kudu/tree/5d3e245c Diff: http://git-wip-us.apache.org/repos/asf/kudu/diff/5d3e245c Branch: refs/heads/master Commit: 5d3e245ca16024a88470defe1d7c519d53350033 Parents: 5bf7455 Author: Jean-Daniel Cryans <[email protected]> Authored: Wed Jun 15 21:18:40 2016 -0700 Committer: Jean-Daniel Cryans <[email protected]> Committed: Wed Jun 15 21:18:40 2016 -0700 ---------------------------------------------------------------------- java/collectl/pom.xml | 2 +- .../examples/collectl/KuduCollectlExample.java | 20 +++++++++++++++++--- java/insert-loadgen/pom.xml | 2 +- java/java-sample/pom.xml | 2 +- .../java/org/kududb/examples/sample/Sample.java | 6 +++++- 5 files changed, 25 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kudu/blob/5d3e245c/java/collectl/pom.xml ---------------------------------------------------------------------- diff --git a/java/collectl/pom.xml b/java/collectl/pom.xml index f90faae..65d1f36 100644 --- a/java/collectl/pom.xml +++ b/java/collectl/pom.xml @@ -57,7 +57,7 @@ <dependency> <groupId>org.kududb</groupId> <artifactId>kudu-client</artifactId> - <version>0.7.1</version> + <version>0.9.0</version> </dependency> <!-- for logging messages --> http://git-wip-us.apache.org/repos/asf/kudu/blob/5d3e245c/java/collectl/src/main/java/org/kududb/examples/collectl/KuduCollectlExample.java ---------------------------------------------------------------------- diff --git a/java/collectl/src/main/java/org/kududb/examples/collectl/KuduCollectlExample.java b/java/collectl/src/main/java/org/kududb/examples/collectl/KuduCollectlExample.java index 4480982..3e1ae29 100644 --- a/java/collectl/src/main/java/org/kududb/examples/collectl/KuduCollectlExample.java +++ b/java/collectl/src/main/java/org/kududb/examples/collectl/KuduCollectlExample.java @@ -14,6 +14,7 @@ import org.kududb.ColumnSchema; import org.kududb.ColumnSchema.ColumnSchemaBuilder; import org.kududb.Schema; import org.kududb.Type; +import org.kududb.client.CreateTableOptions; import org.kududb.client.Insert; import org.kududb.client.KuduClient; import org.kududb.client.KuduSession; @@ -64,7 +65,7 @@ public class KuduCollectlExample { return; } - ArrayList<ColumnSchema> cols = new ArrayList<>(); + List<ColumnSchema> cols = new ArrayList<>(); cols.add(new ColumnSchemaBuilder("host", Type.STRING).key(true).encoding( ColumnSchema.Encoding.DICT_ENCODING).build()); cols.add(new ColumnSchemaBuilder("metric", Type.STRING).key(true).encoding( @@ -74,7 +75,14 @@ public class KuduCollectlExample { cols.add(new ColumnSchemaBuilder("value", Type.DOUBLE) .encoding(ColumnSchema.Encoding.BIT_SHUFFLE).build()); - client.createTable(TABLE_NAME, new Schema(cols)); + // Need to set this up since we're not pre-partitioning. + List<String> rangeKeys = new ArrayList<>(); + rangeKeys.add("host"); + rangeKeys.add("metric"); + rangeKeys.add("timestamp"); + + client.createTable(TABLE_NAME, new Schema(cols), + new CreateTableOptions().setRangePartitionColumns(rangeKeys)); } private void createIdTableIfNecessary() throws Exception { @@ -86,7 +94,13 @@ public class KuduCollectlExample { cols.add(new ColumnSchemaBuilder("host", Type.STRING).key(true).build()); cols.add(new ColumnSchemaBuilder("metric", Type.STRING).key(true).build()); - client.createTable(ID_TABLE_NAME, new Schema(cols)); + // Need to set this up since we're not pre-partitioning. + List<String> rangeKeys = new ArrayList<>(); + rangeKeys.add("host"); + rangeKeys.add("metric"); + + client.createTable(ID_TABLE_NAME, new Schema(cols), + new CreateTableOptions().setRangePartitionColumns(rangeKeys)); } class HandlerThread extends Thread { http://git-wip-us.apache.org/repos/asf/kudu/blob/5d3e245c/java/insert-loadgen/pom.xml ---------------------------------------------------------------------- diff --git a/java/insert-loadgen/pom.xml b/java/insert-loadgen/pom.xml index 2d3bb40..fddcdf9 100644 --- a/java/insert-loadgen/pom.xml +++ b/java/insert-loadgen/pom.xml @@ -57,7 +57,7 @@ <dependency> <groupId>org.kududb</groupId> <artifactId>kudu-client</artifactId> - <version>0.7.1</version> + <version>0.9.0</version> </dependency> <!-- for logging messages --> http://git-wip-us.apache.org/repos/asf/kudu/blob/5d3e245c/java/java-sample/pom.xml ---------------------------------------------------------------------- diff --git a/java/java-sample/pom.xml b/java/java-sample/pom.xml index 183ba2d..2f66c99 100644 --- a/java/java-sample/pom.xml +++ b/java/java-sample/pom.xml @@ -57,7 +57,7 @@ <dependency> <groupId>org.kududb</groupId> <artifactId>kudu-client</artifactId> - <version>0.7.1</version> + <version>0.9.0</version> </dependency> <!-- for logging messages --> http://git-wip-us.apache.org/repos/asf/kudu/blob/5d3e245c/java/java-sample/src/main/java/org/kududb/examples/sample/Sample.java ---------------------------------------------------------------------- diff --git a/java/java-sample/src/main/java/org/kududb/examples/sample/Sample.java b/java/java-sample/src/main/java/org/kududb/examples/sample/Sample.java index 816d8f3..bd4b37b 100644 --- a/java/java-sample/src/main/java/org/kududb/examples/sample/Sample.java +++ b/java/java-sample/src/main/java/org/kududb/examples/sample/Sample.java @@ -28,8 +28,12 @@ public class Sample { .build()); columns.add(new ColumnSchema.ColumnSchemaBuilder("value", Type.STRING) .build()); + List<String> rangeKeys = new ArrayList<>(); + rangeKeys.add("key"); + Schema schema = new Schema(columns); - client.createTable(tableName, schema); + client.createTable(tableName, schema, + new CreateTableOptions().setRangePartitionColumns(rangeKeys)); KuduTable table = client.openTable(tableName); KuduSession session = client.newSession();
