Package org.elasticsearch.xpack.esql.planner

Class LocalExecutionPlanner.PhysicalOperation

java.lang.Object

org.elasticsearch.xpack.esql.planner.LocalExecutionPlanner.PhysicalOperation

Enclosing class:

LocalExecutionPlanner

public static class LocalExecutionPlanner.PhysicalOperation
extends Object

Immutable physical operation.

Method Summary

Modifier and Type	Method	Description
static LocalExecutionPlanner.PhysicalOperation	fromSource(SourceOperator.SourceOperatorFactory sourceOperatorFactory, Layout layout)	Creates a new physical operation with the given source and layout.
Layout	layout()
Supplier<String>	longDescription()
void	operators(List<Operator> operators, DriverContext driverContext)
SinkOperator	sink(DriverContext driverContext)
SourceOperator	source(DriverContext driverContext)
String	toString()
LocalExecutionPlanner.PhysicalOperation	with(Operator.OperatorFactory operatorFactory, Layout layout)	Creates a new physical operation from this operation with the given intermediate operator and layout.
LocalExecutionPlanner.PhysicalOperation	with(Layout layout)	Creates a new physical operation from this operation with the given layout.
LocalExecutionPlanner.PhysicalOperation	withSink(SinkOperator.SinkOperatorFactory sink, Layout layout)	Creates a new physical operation from this operation with the given sink and layout.

Methods inherited from class java.lang.Object

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

Method Details

fromSource

public static LocalExecutionPlanner.PhysicalOperation fromSource(SourceOperator.SourceOperatorFactory sourceOperatorFactory,
 Layout layout)

Creates a new physical operation with the given source and layout.

with

public LocalExecutionPlanner.PhysicalOperation with(Layout layout)

Creates a new physical operation from this operation with the given layout.

with

public LocalExecutionPlanner.PhysicalOperation with(Operator.OperatorFactory operatorFactory,
 Layout layout)

Creates a new physical operation from this operation with the given intermediate operator and layout.

withSink

public LocalExecutionPlanner.PhysicalOperation withSink(SinkOperator.SinkOperatorFactory sink,
 Layout layout)

Creates a new physical operation from this operation with the given sink and layout.

source

public SourceOperator source(DriverContext driverContext)

operators

public void operators(List<Operator> operators,
 DriverContext driverContext)

sink

public SinkOperator sink(DriverContext driverContext)

layout

public Layout layout()

longDescription

public Supplier<String> longDescription()

toString

public String toString()

Overrides:

toString in class Object