org.apache.accumulo.server.master.state
public class TabletStateChangeIterator extends SkippingIterator
Constructor and Description |
---|
TabletStateChangeIterator() |
Modifier and Type | Method and Description |
---|---|
protected void |
consume() |
SortedKeyValueIterator<Key,Value> |
deepCopy(IteratorEnvironment env)
Creates a deep copy of this iterator as though seek had not yet been called.
|
void |
init(SortedKeyValueIterator<Key,Value> source,
Map<String,String> options,
IteratorEnvironment env)
Initializes the iterator.
|
static void |
setCurrentServers(IteratorSetting cfg,
Set<TServerInstance> goodServers) |
static void |
setMerges(IteratorSetting cfg,
Collection<MergeInfo> merges) |
static void |
setMigrations(IteratorSetting cfg,
Collection<KeyExtent> migrations) |
static void |
setOnlineTables(IteratorSetting cfg,
Set<String> onlineTables) |
next, seek
getSource, getTopKey, getTopValue, hasTop, setSource
public void init(SortedKeyValueIterator<Key,Value> source, Map<String,String> options, IteratorEnvironment env) throws IOException
SortedKeyValueIterator
init
in interface SortedKeyValueIterator<Key,Value>
init
in class WrappingIterator
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.IOException
- unused.protected void consume() throws IOException
consume
in class SkippingIterator
IOException
public SortedKeyValueIterator<Key,Value> deepCopy(IteratorEnvironment env)
SortedKeyValueIterator
deepCopy
in interface SortedKeyValueIterator<Key,Value>
deepCopy
in class WrappingIterator
env
- IteratorEnvironment environment in which iterator is being run.public static void setCurrentServers(IteratorSetting cfg, Set<TServerInstance> goodServers)
public static void setOnlineTables(IteratorSetting cfg, Set<String> onlineTables)
public static void setMerges(IteratorSetting cfg, Collection<MergeInfo> merges)
public static void setMigrations(IteratorSetting cfg, Collection<KeyExtent> migrations)
Copyright © 2015 Apache Accumulo Project. All Rights Reserved.