- 2.70.0 (latest)
- 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
public
final
class
BatcherFactory<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)
public
BatcherFactory
(
BatchingDescriptor<RequestT
,
ResponseT
>
batchingDescriptor
,
BatchingSettings
batchingSettings
,
ScheduledExecutorService
executor
,
FlowController
flowController
)
Parameters
Name
Description
batchingDescriptor
BatchingDescriptor
< RequestT
, ResponseT
>
batchingSettings
executor
flowController
Methods
getBatchingSettings()
public
BatchingSettings
getBatchingSettings
()
Returns the BatchingSettings object that is associated with this factory.
This is public only for technical reasons, for advanced usage.
getPushingBatcher(PartitionKey partitionKey)
public
ThresholdBatcher<Batch<RequestT
,
ResponseT
>>
getPushingBatcher
(
PartitionKey
partitionKey
)
Provides the ThresholdBatcher corresponding to the given partitionKey, or constructs one if it doesn't exist yet. The implementation is thread-safe.
