2424import static org .elasticsearch .TransportVersions .ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED ;
2525import static org .elasticsearch .TransportVersions .ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED_8_19 ;
2626import 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 ;
2729
2830public class ValuesSourceReaderOperatorStatus extends AbstractPageMappingToIteratorOperator .Status {
2931 public static final NamedWriteableRegistry .Entry ENTRY = new NamedWriteableRegistry .Entry (
@@ -55,7 +57,7 @@ static ValuesSourceReaderOperatorStatus readFrom(StreamInput in) throws IOExcept
5557 int pagesEmitted ;
5658 long rowsReceived ;
5759 long rowsEmitted ;
58- if (in .getTransportVersion (). onOrAfter ( ESQL_SPLIT_ON_BIG_VALUES )) {
60+ if (supportsSplitOnBigValues ( in .getTransportVersion ())) {
5961 AbstractPageMappingToIteratorOperator .Status status = new AbstractPageMappingToIteratorOperator .Status (in );
6062 processNanos = status .processNanos ();
6163 pagesReceived = status .pagesReceived ();
@@ -85,7 +87,7 @@ static ValuesSourceReaderOperatorStatus readFrom(StreamInput in) throws IOExcept
8587
8688 @ Override
8789 public void writeTo (StreamOutput out ) throws IOException {
88- if (out .getTransportVersion (). onOrAfter ( ESQL_SPLIT_ON_BIG_VALUES )) {
90+ if (supportsSplitOnBigValues ( out .getTransportVersion ())) {
8991 super .writeTo (out );
9092 } else {
9193 /*
@@ -101,6 +103,12 @@ public void writeTo(StreamOutput out) throws IOException {
101103 }
102104 }
103105
106+ private static boolean supportsSplitOnBigValues (TransportVersion version ) {
107+ return version .onOrAfter (ESQL_SPLIT_ON_BIG_VALUES )
108+ || version .isPatchFrom (ESQL_SPLIT_ON_BIG_VALUES_9_1 )
109+ || version .isPatchFrom (ESQL_SPLIT_ON_BIG_VALUES_8_19 );
110+ }
111+
104112 private static boolean supportsValuesLoaded (TransportVersion version ) {
105113 return version .onOrAfter (ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED )
106114 || version .isPatchFrom (ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED_8_19 );
0 commit comments