1717import org .elasticsearch .xpack .core .XPackField ;
1818
1919import java .io .IOException ;
20- import java .util .Collections ;
2120import java .util .Map ;
2221import java .util .Map .Entry ;
2322import java .util .Objects ;
@@ -33,11 +32,7 @@ public class TransformFeatureSetUsage extends Usage {
3332 public TransformFeatureSetUsage (StreamInput in ) throws IOException {
3433 super (in );
3534 this .transformCountByState = in .readMap (StreamInput ::readString , StreamInput ::readLong );
36- if (in .getVersion ().onOrAfter (Version .V_8_0_0 )) { // TODO: V_7_13_0
37- this .transformCountByFeature = in .readMap (StreamInput ::readString , StreamInput ::readLong );
38- } else {
39- this .transformCountByFeature = Collections .emptyMap ();
40- }
35+ this .transformCountByFeature = in .readMap (StreamInput ::readString , StreamInput ::readLong );
4136 this .accumulatedStats = new TransformIndexerStats (in );
4237 }
4338
@@ -59,9 +54,7 @@ public Version getMinimalSupportedVersion() {
5954 public void writeTo (StreamOutput out ) throws IOException {
6055 super .writeTo (out );
6156 out .writeMap (transformCountByState , StreamOutput ::writeString , StreamOutput ::writeLong );
62- if (out .getVersion ().onOrAfter (Version .V_8_0_0 )) { // TODO: V_7_13_0
63- out .writeMap (transformCountByFeature , StreamOutput ::writeString , StreamOutput ::writeLong );
64- }
57+ out .writeMap (transformCountByFeature , StreamOutput ::writeString , StreamOutput ::writeLong );
6558 accumulatedStats .writeTo (out );
6659 }
6760
0 commit comments