File tree Expand file tree Collapse file tree 3 files changed +4
-9
lines changed
resources/transport/definitions/referable
x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/lucene/read Expand file tree Collapse file tree 3 files changed +4
-9
lines changed Original file line number Diff line number Diff line change @@ -199,7 +199,6 @@ static TransportVersion def(int id) {
199
199
public static final TransportVersion ML_INFERENCE_COHERE_API_VERSION_8_19 = def (8_841_0_60 );
200
200
public static final TransportVersion ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED_8_19 = def (8_841_0_61 );
201
201
public static final TransportVersion ESQL_PROFILE_INCLUDE_PLAN_8_19 = def (8_841_0_62 );
202
- public static final TransportVersion ESQL_SPLIT_ON_BIG_VALUES_8_19 = def (8_841_0_63 );
203
202
public static final TransportVersion INITIAL_ELASTICSEARCH_8_19_4 = def (8_841_0_68 );
204
203
public static final TransportVersion INITIAL_ELASTICSEARCH_9_0 = def (9_000_0_00 );
205
204
public static final TransportVersion REMOVE_SNAPSHOT_FAILURES_90 = def (9_000_0_01 );
@@ -323,11 +322,9 @@ static TransportVersion def(int id) {
323
322
public static final TransportVersion ML_INFERENCE_COHERE_API_VERSION = def (9_110_0_00 );
324
323
public static final TransportVersion ESQL_PROFILE_INCLUDE_PLAN = def (9_111_0_00 );
325
324
public static final TransportVersion MAPPINGS_IN_DATA_STREAMS = def (9_112_0_00 );
326
- public static final TransportVersion ESQL_SPLIT_ON_BIG_VALUES_9_1 = def (9_112_0_01 );
327
325
public static final TransportVersion PROJECT_STATE_REGISTRY_RECORDS_DELETIONS = def (9_113_0_00 );
328
326
public static final TransportVersion ESQL_SERIALIZE_TIMESERIES_FIELD_TYPE = def (9_114_0_00 );
329
327
public static final TransportVersion ML_INFERENCE_IBM_WATSONX_COMPLETION_ADDED = def (9_115_0_00 );
330
- public static final TransportVersion ESQL_SPLIT_ON_BIG_VALUES = def (9_116_0_00 );
331
328
public static final TransportVersion INFERENCE_API_EIS_DIAGNOSTICS = def (9_156_0_00 );
332
329
public static final TransportVersion ML_INFERENCE_ENDPOINT_CACHE = def (9_157_0_00 );
333
330
Original file line number Diff line number Diff line change
1
+ 9116000,9112001,8841063
Original file line number Diff line number Diff line change 23
23
24
24
import static org .elasticsearch .TransportVersions .ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED ;
25
25
import static org .elasticsearch .TransportVersions .ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED_8_19 ;
26
- import static org .elasticsearch .TransportVersions .ESQL_SPLIT_ON_BIG_VALUES ;
27
- import static org .elasticsearch .TransportVersions .ESQL_SPLIT_ON_BIG_VALUES_8_19 ;
28
- import static org .elasticsearch .TransportVersions .ESQL_SPLIT_ON_BIG_VALUES_9_1 ;
29
26
30
27
public class ValuesSourceReaderOperatorStatus extends AbstractPageMappingToIteratorOperator .Status {
31
28
public static final NamedWriteableRegistry .Entry ENTRY = new NamedWriteableRegistry .Entry (
@@ -34,6 +31,8 @@ public class ValuesSourceReaderOperatorStatus extends AbstractPageMappingToItera
34
31
ValuesSourceReaderOperatorStatus ::readFrom
35
32
);
36
33
34
+ private static final TransportVersion ESQL_SPLIT_ON_BIG_VALUES = TransportVersion .fromName ("esql_split_on_big_values" );
35
+
37
36
private final Map <String , Integer > readersBuilt ;
38
37
private final long valuesLoaded ;
39
38
@@ -103,9 +102,7 @@ public void writeTo(StreamOutput out) throws IOException {
103
102
}
104
103
105
104
private static boolean supportsSplitOnBigValues (TransportVersion version ) {
106
- return version .onOrAfter (ESQL_SPLIT_ON_BIG_VALUES )
107
- || version .isPatchFrom (ESQL_SPLIT_ON_BIG_VALUES_9_1 )
108
- || version .isPatchFrom (ESQL_SPLIT_ON_BIG_VALUES_8_19 );
105
+ return version .supports (ESQL_SPLIT_ON_BIG_VALUES );
109
106
}
110
107
111
108
private static boolean supportsValuesLoaded (TransportVersion version ) {
You can’t perform that action at this time.
0 commit comments