Interface ExternalSplit
- All Superinterfaces:
NamedWriteable,Writeable
- All Known Implementing Classes:
CoalescedSplit,FileSplit
A serializable, parallelizable unit of work for an external data source.
Each split represents a portion of data (e.g., a file slice, a partition)
that can be read independently by a single driver and shipped across nodes.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V> -
Method Summary
Modifier and TypeMethodDescriptiondefault longdefault SplitStatsReturns per-split statistics for use by the optimizer (aggregate pushdown, filter pruning).Methods inherited from interface org.elasticsearch.common.io.stream.NamedWriteable
getWriteableName
-
Method Details
-
sourceType
String sourceType() -
estimatedSizeInBytes
default long estimatedSizeInBytes() -
splitStats
Returns per-split statistics for use by the optimizer (aggregate pushdown, filter pruning). Returnsnullif statistics are unavailable for this split.Implementations that carry row-group or stripe metadata should override this method.
FileSplitreturns its compactSplitStatswhen present.CoalescedSplitreturns aMergedSplitStatsthat lazily aggregates its children's statistics.
-