org.apache.accumulo.test.continuous
Class ContinuousMoru

java.lang.Object
  extended by org.apache.hadoop.conf.Configured
      extended by org.apache.accumulo.test.continuous.ContinuousMoru
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class ContinuousMoru
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

A map only job that reads a table created by continuous ingest and creates doubly linked list. This map reduce job tests the ability of a map only job to read and write to accumulo at the same time. This map reduce job mutates the table in such a way that it should not create any undefined nodes.


Nested Class Summary
static class ContinuousMoru.CMapper
           
 
Constructor Summary
ContinuousMoru()
           
 
Method Summary
static void main(String[] args)
           
 int run(String[] args)
           
 
Methods inherited from class org.apache.hadoop.conf.Configured
getConf, setConf
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.hadoop.conf.Configurable
getConf, setConf
 

Constructor Detail

ContinuousMoru

public ContinuousMoru()
Method Detail

run

public int run(String[] args)
        throws IOException,
               InterruptedException,
               ClassNotFoundException,
               AccumuloSecurityException
Specified by:
run in interface org.apache.hadoop.util.Tool
Throws:
IOException
InterruptedException
ClassNotFoundException
AccumuloSecurityException

main

public static void main(String[] args)
                 throws Exception
Parameters:
args - instanceName zookeepers username password table columns outputpath
Throws:
Exception


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.