File tree 4 files changed +6
-6
lines changed
main/java/org/opensearch/action
test/java/org/opensearch/action/admin/cluster/shards
4 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ public CatShardsRequest() {}
37
37
38
38
public CatShardsRequest (StreamInput in ) throws IOException {
39
39
super (in );
40
- if (in .getVersion ().onOrAfter (Version .V_3_0_0 )) {
40
+ if (in .getVersion ().onOrAfter (Version .V_2_18_0 )) {
41
41
indices = in .readStringArray ();
42
42
cancelAfterTimeInterval = in .readOptionalTimeValue ();
43
43
if (in .readBoolean ()) {
@@ -50,7 +50,7 @@ public CatShardsRequest(StreamInput in) throws IOException {
50
50
@ Override
51
51
public void writeTo (StreamOutput out ) throws IOException {
52
52
super .writeTo (out );
53
- if (out .getVersion ().onOrAfter (Version .V_3_0_0 )) {
53
+ if (out .getVersion ().onOrAfter (Version .V_2_18_0 )) {
54
54
if (indices == null ) {
55
55
out .writeVInt (0 );
56
56
} else {
Original file line number Diff line number Diff line change @@ -38,7 +38,7 @@ public CatShardsResponse() {}
38
38
public CatShardsResponse (StreamInput in ) throws IOException {
39
39
super (in );
40
40
indicesStatsResponse = new IndicesStatsResponse (in );
41
- if (in .getVersion ().onOrAfter (Version .V_3_0_0 )) {
41
+ if (in .getVersion ().onOrAfter (Version .V_2_18_0 )) {
42
42
nodes = DiscoveryNodes .readFrom (in , null );
43
43
responseShards = in .readList (ShardRouting ::new );
44
44
if (in .readBoolean ()) {
@@ -50,7 +50,7 @@ public CatShardsResponse(StreamInput in) throws IOException {
50
50
@ Override
51
51
public void writeTo (StreamOutput out ) throws IOException {
52
52
indicesStatsResponse .writeTo (out );
53
- if (out .getVersion ().onOrAfter (Version .V_3_0_0 )) {
53
+ if (out .getVersion ().onOrAfter (Version .V_2_18_0 )) {
54
54
nodes .writeToWithAttribute (out );
55
55
out .writeList (responseShards );
56
56
out .writeBoolean (pageToken != null );
Original file line number Diff line number Diff line change 20
20
*
21
21
* Class specific to paginated queries, which will contain common query params required by a paginated API.
22
22
*/
23
- @ PublicApi (since = "3.0 .0" )
23
+ @ PublicApi (since = "2.18 .0" )
24
24
public class PageParams implements Writeable {
25
25
26
26
public static final String PARAM_SORT = "sort" ;
Original file line number Diff line number Diff line change @@ -95,7 +95,7 @@ public void testSerializationWithOlderVersionsParametersNotSerialized() throws E
95
95
catShardsRequest .setCancelAfterTimeInterval (TimeValue .timeValueMillis (randomIntBetween (1 , 5 )));
96
96
catShardsRequest .setIndices (new String [2 ]);
97
97
98
- Version version = VersionUtils .getPreviousVersion (Version .CURRENT );
98
+ Version version = VersionUtils .getPreviousVersion (Version .V_2_18_0 );
99
99
try (BytesStreamOutput out = new BytesStreamOutput ()) {
100
100
out .setVersion (version );
101
101
catShardsRequest .writeTo (out );
You can’t perform that action at this time.
0 commit comments