org.apache.accumulo.server.iterators
Class MetadataBulkLoadFilter
java.lang.Object
org.apache.accumulo.core.iterators.WrappingIterator
org.apache.accumulo.core.iterators.Filter
org.apache.accumulo.server.iterators.MetadataBulkLoadFilter
- All Implemented Interfaces:
- OptionDescriber, SortedKeyValueIterator<Key,Value>
public class MetadataBulkLoadFilter
- extends Filter
A special iterator for the metadata table that removes inactive bulk load flags
Fields inherited from class org.apache.accumulo.core.iterators.Filter |
NEGATE |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MetadataBulkLoadFilter
public MetadataBulkLoadFilter()
accept
public boolean accept(Key k,
Value v)
- Specified by:
accept
in class Filter
- Returns:
- true if the key/value pair is accepted by the filter.
init
public void init(SortedKeyValueIterator<Key,Value> source,
Map<String,String> options,
IteratorEnvironment env)
throws IOException
- Description copied from interface:
SortedKeyValueIterator
- Initializes the iterator. Data should not be read from the source in this method.
- Specified by:
init
in interface SortedKeyValueIterator<Key,Value>
- Overrides:
init
in class Filter
- Parameters:
source
- SortedKeyValueIterator source to read data from.options
- Map map of string option names to option values.env
- IteratorEnvironment environment in which iterator is being run.
- Throws:
IOException
- unused.
getArbitrator
protected TransactionWatcher.Arbitrator getArbitrator()
Copyright © 2013 Apache Accumulo Project. All Rights Reserved.