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 <ktur...@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);