Skip to content

Commit 5ee2382

Browse files
committed
Remove overengineered type param on the InferenceOperator.OutputBuilder
1 parent 6fc5f99 commit 5ee2382

File tree

4 files changed

+8
-9
lines changed

4 files changed

+8
-9
lines changed

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

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
package org.elasticsearch.xpack.esql.inference;
99

1010
import org.elasticsearch.action.ActionListener;
11-
import org.elasticsearch.compute.data.Block;
1211
import org.elasticsearch.compute.data.BlockFactory;
1312
import org.elasticsearch.compute.data.Page;
1413
import org.elasticsearch.compute.operator.AsyncOperator;
@@ -103,7 +102,7 @@ public Page getOutput() {
103102
return null;
104103
}
105104

106-
try (OutputBuilder<Page> outputBuilder = outputBuilder(ongoingInferenceResult.inputPage)) {
105+
try (OutputBuilder outputBuilder = outputBuilder(ongoingInferenceResult.inputPage)) {
107106
for (InferenceAction.Response response : ongoingInferenceResult.responses) {
108107
outputBuilder.addInferenceResponse(response);
109108
}
@@ -126,12 +125,12 @@ public Page getOutput() {
126125
*
127126
* @param input The corresponding input page used to generate the inference requests.
128127
*/
129-
protected abstract OutputBuilder<Page> outputBuilder(Page input);
128+
protected abstract OutputBuilder outputBuilder(Page input);
130129

131130
/**
132-
* An interface for accumulating inference responses and constructing a result (can be a {@link Page} or a {@link Block}).
131+
* An interface for accumulating inference responses and constructing the result page..
133132
*/
134-
public interface OutputBuilder<T> extends Releasable {
133+
public interface OutputBuilder extends Releasable {
135134

136135
/**
137136
* Adds an inference response to the output.
@@ -149,7 +148,7 @@ public interface OutputBuilder<T> extends Releasable {
149148
*
150149
* @return The constructed output block.
151150
*/
152-
T buildOutput();
151+
Page buildOutput();
153152

154153
static <IR extends InferenceServiceResults> IR inferenceResults(InferenceAction.Response inferenceResponse, Class<IR> clazz) {
155154
InferenceServiceResults results = inferenceResponse.getResults();

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/inference/completion/CompletionOperatorOutputBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
* {@link CompletionOperatorOutputBuilder} builds the output page for {@link CompletionOperator} by converting {@link ChatCompletionResults}
2121
* into a {@link BytesRefBlock}.
2222
*/
23-
public class CompletionOperatorOutputBuilder implements InferenceOperator.OutputBuilder<Page> {
23+
public class CompletionOperatorOutputBuilder implements InferenceOperator.OutputBuilder {
2424
private final Page inputPage;
2525
private final BytesRefBlock.Builder outputBlockBuilder;
2626
private final BytesRefBuilder bytesRefBuilder = new BytesRefBuilder();

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/inference/rerank/RerankOperatorOutputBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
* * reranked relevance scores into the specified score channel of the input page.
2525
*/
2626

27-
public class RerankOperatorOutputBuilder implements InferenceOperator.OutputBuilder<Page> {
27+
public class RerankOperatorOutputBuilder implements InferenceOperator.OutputBuilder {
2828

2929
private final Page inputPage;
3030
private final DoubleBlock.Builder scoreBlockBuilder;

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/inference/textembedding/TextEmbeddingOperatorOutputBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
* {@link TextEmbeddingOperatorOutputBuilder} builds the output page for text embedding by converting
2222
* {@link TextEmbeddingResults} into a {@link FloatBlock} containing dense vector embeddings.
2323
*/
24-
public class TextEmbeddingOperatorOutputBuilder implements InferenceOperator.OutputBuilder<Page> {
24+
public class TextEmbeddingOperatorOutputBuilder implements InferenceOperator.OutputBuilder {
2525
private final Page inputPage;
2626
private final FloatBlock.Builder outputBlockBuilder;
2727

0 commit comments

Comments
 (0)