Interface BatchResource (2.35.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
NameDescription
resourceBatchResource
Returns
TypeDescription
BatchResource

getByteCount()

public abstract long getByteCount()

Returns the byte count of this resource.

Returns
TypeDescription
long

getElementCount()

public abstract long getElementCount()

Returns the element count of this resource.

Returns
TypeDescription
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
NameDescription
maxElementThresholdlong
maxBytesThresholdlong
Returns
TypeDescription
boolean