| Modifier and Type | Method and Description |
|---|---|
Future<ParallelScanResponse> |
AsyncClient.parallelScan(ParallelScanRequest request,
TableStoreCallback<ParallelScanRequest,ParallelScanResponse> callback) |
Future<ParallelScanResponse> |
AsyncClientInterface.parallelScan(ParallelScanRequest request,
TableStoreCallback<ParallelScanRequest,ParallelScanResponse> callback)
Scan data form SearchIndex.
|
Future<ParallelScanResponse> |
InternalClient.parallelScan(ParallelScanRequest request,
TableStoreCallback<ParallelScanRequest,ParallelScanResponse> callback) |
| Modifier and Type | Method and Description |
|---|---|
void |
ParallelScanLauncher.fire(ParallelScanRequest req,
org.apache.http.concurrent.FutureCallback<ParallelScanResponse> cb) |
ParallelScanLauncher |
LauncherFactory.parallelScan(TraceLogger tracer,
RetryStrategy retry,
ParallelScanRequest originRequest) |
| Constructor and Description |
|---|
ParallelScanLauncher(OTSUri uri,
TraceLogger tracer,
RetryStrategy retry,
String instanceName,
AsyncServiceClient client,
CredentialsProvider crdsProvider,
ClientConfiguration config,
ParallelScanRequest originRequest) |
| Modifier and Type | Method and Description |
|---|---|
static ParallelScanRequest |
SearchProtocolParser.toParallelScanRequest(byte[] bytes) |
static ParallelScanRequest |
SearchProtocolParser.toParallelScanRequest(com.google.protobuf.ByteString byteString) |
| Modifier and Type | Method and Description |
|---|---|
static Search.ParallelScanRequest |
SearchProtocolBuilder.buildParallelScanRequest(ParallelScanRequest parallelScanRequest) |
static byte[] |
SearchProtocolBuilder.buildParallelScanRequestToBytes(ParallelScanRequest request) |
| Constructor and Description |
|---|
ParallelScanRowIterator(SyncClientInterface syncClient,
ParallelScanRequest parallelScanRequest) |
| Modifier and Type | Method and Description |
|---|---|
ParallelScanRequest |
ParallelScanRequest.Builder.build() |
ParallelScanRequest |
ParallelScanRequest.setColumnsToGet(SearchRequest.ColumnsToGet columnsToGet) |
ParallelScanRequest |
ParallelScanRequest.setIndexName(String indexName) |
ParallelScanRequest |
ParallelScanRequest.setScanQuery(ScanQuery scanQuery) |
ParallelScanRequest |
ParallelScanRequest.setSessionId(byte[] sessionId) |
ParallelScanRequest |
ParallelScanRequest.setTableName(String tableName) |
ParallelScanRequest |
ParallelScanRequest.setTimeoutInMillisecond(int timeoutInMillisecond) |
Copyright © 2024. All Rights Reserved.