Package org.elasticsearch.xpack.esql.datasources

Class ExternalSliceQueue

java.lang.Object

org.elasticsearch.xpack.esql.datasources.ExternalSliceQueue

public final class ExternalSliceQueue
extends Object

Thread-safe queue of ExternalSplit instances for parallel external source execution. Analogous to LuceneSliceQueue but simpler: splits are claimed sequentially via nextSplit() until exhausted.

Constructor Summary

Constructors

Constructor	Description
ExternalSliceQueue(List<ExternalSplit> splits)

Method Summary

Modifier and Type	Method	Description
ExternalSplit	nextSplit()
int	totalSlices()

Methods inherited from class java.lang.Object

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

Constructor Details

ExternalSliceQueue

public ExternalSliceQueue(List<ExternalSplit> splits)

Method Details

nextSplit

@Nullable
public ExternalSplit nextSplit()

totalSlices

public int totalSlices()