org.apache.accumulo.examples.wikisearch.iterator
Class GlobalIndexUidCombiner
java.lang.Object
org.apache.accumulo.core.iterators.WrappingIterator
org.apache.accumulo.core.iterators.Combiner
org.apache.accumulo.core.iterators.TypedValueCombiner<Uid.List>
org.apache.accumulo.examples.wikisearch.iterator.GlobalIndexUidCombiner
- All Implemented Interfaces:
- OptionDescriber, SortedKeyValueIterator<Key,Value>
public class GlobalIndexUidCombiner
- extends TypedValueCombiner<Uid.List>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
UID_LIST_ENCODER
public static final TypedValueCombiner.Encoder<Uid.List> UID_LIST_ENCODER
MAX
public static final int MAX
- See Also:
- Constant Field Values
GlobalIndexUidCombiner
public GlobalIndexUidCombiner()
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 TypedValueCombiner<Uid.List>
- 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.
typedReduce
public Uid.List typedReduce(Key key,
Iterator<Uid.List> iter)
- Description copied from class:
TypedValueCombiner
- Reduces a list of V into a single V.
- Specified by:
typedReduce
in class TypedValueCombiner<Uid.List>
- Parameters:
key
- The most recent version of the Key being reduced.iter
- An iterator over the V for different versions of the key.
- Returns:
- The combined V.
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.