Skip to content

Commit d550915

Browse files
committed
ESQL: Added Sample operator NamedWritable to plugin
1 parent d70093b commit d550915

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/SampleOperator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ public Operator.Status status() {
167167
return new Status(collectNanos, emitNanos, pagesProcessed, rowsReceived, rowsEmitted);
168168
}
169169

170-
private record Status(long collectNanos, long emitNanos, int pagesProcessed, int rowsReceived, int rowsEmitted)
170+
public record Status(long collectNanos, long emitNanos, int pagesProcessed, int rowsReceived, int rowsEmitted)
171171
implements
172172
Operator.Status {
173173

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/EsqlPlugin.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
import org.elasticsearch.compute.operator.HashAggregationOperator;
3333
import org.elasticsearch.compute.operator.LimitOperator;
3434
import org.elasticsearch.compute.operator.MvExpandOperator;
35+
import org.elasticsearch.compute.operator.SampleOperator;
3536
import org.elasticsearch.compute.operator.exchange.ExchangeService;
3637
import org.elasticsearch.compute.operator.exchange.ExchangeSinkOperator;
3738
import org.elasticsearch.compute.operator.exchange.ExchangeSourceOperator;
@@ -321,6 +322,7 @@ public List<NamedWriteableRegistry.Entry> getNamedWriteables() {
321322
entries.add(AsyncOperator.Status.ENTRY);
322323
entries.add(EnrichLookupOperator.Status.ENTRY);
323324
entries.add(LookupFromIndexOperator.Status.ENTRY);
325+
entries.add(SampleOperator.Status.ENTRY);
324326
entries.add(ExpressionQueryBuilder.ENTRY);
325327
entries.add(PlanStreamWrapperQueryBuilder.ENTRY);
326328

0 commit comments

Comments
 (0)