Package org.apache.accumulo.core.util.format

Class ShardedTableDistributionFormatter

java.lang.Object

org.apache.accumulo.core.util.format.DefaultFormatter

org.apache.accumulo.core.util.format.AggregatingFormatter

org.apache.accumulo.core.util.format.ShardedTableDistributionFormatter

All Implemented Interfaces:

Iterator<String>, Formatter

public class ShardedTableDistributionFormatter
extends AggregatingFormatter

Formats the rows in a METADATA table scan to show distribution of shards over servers per day. This can be used to determine the effectiveness of the ShardedTableLoadBalancer Use this formatter with the following scan command in the shell: scan -b tableId -c ~tab:loc

Field Summary

Fields inherited from class org.apache.accumulo.core.util.format.DefaultFormatter

config

Constructor Summary

Constructors

Constructor	Description
ShardedTableDistributionFormatter()

Method Summary

Modifier and Type	Method	Description
protected void	aggregateStats(Map.Entry<Key,Value> entry)	Generate statistics from each Map.Entry, called for each entry to be iterated over.
protected String	getStats()	Finalize the aggregation and return the result.

Methods inherited from class org.apache.accumulo.core.util.format.AggregatingFormatter

next

Methods inherited from class org.apache.accumulo.core.util.format.DefaultFormatter

appendText, checkState, formatEntry, formatEntry, formatEntry, formatEntry, getScannerIterator, hasNext, initialize, isDoTimestamps, remove

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

ShardedTableDistributionFormatter

public ShardedTableDistributionFormatter()

Method Detail

aggregateStats

protected void aggregateStats(Map.Entry<Key,Value> entry)

Description copied from class: AggregatingFormatter

Generate statistics from each Map.Entry, called for each entry to be iterated over.

Specified by:

aggregateStats in class AggregatingFormatter

Parameters:

entry - the next entry to aggregate

getStats

protected String getStats()

Description copied from class: AggregatingFormatter

Finalize the aggregation and return the result. Called once at the end.

Specified by:

getStats in class AggregatingFormatter

Returns:

the aggregation results, suitable for printing to the console