- 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
interface
BatchResource
Represent the resource used by a batch including element and byte. It can also be extended to other things to determine if adding a new element needs to be flow controlled or if the current batch needs to be flushed.
Methods
add(BatchResource resource)
public
abstract
BatchResource
add
(
BatchResource
resource
)
Adds the additional resource.
getByteCount()
public
abstract
long
getByteCount
()
Returns the byte count of this resource.
getElementCount()
public
abstract
long
getElementCount
()
Returns the element count of this resource.
shouldFlush(long maxElementThreshold, long maxBytesThreshold)
public
abstract
boolean
shouldFlush
(
long
maxElementThreshold
,
long
maxBytesThreshold
)
Checks if the current BatchResource should be flushed based on the maxElementThreshold and maxBytesThreshold.
