voldemort.server.protocol.admin
Class FullScanFetchEntriesRequestHandler
java.lang.Object
voldemort.server.protocol.admin.FetchStreamRequestHandler
voldemort.server.protocol.admin.FullScanFetchStreamRequestHandler
voldemort.server.protocol.admin.FullScanFetchEntriesRequestHandler
- All Implemented Interfaces:
- StreamRequestHandler
public class FullScanFetchEntriesRequestHandler
- extends FullScanFetchStreamRequestHandler
Fetches entries by scanning entire storage engine in storage-order.
For performance reason use storageEngine.keys() iterator to filter out
unwanted keys and then call storageEngine.get() for valid keys.
Fields inherited from class voldemort.server.protocol.admin.FetchStreamRequestHandler |
errorCodeMapper, fetched, fetchOrphaned, filter, initialCluster, isJmxEnabled, logger, nodeId, operation, partitionIds, recordsPerPartition, request, scanned, startTimeMs, storageEngine, storeDef, storeInstance, streamStats, throttler |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FullScanFetchEntriesRequestHandler
public FullScanFetchEntriesRequestHandler(VAdminProto.FetchPartitionEntriesRequest request,
MetadataStore metadataStore,
ErrorCodeMapper errorCodeMapper,
VoldemortConfig voldemortConfig,
StoreRepository storeRepository,
NetworkClassLoader networkClassLoader)
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.
- Returns:
StreamRequestHandler.StreamRequestHandlerState
- Throws:
java.io.IOException
Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu