org.apache.accumulo.server.iterators
Class MetadataBulkLoadFilter

java.lang.Object
  extended by org.apache.accumulo.core.iterators.WrappingIterator
      extended by org.apache.accumulo.core.iterators.Filter
          extended by 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


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.accumulo.core.iterators.OptionDescriber
OptionDescriber.IteratorOptions
 
Field Summary
 
Fields inherited from class org.apache.accumulo.core.iterators.Filter
NEGATE
 
Constructor Summary
MetadataBulkLoadFilter()
           
 
Method Summary
 boolean accept(Key k, Value v)
           
protected  TransactionWatcher.Arbitrator getArbitrator()
           
 void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options, IteratorEnvironment env)
          Initializes the iterator.
 
Methods inherited from class org.apache.accumulo.core.iterators.Filter
deepCopy, describeOptions, findTop, next, seek, setNegate, validateOptions
 
Methods inherited from class org.apache.accumulo.core.iterators.WrappingIterator
getSource, getTopKey, getTopValue, hasTop, setSource
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MetadataBulkLoadFilter

public MetadataBulkLoadFilter()
Method Detail

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.