Update artifact versions and make examples compile again There were some API changes during development so the collectl example no longer compiled.
Project: http://git-wip-us.apache.org/repos/asf/kudu/repo Commit: http://git-wip-us.apache.org/repos/asf/kudu/commit/e4fc37ac Tree: http://git-wip-us.apache.org/repos/asf/kudu/tree/e4fc37ac Diff: http://git-wip-us.apache.org/repos/asf/kudu/diff/e4fc37ac Branch: refs/heads/master Commit: e4fc37ac129de39a3f3f5855d2c750093d1b0e39 Parents: aefb1ab Author: Mike Percy <[email protected]> Authored: Sun Sep 27 18:16:29 2015 -0400 Committer: Mike Percy <[email protected]> Committed: Sun Sep 27 18:39:43 2015 -0400 ---------------------------------------------------------------------- java/collectl/pom.xml | 18 +++++++++----- .../examples/collectl/KuduCollectlExample.java | 26 +++++++++----------- java/java-sample/pom.xml | 17 +++++++++---- 3 files changed, 36 insertions(+), 25 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kudu/blob/e4fc37ac/java/collectl/pom.xml ---------------------------------------------------------------------- diff --git a/java/collectl/pom.xml b/java/collectl/pom.xml index 469eca0..70bf48b 100644 --- a/java/collectl/pom.xml +++ b/java/collectl/pom.xml @@ -6,7 +6,7 @@ <packaging>jar</packaging> <version>1.0-SNAPSHOT</version> <name>kudu-collectl-example</name> - + <build> <plugins> <plugin> @@ -40,19 +40,25 @@ </plugin> </plugins> </build> + <repositories> <repository> - <id>kudu-internal</id> - <name>Kudu client on Cloudera network</name> - <url>http://d2106.halxg.cloudera.com/kudu-2015-08-13-1/</url> + <id>cdh.repo</id> + <name>Cloudera Repositories</name> + <!-- <url>https://repository.cloudera.com/artifactory/cloudera-repos</url> --> + <url>http://maven.jenkins.cloudera.com:8081/artifactory/libs-release-local</url> + <snapshots> + <enabled>false</enabled> + </snapshots> </repository> </repositories> - + <dependencies> <dependency> <groupId>org.kududb</groupId> <artifactId>kudu-client</artifactId> - <version>0.1.0-SNAPSHOT</version> + <version>0.5.0</version> </dependency> </dependencies> + </project> http://git-wip-us.apache.org/repos/asf/kudu/blob/e4fc37ac/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 d35ffd3..effcca2 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 @@ -6,6 +6,7 @@ import java.net.ServerSocket; import java.net.Socket; import java.util.ArrayList; import java.util.Collections; +import java.util.List; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; @@ -13,11 +14,11 @@ import org.kududb.ColumnSchema; import org.kududb.ColumnSchema.ColumnSchemaBuilder; import org.kududb.Schema; import org.kududb.Type; -import org.kududb.client.BatchResponse; import org.kududb.client.Insert; import org.kududb.client.KuduClient; import org.kududb.client.KuduSession; import org.kududb.client.KuduTable; +import org.kududb.client.OperationResponse; import org.kududb.client.RowError; import org.kududb.client.SessionConfiguration.FlushMode; @@ -160,20 +161,17 @@ public class KuduCollectlExample { // If there's more data to read, don't flush yet -- better to accumulate // a larger batch. if (!br.ready()) { - ArrayList<BatchResponse> responses = session.flush(); - // TODO: the client should not group BatchResponse by tablet, since tablets - // are an implementation detail. - for (BatchResponse r : responses) { - for (RowError e : r.getRowErrors()) { - // TODO: the client should offer an enum for different row errors, instead - // of string comparison! - if ("ALREADY_PRESENT".equals(e.getStatus())) { - continue; - } - System.err.println("Error inserting " + e.getOperation().toString() - + ": " + e.toString()); + List<OperationResponse> responses = session.flush(); + for (OperationResponse r : responses) { + RowError e = r.getRowError(); + // TODO: the client should offer an enum for different row errors, instead + // of string comparison! + if ("ALREADY_PRESENT".equals(e.getStatus())) { + continue; + } + System.err.println("Error inserting " + e.getOperation().toString() + + ": " + e.toString()); } - } } } } http://git-wip-us.apache.org/repos/asf/kudu/blob/e4fc37ac/java/java-sample/pom.xml ---------------------------------------------------------------------- diff --git a/java/java-sample/pom.xml b/java/java-sample/pom.xml index f20e7ba..b0aa946 100644 --- a/java/java-sample/pom.xml +++ b/java/java-sample/pom.xml @@ -6,7 +6,7 @@ <packaging>jar</packaging> <version>1.0-SNAPSHOT</version> <name>kudu-java-sample</name> - + <build> <plugins> <plugin> @@ -40,18 +40,25 @@ </plugin> </plugins> </build> + <repositories> <repository> - <id>kudu-internal</id> - <name>Kudu client on Cloudera network</name> - <url>http://d2106.halxg.cloudera.com/kudu-2015-08-13-1/</url> + <id>cdh.repo</id> + <name>Cloudera Repositories</name> + <!-- <url>https://repository.cloudera.com/artifactory/cloudera-repos</url> --> + <url>http://maven.jenkins.cloudera.com:8081/artifactory/libs-release-local</url> + <snapshots> + <enabled>false</enabled> + </snapshots> </repository> </repositories> + <dependencies> <dependency> <groupId>org.kududb</groupId> <artifactId>kudu-client</artifactId> - <version>0.1.0-SNAPSHOT</version> + <version>0.5.0</version> </dependency> </dependencies> + </project>
