Package org.elasticsearch.xpack.esql.planner

Class EsPhysicalOperationProviders.DefaultShardContext

java.lang.Object

org.elasticsearch.xpack.esql.planner.EsPhysicalOperationProviders.ShardContext

org.elasticsearch.xpack.esql.planner.EsPhysicalOperationProviders.DefaultShardContext

All Implemented Interfaces:

Closeable, AutoCloseable, ShardContext, RefCounted, Releasable

Enclosing class:

EsPhysicalOperationProviders

public static class EsPhysicalOperationProviders.DefaultShardContext
extends EsPhysicalOperationProviders.ShardContext

Field Summary

Fields inherited from interface org.elasticsearch.core.RefCounted

ALWAYS_REFERENCED

Constructor Summary

Constructors

Constructor	Description
DefaultShardContext(int index, Releasable releasable, SearchExecutionContext ctx, AliasFilter aliasFilter)

Method Summary

Modifier and Type	Method	Description
BlockLoader	blockLoader(String name, boolean asUnsupportedSource, MappedFieldType.FieldExtractPreference fieldExtractPreference, BlockLoaderFunctionConfig blockLoaderFunctionConfig, Warnings warnings, ByteSizeValue blockLoaderSizeOrdinals, ByteSizeValue blockLoaderSizeScript)
Optional<SortAndFormats>	buildSort(List<SortBuilder<?>> sorts)
void	close()
MappedFieldType	fieldType(String name)
int	index()
IndexSettings	indexSettings()
MappingLookup	mappingLookup()
SourceLoader	newSourceLoader(Set<String> sourcePaths)
org.apache.lucene.search.IndexSearcher	searcher()
String	shardIdentifier()
ShardSearchStats	stats()
double	storedFieldsSequentialProportion()	Tuning parameter for deciding when to use the "merge" stored field loader.
org.apache.lucene.search.Query	toQuery(QueryBuilder queryBuilder)	Convert a QueryBuilder into a real lucene query.

Methods inherited from class org.elasticsearch.xpack.esql.planner.EsPhysicalOperationProviders.ShardContext

decRef, hasReferences, incRef, tryIncRef

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.core.RefCounted

mustIncRef

Constructor Details

DefaultShardContext

public DefaultShardContext(int index,
 Releasable releasable,
 SearchExecutionContext ctx,
 AliasFilter aliasFilter)

Method Details

index

public int index()

searcher

public org.apache.lucene.search.IndexSearcher searcher()

buildSort

public Optional<SortAndFormats> buildSort(List<SortBuilder<?>> sorts)
                                   throws IOException

Throws:

IOException

shardIdentifier

public String shardIdentifier()

newSourceLoader

public SourceLoader newSourceLoader(Set<String> sourcePaths)

toQuery

public org.apache.lucene.search.Query toQuery(QueryBuilder queryBuilder)

Description copied from class: EsPhysicalOperationProviders.ShardContext

Convert a QueryBuilder into a real lucene query.

Specified by:

toQuery in class EsPhysicalOperationProviders.ShardContext

indexSettings

public IndexSettings indexSettings()

Specified by:

indexSettings in class EsPhysicalOperationProviders.ShardContext

mappingLookup

public MappingLookup mappingLookup()

Specified by:

mappingLookup in class EsPhysicalOperationProviders.ShardContext

blockLoader

public BlockLoader blockLoader(String name,
 boolean asUnsupportedSource,
 MappedFieldType.FieldExtractPreference fieldExtractPreference,
 BlockLoaderFunctionConfig blockLoaderFunctionConfig,
 Warnings warnings,
 ByteSizeValue blockLoaderSizeOrdinals,
 ByteSizeValue blockLoaderSizeScript)

fieldType

@Nullable
public MappedFieldType fieldType(String name)

stats

public ShardSearchStats stats()

storedFieldsSequentialProportion

public double storedFieldsSequentialProportion()

Description copied from class: EsPhysicalOperationProviders.ShardContext

Tuning parameter for deciding when to use the "merge" stored field loader. Think of it as "how similar to a sequential block of documents do I have to be before I'll use the merge reader?" So a value of 1 means I have to be exactly a sequential block, like 0, 1, 2, 3, .. 1299, 1300. A value of .2 means we'll use the sequential reader even if we only need one in ten documents.

Specified by:

storedFieldsSequentialProportion in class EsPhysicalOperationProviders.ShardContext

close

public void close()