Skip to content

Commit 2387d14

Browse files
committed
Lint.
1 parent 20773db commit 2387d14

File tree

4 files changed

+14
-5
lines changed

4 files changed

+14
-5
lines changed

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

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ public void addInput(Page input) {
5656
super.addInput(input.appendBlock(promptEvaluator.eval(input)));
5757
} catch (Exception e) {
5858
releasePageOnAnyThread(input);
59-
throw(e);
59+
throw (e);
6060
}
6161
}
6262

@@ -79,7 +79,10 @@ protected BulkInferenceRequestIterator requests(Page inputPage) {
7979
@Override
8080
protected CompletionOperatorOutputBuilder outputBuilder(Page input) {
8181
BytesRefBlock.Builder outputBlockBuilder = blockFactory().newBytesRefBlockBuilder(input.getPositionCount());
82-
return new CompletionOperatorOutputBuilder(outputBlockBuilder, input.projectBlocks(IntStream.range(0, input.getBlockCount() - 1).toArray()));
82+
return new CompletionOperatorOutputBuilder(
83+
outputBlockBuilder,
84+
input.projectBlocks(IntStream.range(0, input.getBlockCount() - 1).toArray())
85+
);
8386
}
8487

8588
/**

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ public void addInput(Page input) {
5757
super.addInput(input.appendBlock(rowEncoder.eval(input)));
5858
} catch (Exception e) {
5959
releasePageOnAnyThread(input);
60-
throw(e);
60+
throw (e);
6161
}
6262
}
6363

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,10 @@ public Page buildOutput() {
7979
*/
8080
@Override
8181
public void addInferenceResponse(InferenceAction.Response inferenceResponse) {
82-
Iterator<RankedDocsResults.RankedDoc> sortedRankedDocIterator = inferenceResults(inferenceResponse).getRankedDocs().stream().sorted(Comparator.comparingInt(RankedDocsResults.RankedDoc::index)).iterator();
82+
Iterator<RankedDocsResults.RankedDoc> sortedRankedDocIterator = inferenceResults(inferenceResponse).getRankedDocs()
83+
.stream()
84+
.sorted(Comparator.comparingInt(RankedDocsResults.RankedDoc::index))
85+
.iterator();
8386
while (sortedRankedDocIterator.hasNext()) {
8487
scoreBlockBuilder.appendDouble(sortedRankedDocIterator.next().relevanceScore());
8588
}

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/inference/completion/CompletionOperatorRequestIteratorTests.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,10 @@ public void testIterateLargeInput() {
2727
private void assertIterate(int size) {
2828
final String inferenceId = randomIdentifier();
2929

30-
try (BytesRefBlock inputBlock = randomInputBlock(size); CompletionOperatorRequestIterator requestIterator = new CompletionOperatorRequestIterator(inputBlock, inferenceId)) {
30+
try (
31+
BytesRefBlock inputBlock = randomInputBlock(size);
32+
CompletionOperatorRequestIterator requestIterator = new CompletionOperatorRequestIterator(inputBlock, inferenceId)
33+
) {
3134
BytesRef scratch = new BytesRef();
3235

3336
for (int currentPos = 0; requestIterator.hasNext(); currentPos++) {

0 commit comments

Comments
 (0)