You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluo.apache.org by kt...@apache.org on 2019/02/14 15:00:53 UTC
[fluo-examples] branch master updated: updates to work with
Accumulo 2.0.0-alpha-2 (#4)
This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/fluo-examples.git
The following commit(s) were added to refs/heads/master by this push:
new d0a82b1 updates to work with Accumulo 2.0.0-alpha-2 (#4)
d0a82b1 is described below
commit d0a82b1b1fb0ad815dc84daa4003684131f3e917
Author: Keith Turner <kt...@apache.org>
AuthorDate: Thu Feb 14 10:00:49 2019 -0500
updates to work with Accumulo 2.0.0-alpha-2 (#4)
---
stresso/pom.xml | 7 +------
stresso/src/main/java/stresso/trie/AccumuloUtil.java | 4 ++--
2 files changed, 3 insertions(+), 8 deletions(-)
diff --git a/stresso/pom.xml b/stresso/pom.xml
index 0d3deba..8174112 100644
--- a/stresso/pom.xml
+++ b/stresso/pom.xml
@@ -27,7 +27,7 @@
<url>https://github.com/astralway/stresso</url>
<properties>
- <accumulo.version>2.0.0-alpha-1</accumulo.version>
+ <accumulo.version>2.0.0-alpha-2</accumulo.version>
<accumulo-plugin.version>2.0.0-SNAPSHOT</accumulo-plugin.version>
<hadoop.version>3.1.1</hadoop.version>
<fluo.version>1.2.0</fluo.version>
@@ -167,11 +167,6 @@
<version>${accumulo.version}</version>
</dependency>
<dependency>
- <groupId>org.apache.accumulo</groupId>
- <artifactId>accumulo-client-mapreduce</artifactId>
- <version>${accumulo.version}</version>
- </dependency>
- <dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-client</artifactId>
<version>${hadoop.version}</version>
diff --git a/stresso/src/main/java/stresso/trie/AccumuloUtil.java b/stresso/src/main/java/stresso/trie/AccumuloUtil.java
index a20bd01..8d36547 100644
--- a/stresso/src/main/java/stresso/trie/AccumuloUtil.java
+++ b/stresso/src/main/java/stresso/trie/AccumuloUtil.java
@@ -29,8 +29,8 @@ public class AccumuloUtil {
FluoConfiguration appCfg = new FluoConfiguration(fadmin.getApplicationConfig());
appCfg.setApplicationName(fc.getApplicationName());
AccumuloClient client = Accumulo.newClient()
- .forInstance(appCfg.getAccumuloInstance(), appCfg.getAccumuloZookeepers())
- .usingPassword(appCfg.getAccumuloUser(), appCfg.getAccumuloPassword()).build();
+ .to(appCfg.getAccumuloInstance(), appCfg.getAccumuloZookeepers())
+ .as(appCfg.getAccumuloUser(), appCfg.getAccumuloPassword()).build();
return tableOp.run(client.tableOperations(), appCfg.getAccumuloTable());
} catch (Exception e) {
throw new RuntimeException(e);