Package org.elasticsearch.xpack.esql.datasources

Class ExternalSourceDrainUtils

java.lang.Object

org.elasticsearch.xpack.esql.datasources.ExternalSourceDrainUtils

public final class ExternalSourceDrainUtils
extends Object

Utility for draining pages from a CloseableIterator into an AsyncExternalSourceBuffer with backpressure. Uses blocking wait instead of spin-wait, relying on the buffer's notifyNotFull() in finish() to wake producers when no more input is needed.

Method Summary

Modifier and Type	Method	Description
static void	drainPages(CloseableIterator<Page> pages, AsyncExternalSourceBuffer buffer)
static void	drainPages(CloseableIterator<Page> pages, AsyncExternalSourceBuffer buffer, org.elasticsearch.core.TimeValue timeout)
static int	drainPagesWithBudget(CloseableIterator<Page> pages, AsyncExternalSourceBuffer buffer)
static int	drainPagesWithBudget(CloseableIterator<Page> pages, AsyncExternalSourceBuffer buffer, int rowLimit)
static int	drainPagesWithBudget(CloseableIterator<Page> pages, AsyncExternalSourceBuffer buffer, int rowLimit, org.elasticsearch.core.TimeValue timeout)

Methods inherited from class java.lang.Object

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

Method Details

drainPages

public static void drainPages(CloseableIterator<Page> pages,
 AsyncExternalSourceBuffer buffer)

drainPages

public static void drainPages(CloseableIterator<Page> pages,
 AsyncExternalSourceBuffer buffer,
 org.elasticsearch.core.TimeValue timeout)

drainPagesWithBudget

public static int drainPagesWithBudget(CloseableIterator<Page> pages,
 AsyncExternalSourceBuffer buffer)

drainPagesWithBudget

public static int drainPagesWithBudget(CloseableIterator<Page> pages,
 AsyncExternalSourceBuffer buffer,
 int rowLimit)

drainPagesWithBudget

public static int drainPagesWithBudget(CloseableIterator<Page> pages,
 AsyncExternalSourceBuffer buffer,
 int rowLimit,
 org.elasticsearch.core.TimeValue timeout)