Package org.apache.accumulo.core.util

Class Merge

java.lang.Object

org.apache.accumulo.core.util.Merge

public class Merge
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Merge.MemoryConverter
static class	Merge.MergeException
static class	Merge.Size

Constructor Summary

Constructors

Constructor	Description
Merge()

Method Summary

Modifier and Type	Method	Description
protected Iterator<Merge.Size>	getSizeIterator(AccumuloClient client, String tablename, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end)
static void	main(String[] args)
protected void	merge(AccumuloClient client, String table, List<Merge.Size> sizes, int numToMerge)
protected long	mergeMany(AccumuloClient client, String table, List<Merge.Size> sizes, long goalSize, boolean force, boolean last)
protected void	mergeSome(AccumuloClient client, String table, List<Merge.Size> sizes, int numToMerge)
void	mergomatic(AccumuloClient client, String table, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end, long goalSize, boolean force)
protected void	message(String format, Object... args)
void	start(String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

Merge

public Merge()

Method Detail

message

protected void message(String format,
                       Object... args)

start

public void start(String[] args)
           throws Merge.MergeException

Throws:

Merge.MergeException

main

public static void main(String[] args)
                 throws Merge.MergeException

Throws:

Merge.MergeException

mergomatic

public void mergomatic(AccumuloClient client,
                       String table,
                       org.apache.hadoop.io.Text start,
                       org.apache.hadoop.io.Text end,
                       long goalSize,
                       boolean force)
                throws Merge.MergeException

Throws:

Merge.MergeException

mergeMany

protected long mergeMany(AccumuloClient client,
                         String table,
                         List<Merge.Size> sizes,
                         long goalSize,
                         boolean force,
                         boolean last)
                  throws Merge.MergeException

Throws:

Merge.MergeException

mergeSome

protected void mergeSome(AccumuloClient client,
                         String table,
                         List<Merge.Size> sizes,
                         int numToMerge)
                  throws Merge.MergeException

Throws:

Merge.MergeException

merge

protected void merge(AccumuloClient client,
                     String table,
                     List<Merge.Size> sizes,
                     int numToMerge)
              throws Merge.MergeException

Throws:

Merge.MergeException

getSizeIterator

protected Iterator<Merge.Size> getSizeIterator(AccumuloClient client,
                                               String tablename,
                                               org.apache.hadoop.io.Text start,
                                               org.apache.hadoop.io.Text end)
                                        throws Merge.MergeException

Throws:

Merge.MergeException