voldemort.server.protocol.admin
Class FetchStreamRequestHandler

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

All Implemented Interfaces:

StreamRequestHandler

Direct Known Subclasses:

FetchEntriesStreamRequestHandler, FetchKeysStreamRequestHandler, FetchPartitionEntriesStreamRequestHandler, FetchPartitionKeysStreamRequestHandler

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 boolean	fetchOrphaned
protected VoldemortFilter	filter
protected Cluster	initialCluster
protected boolean	isJmxEnabled
protected org.apache.log4j.Logger	logger
protected int	nodeId
protected StreamingStats.Operation	operation
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 StorageEngine<ByteArray,byte[],byte[]>	storageEngine
protected StoreDefinition	storeDef
protected StreamingStats	streamStats
protected EventThrottler	throttler

Fields inherited from interface voldemort.server.protocol.StreamRequestHandler

STAT_RECORDS_INTERVAL

Constructor Summary

protected

FetchStreamRequestHandler(VAdminProto.FetchPartitionEntriesRequest request, MetadataStore metadataStore, ErrorCodeMapper errorCodeMapper, VoldemortConfig voldemortConfig, StoreRepository storeRepository, NetworkClassLoader networkClassLoader, StreamingStats.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 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

streamStats

protected final StreamingStats streamStats

isJmxEnabled

protected boolean isJmxEnabled

operation

protected final StreamingStats.Operation operation

counter

protected long counter

skipRecords

protected long skipRecords

fetched

protected int fetched

startTime

protected final long startTime

logger

protected final org.apache.log4j.Logger logger

nodeId

protected int nodeId

storeDef

protected StoreDefinition storeDef

fetchOrphaned

protected boolean fetchOrphaned

Constructor Detail

FetchStreamRequestHandler

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

Method Detail

getDirection

public final 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 final void handleError(java.io.DataOutputStream outputStream,
                              VoldemortException e)
                       throws java.io.IOException

Specified by:

handleError in interface StreamRequestHandler

Throws:

java.io.IOException