Fix to use proper Accumulo API
Project: http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/commit/e51ad6a2 Tree: http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/tree/e51ad6a2 Diff: http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/diff/e51ad6a2 Branch: refs/heads/master Commit: e51ad6a2f6a2f6437f627e6ec7d76f17d0378323 Parents: fb4af6c Author: Mike Miller <mmil...@apache.org> Authored: Fri Feb 17 12:27:58 2017 -0500 Committer: Mike Miller <mmil...@apache.org> Committed: Fri Feb 17 12:27:58 2017 -0500 ---------------------------------------------------------------------- .../iterator/DefaultIteratorEnvironment.java | 45 ++++++++++++++++---- 1 file changed, 37 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/blob/e51ad6a2/query/src/main/java/org/apache/accumulo/examples/wikisearch/iterator/DefaultIteratorEnvironment.java ---------------------------------------------------------------------- diff --git a/query/src/main/java/org/apache/accumulo/examples/wikisearch/iterator/DefaultIteratorEnvironment.java b/query/src/main/java/org/apache/accumulo/examples/wikisearch/iterator/DefaultIteratorEnvironment.java index d37751e..6783efe 100644 --- a/query/src/main/java/org/apache/accumulo/examples/wikisearch/iterator/DefaultIteratorEnvironment.java +++ b/query/src/main/java/org/apache/accumulo/examples/wikisearch/iterator/DefaultIteratorEnvironment.java @@ -16,26 +16,25 @@ */ package org.apache.accumulo.examples.wikisearch.iterator; -import java.io.IOException; - -import org.apache.accumulo.core.client.impl.BaseIteratorEnvironment; import org.apache.accumulo.core.conf.AccumuloConfiguration; +import org.apache.accumulo.core.client.sample.SamplerConfiguration; import org.apache.accumulo.core.data.Key; import org.apache.accumulo.core.data.Value; +import org.apache.accumulo.core.iterators.IteratorEnvironment; import org.apache.accumulo.core.iterators.SortedKeyValueIterator; import org.apache.accumulo.core.iterators.system.MapFileIterator; import org.apache.accumulo.core.util.CachedConfiguration; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; +import org.apache.accumulo.core.security.Authorizations; +import org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope; + +import java.io.IOException; -public class DefaultIteratorEnvironment extends BaseIteratorEnvironment { +public class DefaultIteratorEnvironment implements IteratorEnvironment { AccumuloConfiguration conf; - public DefaultIteratorEnvironment(AccumuloConfiguration conf) { - this.conf = conf; - } - public DefaultIteratorEnvironment() { this.conf = AccumuloConfiguration.getDefaultConfiguration(); } @@ -56,4 +55,34 @@ public class DefaultIteratorEnvironment extends BaseIteratorEnvironment { public boolean isSamplingEnabled() { return false; } + + @Override + public IteratorScope getIteratorScope() { + throw new UnsupportedOperationException(); + } + + @Override + public boolean isFullMajorCompaction() { + throw new UnsupportedOperationException(); + } + + @Override + public void registerSideChannel(SortedKeyValueIterator<Key,Value> iter) { + throw new UnsupportedOperationException(); + } + + @Override + public Authorizations getAuthorizations() { + throw new UnsupportedOperationException(); + } + + @Override + public SamplerConfiguration getSamplerConfiguration() { + throw new UnsupportedOperationException(); + } + + @Override + public IteratorEnvironment cloneWithSamplingEnabled() { + throw new UnsupportedOperationException(); + } }