public class BackPressureRequestCoordinator extends Object
Constructor and Description |
---|
BackPressureRequestCoordinator(Executor executor,
long requestTimeout)
Creates a new coordinator for the cluster.
|
public BackPressureRequestCoordinator(Executor executor, long requestTimeout)
executor
- Used to execute the futures.requestTimeout
- Request time out of a triggered back pressure request.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.