99
1010package org .elasticsearch .action .search ;
1111
12+ import org .elasticsearch .TransportVersion ;
1213import org .elasticsearch .action .ActionResponse ;
1314import org .elasticsearch .action .ResolvedIndexExpressions ;
1415import org .elasticsearch .action .admin .cluster .shards .ClusterSearchShardsGroup ;
@@ -38,6 +39,9 @@ public final class SearchShardsResponse extends ActionResponse {
3839 private final Collection <DiscoveryNode > nodes ;
3940 private final Map <String , AliasFilter > aliasFilters ;
4041 private final ResolvedIndexExpressions resolvedIndexExpressions ;
42+ public static final TransportVersion SEARCH_SHARDS_RESOLVED_INDEX_EXPRESSIONS = TransportVersion .fromName (
43+ "search_shards_resolved_index_expressions"
44+ );
4145
4246 public SearchShardsResponse (
4347 Collection <SearchShardsGroup > groups ,
@@ -63,7 +67,7 @@ public SearchShardsResponse(StreamInput in) throws IOException {
6367 this .groups = in .readCollectionAsList (SearchShardsGroup ::new );
6468 this .nodes = in .readCollectionAsList (DiscoveryNode ::new );
6569 this .aliasFilters = in .readMap (AliasFilter ::readFrom );
66- if (in .getTransportVersion ().supports (ResolvedIndexExpressions . RESOLVED_INDEX_EXPRESSIONS )) {
70+ if (in .getTransportVersion ().supports (SEARCH_SHARDS_RESOLVED_INDEX_EXPRESSIONS )) {
6771 this .resolvedIndexExpressions = in .readOptionalWriteable (ResolvedIndexExpressions ::new );
6872 } else {
6973 this .resolvedIndexExpressions = null ;
@@ -75,7 +79,7 @@ public void writeTo(StreamOutput out) throws IOException {
7579 out .writeCollection (groups );
7680 out .writeCollection (nodes );
7781 out .writeMap (aliasFilters , StreamOutput ::writeWriteable );
78- if (out .getTransportVersion ().supports (ResolvedIndexExpressions . RESOLVED_INDEX_EXPRESSIONS )) {
82+ if (out .getTransportVersion ().supports (SEARCH_SHARDS_RESOLVED_INDEX_EXPRESSIONS )) {
7983 out .writeOptionalWriteable (resolvedIndexExpressions );
8084 }
8185 }
0 commit comments