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
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`