Package org.elasticsearch.xpack.esql.datasources

Class HivePartitionDetector

java.lang.Object

org.elasticsearch.xpack.esql.datasources.HivePartitionDetector

All Implemented Interfaces:

PartitionDetector

public final class HivePartitionDetector
extends Object
implements PartitionDetector

Detects Hive-style partition columns from file paths (e.g., /year=2024/month=06/file.parquet). Parses key=value segments, validates consistency across all files, and infers types using Spark-style rules: try Integer, Long, Double, Boolean, fallback to keyword.

Field Summary

Fields

Modifier and Type	Field	Description
static final HivePartitionDetector	INSTANCE

Method Summary

Modifier and Type	Method	Description
PartitionMetadata	detect(List<StorageEntry> files, Map<String,Object> config)
String	name()

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final HivePartitionDetector INSTANCE

Method Details

name

public String name()

Specified by:

name in interface PartitionDetector

detect

public PartitionMetadata detect(List<StorageEntry> files,
 Map<String,Object> config)

Specified by:

detect in interface PartitionDetector