Class BatcherFactory<RequestT,ResponseT> (2.72.2)
- 2.72.2 (latest)
- 2.72.1
- 2.71.0
- 2.70.3
- 2.69.0
- 2.68.2
- 2.67.0
- 2.66.0
- 2.65.0
- 2.63.1
- 2.62.0
- 2.61.0
- 2.60.0
- 2.59.1
- 2.58.0
- 2.57.0
- 2.55.0
- 2.54.1
- 2.53.0
- 2.52.0
- 2.51.0
- 2.50.0
- 2.49.0
- 2.48.1
- 2.47.0
- 2.46.1
- 2.45.0
- 2.43.0
- 2.42.0
- 2.41.0
- 2.39.0
- 2.38.0
- 2.37.0
- 2.36.0
- 2.35.0
- 2.34.1
- 2.33.0
- 2.32.1
- 2.31.1
- 2.30.1
- 2.24.0
- 2.23.3
- 2.22.0
- 2.21.0
- 2.20.1
- 2.19.6
- 2.18.7
- 2.17.0
- 2.16.0
- 2.15.0
- 2.14.0
- 2.13.0
- 2.12.2
- 2.11.0
- 2.10.0
- 2.9.0
- 2.8.1
- 2.7.1
publicfinalclassBatcherFactory<RequestT,ResponseT>A Factory class which, for each unique partitionKey, creates a trio including a ThresholdBatcher, BatchExecutor, and ThresholdBatchingForwarder. The ThresholdBatchingForwarder pulls items from the ThresholdBatcher and forwards them to the BatchExecutor for processing.
This is public only for technical reasons, for advanced usage.
Type Parameters | |
|---|---|
| Name | Description |
RequestT | |
ResponseT | |
Constructors
BatcherFactory(BatchingDescriptor<RequestT,ResponseT> batchingDescriptor, BatchingSettings batchingSettings, ScheduledExecutorService executor, FlowController flowController)
publicBatcherFactory(BatchingDescriptor<RequestT,ResponseT>batchingDescriptor,BatchingSettingsbatchingSettings,ScheduledExecutorServiceexecutor,FlowControllerflowController)| Parameters | |
|---|---|
| Name | Description |
batchingDescriptor | BatchingDescriptor<RequestT,ResponseT> |
batchingSettings | BatchingSettings |
executor | ScheduledExecutorService |
flowController | FlowController |
Methods
getBatchingSettings()
publicBatchingSettingsgetBatchingSettings()| Returns | |
|---|---|
| Type | Description |
BatchingSettings | |
getPushingBatcher(PartitionKey partitionKey)
publicThresholdBatcher<Batch<RequestT,ResponseT>>getPushingBatcher(PartitionKeypartitionKey)Provides the ThresholdBatcher corresponding to the given partitionKey, or constructs one if it doesn't exist yet. The implementation is thread-safe.
| Parameter | |
|---|---|
| Name | Description |
partitionKey | PartitionKey |
| Returns | |
|---|---|
| Type | Description |
ThresholdBatcher<Batch<RequestT,ResponseT>> | |
Except as otherwise noted, the content of this page is licensed under theCreative Commons Attribution 4.0 License, and code samples are licensed under theApache 2.0 License. For details, see theGoogle Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-12-17 UTC.