Interface BatchResource (2.58.0)

Version 2.58.0

• 2.59.0 (latest)
• 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.

Parameter
Name	Description
resource	BatchResource

Returns
Type	Description
BatchResource

getByteCount()

public abstract long getByteCount()

Returns the byte count of this resource.

Returns
Type	Description
long

getElementCount()

public abstract long getElementCount()

Returns the element count of this resource.

Returns
Type	Description
long

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.

Parameters
Name	Description
maxElementThreshold	long
maxBytesThreshold	long

Returns
Type	Description
boolean