voldemort.server.protocol.admin
Class FetchStreamRequestHandler

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

All Implemented Interfaces:

StreamRequestHandler

Direct Known Subclasses:

FetchEntriesStreamRequestHandler, FetchKeysStreamRequestHandler

public abstract class FetchStreamRequestHandler
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

protected long	counter
protected ErrorCodeMapper	errorCodeMapper
protected int	fetched
protected VoldemortFilter	filter
protected StreamStats.Handle	handle
protected Cluster	initialCluster
protected ClosableIterator<ByteArray>	keyIterator
protected org.apache.log4j.Logger	logger
protected int	nodeId
protected java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>	replicaToPartitionList
protected VAdminProto.FetchPartitionEntriesRequest	request
protected long	skipRecords
protected long	startTime
protected StreamStats	stats
protected StorageEngine<ByteArray,byte[],byte[]>	storageEngine
protected StoreDefinition	storeDef
protected EventThrottler	throttler

Constructor Summary

protected

FetchStreamRequestHandler(VAdminProto.FetchPartitionEntriesRequest request, MetadataStore metadataStore, ErrorCodeMapper errorCodeMapper, VoldemortConfig voldemortConfig, StoreRepository storeRepository, NetworkClassLoader networkClassLoader, StreamStats stats, StreamStats.Operation operation)

Method Summary

void	close(java.io.DataOutputStream outputStream)
StreamRequestHandler.StreamRequestDirection	getDirection()
void	handleError(java.io.DataOutputStream outputStream, VoldemortException e)

Methods inherited from class java.lang.Object

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

Methods inherited from interface voldemort.server.protocol.StreamRequestHandler

handleRequest

Field Detail

request

protected final VAdminProto.FetchPartitionEntriesRequest request

errorCodeMapper

protected final ErrorCodeMapper errorCodeMapper

initialCluster

protected final Cluster initialCluster

throttler

protected final EventThrottler throttler

replicaToPartitionList

protected final java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList

filter

protected final VoldemortFilter filter

storageEngine

protected final StorageEngine<ByteArray,byte[],byte[]> storageEngine

keyIterator

protected final ClosableIterator<ByteArray> keyIterator

counter

protected long counter

skipRecords

protected long skipRecords

fetched

protected int fetched

startTime

protected final long startTime

handle

protected final StreamStats.Handle handle

stats

protected final StreamStats stats

logger

protected final org.apache.log4j.Logger logger

nodeId

protected int nodeId

storeDef

protected StoreDefinition storeDef

Constructor Detail

FetchStreamRequestHandler

protected FetchStreamRequestHandler(VAdminProto.FetchPartitionEntriesRequest request,
                                    MetadataStore metadataStore,
                                    ErrorCodeMapper errorCodeMapper,
                                    VoldemortConfig voldemortConfig,
                                    StoreRepository storeRepository,
                                    NetworkClassLoader networkClassLoader,
                                    StreamStats stats,
                                    StreamStats.Operation operation)

Method Detail

getDirection

public final StreamRequestHandler.StreamRequestDirection getDirection()

Specified by:

getDirection in interface StreamRequestHandler

close

public final void close(java.io.DataOutputStream outputStream)
                 throws java.io.IOException

Specified by:

close in interface StreamRequestHandler

Throws:

java.io.IOException

handleError

public final void handleError(java.io.DataOutputStream outputStream,
                              VoldemortException e)
                       throws java.io.IOException

Specified by:

handleError in interface StreamRequestHandler

Throws:

java.io.IOException