public class ZipNumBlockLoader extends Object
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
bufferFully |
protected int |
connectTimeoutMS |
protected String |
cookie |
protected Map<String,SeekableLineReaderFactory> |
fileFactoryMap |
protected HTTPSeekableLineReaderFactory |
httpFactory |
protected String |
httpLib |
protected int |
maxHostConnections |
protected int |
maxTotalConnections |
protected boolean |
noKeepAlive |
protected int |
numRetries |
protected int |
readTimeoutMS |
protected int |
signDurationSecs |
protected HMACSigner |
signer |
protected boolean |
staleChecking |
protected boolean |
useNio |
| Constructor and Description |
|---|
ZipNumBlockLoader() |
| Modifier and Type | Method and Description |
|---|---|
SeekableLineReader |
attemptLoadBlock(String location,
long startOffset,
int totalLength,
boolean decompress,
boolean isRequired) |
void |
close() |
static void |
closeAllReaders() |
void |
closeFileFactory(String filename) |
SeekableLineReader |
createBlockReader(String uri) |
int |
getConnectTimeoutMS() |
String |
getCookie() |
protected SeekableLineReader |
getFileReader(String filename) |
String |
getHttpLib() |
protected HTTPSeekableLineReader |
getHttpReader(String url) |
int |
getMaxHostConnections() |
int |
getMaxTotalConnections() |
int |
getNumRetries() |
int |
getReadTimeoutMS() |
int |
getSignDurationSecs() |
HMACSigner |
getSigner() |
boolean |
isBufferFully() |
boolean |
isNoKeepAlive() |
boolean |
isStaleChecking() |
boolean |
isUseNio() |
void |
setBufferFully(boolean bufferFully) |
void |
setConnectTimeoutMS(int connectTimeoutMS) |
void |
setCookie(String cookie) |
void |
setHttpLib(String httpLib) |
void |
setMaxHostConnections(int maxHostConnections) |
void |
setMaxTotalConnections(int maxTotalConnections) |
void |
setNoKeepAlive(boolean noKeepAlive) |
void |
setNumRetries(int numRetries) |
void |
setReadTimeoutMS(int readTimeoutMS) |
void |
setSignDurationSecs(int signDurationSecs) |
void |
setSigner(HMACSigner signer) |
void |
setStaleChecking(boolean staleChecking) |
void |
setUseNio(boolean useNio) |
protected Map<String,SeekableLineReaderFactory> fileFactoryMap
protected HTTPSeekableLineReaderFactory httpFactory
protected HMACSigner signer
protected int signDurationSecs
protected boolean useNio
protected String httpLib
protected boolean bufferFully
protected boolean noKeepAlive
protected String cookie
protected int maxHostConnections
protected int maxTotalConnections
protected int connectTimeoutMS
protected int readTimeoutMS
protected int numRetries
protected boolean staleChecking
public static void closeAllReaders()
public SeekableLineReader createBlockReader(String uri) throws IOException
IOExceptionprotected HTTPSeekableLineReader getHttpReader(String url) throws IOException
IOExceptionprotected SeekableLineReader getFileReader(String filename) throws IOException
IOExceptionpublic SeekableLineReader attemptLoadBlock(String location, long startOffset, int totalLength, boolean decompress, boolean isRequired)
public void closeFileFactory(String filename) throws IOException
IOExceptionpublic void close()
throws IOException
IOExceptionpublic boolean isUseNio()
public void setUseNio(boolean useNio)
public boolean isBufferFully()
public void setBufferFully(boolean bufferFully)
public boolean isNoKeepAlive()
public void setNoKeepAlive(boolean noKeepAlive)
public int getMaxHostConnections()
public void setMaxHostConnections(int maxHostConnections)
public int getMaxTotalConnections()
public void setMaxTotalConnections(int maxTotalConnections)
public int getConnectTimeoutMS()
public void setConnectTimeoutMS(int connectTimeoutMS)
public int getReadTimeoutMS()
public void setReadTimeoutMS(int readTimeoutMS)
public int getNumRetries()
public void setNumRetries(int numRetries)
public void setStaleChecking(boolean staleChecking)
public boolean isStaleChecking()
public String getHttpLib()
public void setHttpLib(String httpLib)
public String getCookie()
public void setCookie(String cookie)
public HMACSigner getSigner()
public void setSigner(HMACSigner signer)
public int getSignDurationSecs()
public void setSignDurationSecs(int signDurationSecs)
Copyright © 2015 The International Internet Preservation Consortium. All Rights Reserved.