org.apache.accumulo.server.tabletserver
Class BulkFailedCopyProcessor

java.lang.Object
  extended by org.apache.accumulo.server.tabletserver.BulkFailedCopyProcessor
All Implemented Interfaces:
DistributedWorkQueue.Processor

public class BulkFailedCopyProcessor
extends Object
implements DistributedWorkQueue.Processor

Copy failed bulk imports.


Constructor Summary
BulkFailedCopyProcessor()
           
 
Method Summary
 DistributedWorkQueue.Processor newProcessor()
           
 void process(String workID, byte[] data)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BulkFailedCopyProcessor

public BulkFailedCopyProcessor()
Method Detail

newProcessor

public DistributedWorkQueue.Processor newProcessor()
Specified by:
newProcessor in interface DistributedWorkQueue.Processor

process

public void process(String workID,
                    byte[] data)
Specified by:
process in interface DistributedWorkQueue.Processor


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.