限定符和类型 | 方法和说明 |
---|---|
RowIterator |
SyncClient.createParallelScanIterator(ParallelScanRequest request) |
RowIterator |
SyncClientInterface.createParallelScanIterator(ParallelScanRequest request)
Get the Iterator for ParallelScan.
|
ParallelScanResponse |
SyncClient.parallelScan(ParallelScanRequest request) |
ParallelScanResponse |
SyncClientInterface.parallelScan(ParallelScanRequest request)
Scan data form SearchIndex.
|
Future<ParallelScanResponse> |
AsyncClient.parallelScan(ParallelScanRequest request,
TableStoreCallback<ParallelScanRequest,ParallelScanResponse> callback) |
Future<ParallelScanResponse> |
InternalClient.parallelScan(ParallelScanRequest request,
TableStoreCallback<ParallelScanRequest,ParallelScanResponse> callback) |
Future<ParallelScanResponse> |
AsyncClientInterface.parallelScan(ParallelScanRequest request,
TableStoreCallback<ParallelScanRequest,ParallelScanResponse> callback)
Scan data form SearchIndex.
|
限定符和类型 | 方法和说明 |
---|---|
Future<ParallelScanResponse> |
AsyncClient.parallelScan(ParallelScanRequest request,
TableStoreCallback<ParallelScanRequest,ParallelScanResponse> callback) |
Future<ParallelScanResponse> |
InternalClient.parallelScan(ParallelScanRequest request,
TableStoreCallback<ParallelScanRequest,ParallelScanResponse> callback) |
Future<ParallelScanResponse> |
AsyncClientInterface.parallelScan(ParallelScanRequest request,
TableStoreCallback<ParallelScanRequest,ParallelScanResponse> callback)
Scan data form SearchIndex.
|
限定符和类型 | 方法和说明 |
---|---|
void |
ParallelScanLauncher.fire(ParallelScanRequest req,
org.apache.http.concurrent.FutureCallback<ParallelScanResponse> cb) |
ParallelScanLauncher |
LauncherFactory.parallelScan(TraceLogger tracer,
RetryStrategy retry,
ParallelScanRequest originRequest) |
构造器和说明 |
---|
ParallelScanLauncher(OTSUri uri,
TraceLogger tracer,
RetryStrategy retry,
String instanceName,
AsyncServiceClient client,
CredentialsProvider crdsProvider,
ClientConfiguration config,
ParallelScanRequest originRequest) |
限定符和类型 | 方法和说明 |
---|---|
static ParallelScanRequest |
SearchProtocolParser.toParallelScanRequest(byte[] bytes) |
static ParallelScanRequest |
SearchProtocolParser.toParallelScanRequest(com.google.protobuf.ByteString byteString) |
限定符和类型 | 方法和说明 |
---|---|
static Search.ParallelScanRequest |
SearchProtocolBuilder.buildParallelScanRequest(ParallelScanRequest parallelScanRequest) |
static byte[] |
SearchProtocolBuilder.buildParallelScanRequestToBytes(ParallelScanRequest request) |
构造器和说明 |
---|
ParallelScanRowIterator(SyncClientInterface syncClient,
ParallelScanRequest parallelScanRequest) |
限定符和类型 | 方法和说明 |
---|---|
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 © 2021. All Rights Reserved.