Package org.elasticsearch.xpack.esql.datasource.parquet

Class CircuitBreakerByteBufferAllocator

java.lang.Object

org.elasticsearch.xpack.esql.datasource.parquet.CircuitBreakerByteBufferAllocator

All Implemented Interfaces:

org.apache.parquet.bytes.ByteBufferAllocator

public class CircuitBreakerByteBufferAllocator
extends Object
implements org.apache.parquet.bytes.ByteBufferAllocator

A Parquet ByteBufferAllocator that uses a circuit breaker to manage memory usage.

Constructor Summary

Constructors

Constructor	Description
CircuitBreakerByteBufferAllocator(org.apache.parquet.bytes.ByteBufferAllocator delegate, CircuitBreaker breaker)

Method Summary

Modifier and Type	Method	Description
ByteBuffer	allocate(int capacity)
boolean	isDirect()
void	release(ByteBuffer byteBuffer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CircuitBreakerByteBufferAllocator

public CircuitBreakerByteBufferAllocator(org.apache.parquet.bytes.ByteBufferAllocator delegate,
 CircuitBreaker breaker)

Method Details

allocate

public ByteBuffer allocate(int capacity)

Specified by:

allocate in interface org.apache.parquet.bytes.ByteBufferAllocator

release

public void release(ByteBuffer byteBuffer)

Specified by:

release in interface org.apache.parquet.bytes.ByteBufferAllocator

isDirect

public boolean isDirect()

Specified by:

isDirect in interface org.apache.parquet.bytes.ByteBufferAllocator