public class TNonblockingMultiFetchClient
extends java.lang.Object
Constructor and Description |
---|
TNonblockingMultiFetchClient(int maxRecvBufBytesPerServer,
int fetchTimeoutSeconds,
java.nio.ByteBuffer requestBuf,
java.util.List<java.net.InetSocketAddress> servers) |
Modifier and Type | Method and Description |
---|---|
java.nio.ByteBuffer[] |
fetch()
main entry function for fetching from servers
|
TNonblockingMultiFetchStats |
getFetchStats() |
int |
getFetchTimeoutSeconds() |
int |
getMaxRecvBufBytesPerServer() |
java.nio.ByteBuffer |
getRequestBuf()
return a duplication of requestBuf, so that requestBuf will not
be modified by others.
|
java.util.List<java.net.InetSocketAddress> |
getServerList() |
public TNonblockingMultiFetchClient(int maxRecvBufBytesPerServer, int fetchTimeoutSeconds, java.nio.ByteBuffer requestBuf, java.util.List<java.net.InetSocketAddress> servers)
public int getMaxRecvBufBytesPerServer()
public int getFetchTimeoutSeconds()
public java.nio.ByteBuffer getRequestBuf()
public java.util.List<java.net.InetSocketAddress> getServerList()
public TNonblockingMultiFetchStats getFetchStats()
public java.nio.ByteBuffer[] fetch()