voldemort.server.protocol.admin
Class UpdatePartitionEntriesStreamRequestHandler

java.lang.Object
  voldemort.server.protocol.admin.UpdatePartitionEntriesStreamRequestHandler

All Implemented Interfaces:

StreamRequestHandler

public class UpdatePartitionEntriesStreamRequestHandler
extends java.lang.Object
implements StreamRequestHandler

UpdatePartitionEntriesStreamRequestHandler implements the streaming logic for updating partition entries.

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

UpdatePartitionEntriesStreamRequestHandler(VAdminProto.UpdatePartitionEntriesRequest request, ErrorCodeMapper errorCodeMapper, VoldemortConfig voldemortConfig, StoreRepository storeRepository, NetworkClassLoader networkClassLoader)

Method Summary

void	close(java.io.DataOutputStream outputStream)
protected void	finalize()
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, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UpdatePartitionEntriesStreamRequestHandler

public UpdatePartitionEntriesStreamRequestHandler(VAdminProto.UpdatePartitionEntriesRequest request,
                                                  ErrorCodeMapper errorCodeMapper,
                                                  VoldemortConfig voldemortConfig,
                                                  StoreRepository storeRepository,
                                                  NetworkClassLoader networkClassLoader)

Method Detail

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object

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

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