File tree Expand file tree Collapse file tree 3 files changed +6
-5
lines changed
main/java/org/elasticsearch/xpack/esql/inference
test/java/org/elasticsearch/xpack/esql/inference Expand file tree Collapse file tree 3 files changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -79,6 +79,7 @@ protected BulkInferenceRequestIterator requests(Page inputPage) {
7979 return new BulkInferenceRequestIterator () {
8080 private int currentPos = 0 ;
8181 BytesRef readBuffer = new BytesRef ();
82+
8283 @ Override
8384 public boolean hasNext () {
8485 return currentPos < promptBlock .getPositionCount ();
@@ -113,7 +114,7 @@ public void close() {
113114 } catch (Exception e ) {
114115 promptBlock .allowPassingToDifferentDriver ();
115116 Releasables .closeExpectNoException (promptBlock );
116- throw (e );
117+ throw (e );
117118 }
118119 }
119120
@@ -168,7 +169,7 @@ public Page buildOutput() {
168169 } catch (Exception e ) {
169170 releasePageOnAnyThread (inputPage );
170171 Releasables .closeExpectNoException (outputBlockBuilder );
171- throw (e );
172+ throw (e );
172173 }
173174 }
174175
Original file line number Diff line number Diff line change @@ -136,7 +136,7 @@ public void close() {
136136 } catch (Exception e ) {
137137 inputBlock .allowPassingToDifferentDriver ();
138138 Releasables .closeExpectNoException (inputBlock );
139- throw (e );
139+ throw (e );
140140 }
141141 }
142142
@@ -189,7 +189,7 @@ public void onInferenceResults(RankedDocsResults results) {
189189 } catch (Exception e ) {
190190 releasePageOnAnyThread (inputPage );
191191 Releasables .closeExpectNoException (scoreBlockBuilder );
192- throw (e );
192+ throw (e );
193193 }
194194 }
195195
Original file line number Diff line number Diff line change @@ -123,7 +123,7 @@ protected RankedDocsResults mockInferenceResult(InferenceAction.Request request)
123123 }
124124
125125 private float score (int rank ) {
126- return 1f / (rank % 20 );
126+ return 1f / (rank % 20 );
127127 }
128128
129129 private ColumnInfoImpl columnInfo (int channel ) {
You can’t perform that action at this time.
0 commit comments