Interface BatchResource (2.51.0) 

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