Package org.elasticsearch.xpack.esql.datasources.spi

Class SourceOperatorContext.Builder

java.lang.Object

org.elasticsearch.xpack.esql.datasources.spi.SourceOperatorContext.Builder

Enclosing class:

SourceOperatorContext

public static class SourceOperatorContext.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
SourceOperatorContext.Builder	attributes(List<Attribute> attributes)
SourceOperatorContext.Builder	batchSize(int batchSize)
SourceOperatorContext	build()
SourceOperatorContext.Builder	config(Map<String,Object> config)
SourceOperatorContext.Builder	executor(Executor executor)
SourceOperatorContext.Builder	fileList(FileList fileList)
SourceOperatorContext.Builder	maxBufferSize(int maxBufferSize)
SourceOperatorContext.Builder	parsingParallelism(int parsingParallelism)
SourceOperatorContext.Builder	partitionColumnNames(Set<String> partitionColumnNames)
SourceOperatorContext.Builder	path(StoragePath path)
SourceOperatorContext.Builder	projectedColumns(List<String> projectedColumns)
SourceOperatorContext.Builder	pushedExpressions(List<Expression> pushedExpressions)
SourceOperatorContext.Builder	pushedFilter(Object pushedFilter)
SourceOperatorContext.Builder	rowLimit(int rowLimit)
SourceOperatorContext.Builder	sliceQueue(ExternalSliceQueue sliceQueue)
SourceOperatorContext.Builder	sourceMetadata(Map<String,Object> sourceMetadata)
SourceOperatorContext.Builder	sourceType(String sourceType)
SourceOperatorContext.Builder	split(ExternalSplit split)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

sourceType

public SourceOperatorContext.Builder sourceType(String sourceType)

path

public SourceOperatorContext.Builder path(StoragePath path)

projectedColumns

public SourceOperatorContext.Builder projectedColumns(List<String> projectedColumns)

attributes

public SourceOperatorContext.Builder attributes(List<Attribute> attributes)

batchSize

public SourceOperatorContext.Builder batchSize(int batchSize)

maxBufferSize

public SourceOperatorContext.Builder maxBufferSize(int maxBufferSize)

rowLimit

public SourceOperatorContext.Builder rowLimit(int rowLimit)

executor

public SourceOperatorContext.Builder executor(Executor executor)

config

public SourceOperatorContext.Builder config(Map<String,Object> config)

sourceMetadata

public SourceOperatorContext.Builder sourceMetadata(Map<String,Object> sourceMetadata)

pushedFilter

public SourceOperatorContext.Builder pushedFilter(Object pushedFilter)

pushedExpressions

public SourceOperatorContext.Builder pushedExpressions(List<Expression> pushedExpressions)

fileList

public SourceOperatorContext.Builder fileList(FileList fileList)

split

public SourceOperatorContext.Builder split(ExternalSplit split)

partitionColumnNames

public SourceOperatorContext.Builder partitionColumnNames(Set<String> partitionColumnNames)

sliceQueue

public SourceOperatorContext.Builder sliceQueue(ExternalSliceQueue sliceQueue)

parsingParallelism

public SourceOperatorContext.Builder parsingParallelism(int parsingParallelism)

build

public SourceOperatorContext build()