@Stability.Internal public class RangeScanOrchestrator extends Object
This class is meant as a low-level abstraction which is to be consumed from the higher level language bindings and not directly by the user. See the respective documentation for each language binding (java, scala, kotlin) for example usage.
Modifier and Type | Field and Description |
---|---|
static int |
RANGE_SCAN_DEFAULT_BATCH_BYTE_LIMIT |
static int |
RANGE_SCAN_DEFAULT_BATCH_ITEM_LIMIT |
Constructor and Description |
---|
RangeScanOrchestrator(Core core,
CollectionIdentifier collectionIdentifier)
Creates a new
RangeScanOrchestrator which can be shared across calls. |
Modifier and Type | Method and Description |
---|---|
Flux<CoreRangeScanItem> |
rangeScan(CoreRangeScan rangeScan,
CoreScanOptions options)
Performs a range scan between a start and an end term (reactive).
|
Flux<CoreRangeScanItem> |
samplingScan(CoreSamplingScan samplingScan,
CoreScanOptions options)
Performs a sampling scan (reactive).
|
public static final int RANGE_SCAN_DEFAULT_BATCH_BYTE_LIMIT
public static final int RANGE_SCAN_DEFAULT_BATCH_ITEM_LIMIT
public RangeScanOrchestrator(Core core, CollectionIdentifier collectionIdentifier)
RangeScanOrchestrator
which can be shared across calls.core
- the core to perform ops against.collectionIdentifier
- the pointer to the right collection to use.public Flux<CoreRangeScanItem> rangeScan(CoreRangeScan rangeScan, CoreScanOptions options)
rangeScan
- options
- Flux
of returned items, or a failed flux during errors.public Flux<CoreRangeScanItem> samplingScan(CoreSamplingScan samplingScan, CoreScanOptions options)
samplingScan
- options
- Flux
of returned items, or a failed flux during errors.Copyright © 2024 Couchbase, Inc.. All rights reserved.