Package org.elasticsearch.xpack.esql.datasources

Class FileSplit

java.lang.Object

org.elasticsearch.xpack.esql.datasources.FileSplit

All Implemented Interfaces:

NamedWriteable, Writeable, ExternalSplit

public class FileSplit
extends Object
implements ExternalSplit

Represents a byte range within a file for a file-based external source. A single file may map to one or more splits. Carries Hive partition key-value pairs extracted from the file path for partition pruning.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields

Modifier and Type	Field	Description
static final NamedWriteableRegistry.Entry	ENTRY

Constructor Summary

Constructors

Constructor	Description
FileSplit(String sourceType, StoragePath path, long offset, long length, String format, Map<String,Object> config, Map<String,Object> partitionValues)
FileSplit(String sourceType, StoragePath path, long offset, long length, String format, Map<String,Object> config, Map<String,Object> partitionValues, SchemaReconciliation.ColumnMapping columnMapping)
FileSplit(String sourceType, StoragePath path, long offset, long length, String format, Map<String,Object> config, Map<String,Object> partitionValues, SchemaReconciliation.ColumnMapping columnMapping, Map<String,Object> statistics)
FileSplit(StreamInput in)

Method Summary

Modifier and Type	Method	Description
SchemaReconciliation.ColumnMapping	columnMapping()
Map<String,Object>	config()
boolean	equals(Object o)
long	estimatedSizeInBytes()
String	format()
String	getWriteableName()
int	hashCode()
long	length()
long	offset()
Map<String,Object>	partitionValues()
StoragePath	path()
String	sourceType()
Map<String,Object>	statistics()
String	toString()
void	writeTo(StreamOutput out)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

ENTRY

public static final NamedWriteableRegistry.Entry ENTRY

Constructor Details

FileSplit

public FileSplit(String sourceType,
 StoragePath path,
 long offset,
 long length,
 String format,
 Map<String,Object> config,
 Map<String,Object> partitionValues)

FileSplit

public FileSplit(String sourceType,
 StoragePath path,
 long offset,
 long length,
 String format,
 Map<String,Object> config,
 Map<String,Object> partitionValues,
 @Nullable
 SchemaReconciliation.ColumnMapping columnMapping)

FileSplit

public FileSplit(String sourceType,
 StoragePath path,
 long offset,
 long length,
 String format,
 Map<String,Object> config,
 Map<String,Object> partitionValues,
 @Nullable
 SchemaReconciliation.ColumnMapping columnMapping,
 @Nullable
 Map<String,Object> statistics)

FileSplit

public FileSplit(StreamInput in)
          throws IOException

Throws:

IOException

Method Details

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Writeable

Throws:

IOException

getWriteableName

public String getWriteableName()

Specified by:

getWriteableName in interface NamedWriteable

sourceType

public String sourceType()

Specified by:

sourceType in interface ExternalSplit

path

public StoragePath path()

offset

public long offset()

length

public long length()

format

public String format()

config

public Map<String,Object> config()

partitionValues

public Map<String,Object> partitionValues()

columnMapping

@Nullable
public SchemaReconciliation.ColumnMapping columnMapping()

statistics

@Nullable
public Map<String,Object> statistics()

estimatedSizeInBytes

public long estimatedSizeInBytes()

Specified by:

estimatedSizeInBytes in interface ExternalSplit

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object