Package org.elasticsearch.xpack.esql.datasource.ndjson

Class NdJsonSchemaInferrer

java.lang.Object

org.elasticsearch.xpack.esql.datasource.ndjson.NdJsonSchemaInferrer

public class NdJsonSchemaInferrer
extends Object

Infers schema from NDJSON files by reading the first N lines. - Flattens nested objects using dot notation - Detects arrays as multi-value fields - Marks fields as nullable when null or missing values are encountered Types: KEYWORD, INTEGER, LONG, DOUBLE, BOOLEAN, DATETIME.

Field Summary

Fields

Modifier and Type	Field	Description
static final DateFormatter	DATE_FORMATTER

Method Summary

Modifier and Type	Method	Description
static Attribute	attribute(String name, DataType type, boolean nullable)
static List<Attribute>	inferSchema(InputStream inputStream, int maxLines)	Infers schema from an NDJSON input stream, reading up to maxLines.

Methods inherited from class java.lang.Object

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

Field Details

DATE_FORMATTER

public static final DateFormatter DATE_FORMATTER

Method Details

inferSchema

public static List<Attribute> inferSchema(InputStream inputStream,
 int maxLines)
                                   throws IOException

Infers schema from an NDJSON input stream, reading up to maxLines.

Throws:

IOException

attribute

public static Attribute attribute(String name,
 DataType type,
 boolean nullable)