org.apache.accumulo.examples.wikisearch.iterator
Class GlobalIndexUidCombiner

java.lang.Object
  extended by org.apache.accumulo.core.iterators.WrappingIterator
      extended by org.apache.accumulo.core.iterators.Combiner
          extended by org.apache.accumulo.core.iterators.TypedValueCombiner<Uid.List>
              extended by org.apache.accumulo.examples.wikisearch.iterator.GlobalIndexUidCombiner
All Implemented Interfaces:
OptionDescriber, SortedKeyValueIterator<Key,Value>

public class GlobalIndexUidCombiner
extends TypedValueCombiner<Uid.List>


Nested Class Summary
static class GlobalIndexUidCombiner.UidListEncoder
           
 
Nested classes/interfaces inherited from class org.apache.accumulo.core.iterators.TypedValueCombiner
TypedValueCombiner.Encoder<V>
 
Nested classes/interfaces inherited from class org.apache.accumulo.core.iterators.Combiner
Combiner.ValueIterator
 
Nested classes/interfaces inherited from interface org.apache.accumulo.core.iterators.OptionDescriber
OptionDescriber.IteratorOptions
 
Field Summary
static int MAX
           
static TypedValueCombiner.Encoder<Uid.List> UID_LIST_ENCODER
           
 
Fields inherited from class org.apache.accumulo.core.iterators.TypedValueCombiner
LOSSY
 
Fields inherited from class org.apache.accumulo.core.iterators.Combiner
ALL_OPTION, COLUMNS_OPTION
 
Constructor Summary
GlobalIndexUidCombiner()
           
 
Method Summary
 void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options, IteratorEnvironment env)
          Initializes the iterator.
 Uid.List typedReduce(Key key, Iterator<Uid.List> iter)
          Reduces a list of V into a single V.
 
Methods inherited from class org.apache.accumulo.core.iterators.TypedValueCombiner
deepCopy, describeOptions, reduce, setEncoder, setEncoder, setLossyness, testEncoder, testEncoder, validateOptions
 
Methods inherited from class org.apache.accumulo.core.iterators.Combiner
getTopKey, getTopValue, hasTop, next, seek, setColumns, setCombineAllColumns
 
Methods inherited from class org.apache.accumulo.core.iterators.WrappingIterator
getSource, setSource
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

UID_LIST_ENCODER

public static final TypedValueCombiner.Encoder<Uid.List> UID_LIST_ENCODER

MAX

public static final int MAX
See Also:
Constant Field Values
Constructor Detail

GlobalIndexUidCombiner

public GlobalIndexUidCombiner()
Method Detail

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.