Package org.elasticsearch.xpack.esql.datasources

Class SplitCoalescer

java.lang.Object

org.elasticsearch.xpack.esql.datasources.SplitCoalescer

public final class SplitCoalescer
extends Object

Groups many small ExternalSplits into CoalescedSplits to reduce scheduling overhead. Uses greedy bin-packing by size when all splits report a positive estimatedSizeInBytes(), and falls back to count-based grouping otherwise.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	COALESCING_THRESHOLD
static final int	DEFAULT_TARGET_GROUP_COUNT
static final long	DEFAULT_TARGET_GROUP_SIZE_BYTES

Method Summary

Modifier and Type	Method	Description
static List<ExternalSplit>	coalesce(List<ExternalSplit> splits)
static List<ExternalSplit>	coalesce(List<ExternalSplit> splits, long targetGroupSizeBytes, int targetGroupCount)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_TARGET_GROUP_SIZE_BYTES

public static final long DEFAULT_TARGET_GROUP_SIZE_BYTES

See Also:

• Constant Field Values

DEFAULT_TARGET_GROUP_COUNT

public static final int DEFAULT_TARGET_GROUP_COUNT

See Also:

• Constant Field Values

COALESCING_THRESHOLD

public static final int COALESCING_THRESHOLD

See Also:

• Constant Field Values

Method Details

coalesce

public static List<ExternalSplit> coalesce(List<ExternalSplit> splits)

coalesce

public static List<ExternalSplit> coalesce(List<ExternalSplit> splits,
 long targetGroupSizeBytes,
 int targetGroupCount)