voldemort.server.protocol.admin
Class UpdateSlopEntriesRequestHandler

java.lang.Object
  extended by voldemort.server.protocol.admin.UpdateSlopEntriesRequestHandler
All Implemented Interfaces:
StreamRequestHandler

public class UpdateSlopEntriesRequestHandler
extends java.lang.Object
implements StreamRequestHandler


Nested Class Summary
 
Nested classes/interfaces inherited from interface voldemort.server.protocol.StreamRequestHandler
StreamRequestHandler.StreamRequestDirection, StreamRequestHandler.StreamRequestHandlerState
 
Field Summary
 
Fields inherited from interface voldemort.server.protocol.StreamRequestHandler
STAT_RECORDS_INTERVAL
 
Constructor Summary
UpdateSlopEntriesRequestHandler(VAdminProto.UpdateSlopEntriesRequest request, ErrorCodeMapper errorCodeMapper, StoreRepository storeRepository, VoldemortConfig voldemortConfig)
           
 
Method Summary
 void close(java.io.DataOutputStream outputStream)
           
 StreamRequestHandler.StreamRequestDirection getDirection()
           
 void handleError(java.io.DataOutputStream outputStream, VoldemortException e)
           
 StreamRequestHandler.StreamRequestHandlerState handleRequest(java.io.DataInputStream inputStream, java.io.DataOutputStream outputStream)
          Handles a "segment" of a streaming request.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

UpdateSlopEntriesRequestHandler

public UpdateSlopEntriesRequestHandler(VAdminProto.UpdateSlopEntriesRequest request,
                                       ErrorCodeMapper errorCodeMapper,
                                       StoreRepository storeRepository,
                                       VoldemortConfig voldemortConfig)
Method Detail

getDirection

public StreamRequestHandler.StreamRequestDirection getDirection()
Specified by:
getDirection in interface StreamRequestHandler

close

public void close(java.io.DataOutputStream outputStream)
           throws java.io.IOException
Specified by:
close in interface StreamRequestHandler
Throws:
java.io.IOException

handleError

public void handleError(java.io.DataOutputStream outputStream,
                        VoldemortException e)
                 throws java.io.IOException
Specified by:
handleError in interface StreamRequestHandler
Throws:
java.io.IOException

handleRequest

public StreamRequestHandler.StreamRequestHandlerState handleRequest(java.io.DataInputStream inputStream,
                                                                    java.io.DataOutputStream outputStream)
                                                             throws java.io.IOException
Description copied from interface: StreamRequestHandler
Handles a "segment" of a streaming request.

Specified by:
handleRequest in interface StreamRequestHandler
Returns:
StreamRequestHandler.StreamRequestHandlerState
Throws:
java.io.IOException


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu