public class AsyncMultiRead extends java.lang.Object implements java.util.concurrent.Callable<AsyncMultiReadResult>
Modifier and Type | Field and Description |
---|---|
private AsyncMultiReadResult |
asyncMultiReadResult |
private AbstractMultiSend |
bulkSend |
private int |
paramCount |
private java.util.List<ParameterHolder[]> |
parametersList |
private Protocol |
protocol |
private java.util.List<java.lang.String> |
queries |
private Results |
results |
private int |
sendCmdInitialCounter |
private BulkStatus |
status |
Constructor and Description |
---|
AsyncMultiRead(BulkStatus status,
Protocol protocol,
AbstractMultiSend bulkSend,
int paramCount,
Results results,
java.util.List<ParameterHolder[]> parametersList,
java.util.List<java.lang.String> queries,
PrepareResult prepareResult)
Read results async to avoid local and remote networking stack buffer overflow "lock".
|
Modifier and Type | Method and Description |
---|---|
AsyncMultiReadResult |
call() |
private final BulkStatus status
private final int sendCmdInitialCounter
private final Protocol protocol
private final AbstractMultiSend bulkSend
private final java.util.List<ParameterHolder[]> parametersList
private final java.util.List<java.lang.String> queries
private final Results results
private final int paramCount
private final AsyncMultiReadResult asyncMultiReadResult
public AsyncMultiRead(BulkStatus status, Protocol protocol, AbstractMultiSend bulkSend, int paramCount, Results results, java.util.List<ParameterHolder[]> parametersList, java.util.List<java.lang.String> queries, PrepareResult prepareResult)
status
- bulk statusprotocol
- protocolbulkSend
- bulk sender objectparamCount
- number of parametersresults
- execution resultparametersList
- parameter listqueries
- queriesprepareResult
- prepare resultpublic AsyncMultiReadResult call() throws java.lang.Exception
call
in interface java.util.concurrent.Callable<AsyncMultiReadResult>
java.lang.Exception