honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-03-01 16:39:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update BWC version after backporting to 6.1

Browse Source 
Relates elastic/x-pack-elasticsearch#2975

Original commit: elastic/x-pack-elasticsearch@a63c56a019
This commit is contained in:
David Roberts 2017-11-21 10:22:43 +00:00
parent 41b254cdf4
commit 402852a4ee
2 changed files with 6 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
plugin/src/main/java/org/elasticsearch/xpack/ml/job/config/Job.java
View File

@ -222,8 +222,7 @@ public class Job extends AbstractDiffable<Job> implements Writeable, ToXContentO
createTime = new Date(in.readVLong()); createTime = new Date(in.readVLong());
finishedTime = in.readBoolean() ? new Date(in.readVLong()) : null; finishedTime = in.readBoolean() ? new Date(in.readVLong()) : null;
lastDataTime = in.readBoolean() ? new Date(in.readVLong()) : null; lastDataTime = in.readBoolean() ? new Date(in.readVLong()) : null;
// TODO: set to V_6_1_0 after backporting if (in.getVersion().onOrAfter(Version.V_6_1_0)) {
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
establishedModelMemory = in.readOptionalLong(); establishedModelMemory = in.readOptionalLong();
} else { } else {
establishedModelMemory = null; establishedModelMemory = null;
@ -484,8 +483,7 @@ public class Job extends AbstractDiffable<Job> implements Writeable, ToXContentO
} else { } else {
out.writeBoolean(false); out.writeBoolean(false);
} }
// TODO: set to V_6_1_0 after backporting if (out.getVersion().onOrAfter(Version.V_6_1_0)) {
if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
out.writeOptionalLong(establishedModelMemory); out.writeOptionalLong(establishedModelMemory);
} }
analysisConfig.writeTo(out); analysisConfig.writeTo(out);
@ -707,8 +705,7 @@ public class Job extends AbstractDiffable<Job> implements Writeable, ToXContentO
createTime = in.readBoolean() ? new Date(in.readVLong()) : null; createTime = in.readBoolean() ? new Date(in.readVLong()) : null;
finishedTime = in.readBoolean() ? new Date(in.readVLong()) : null; finishedTime = in.readBoolean() ? new Date(in.readVLong()) : null;
lastDataTime = in.readBoolean() ? new Date(in.readVLong()) : null; lastDataTime = in.readBoolean() ? new Date(in.readVLong()) : null;
// TODO: set to V_6_1_0 after backporting if (in.getVersion().onOrAfter(Version.V_6_1_0)) {
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
establishedModelMemory = in.readOptionalLong(); establishedModelMemory = in.readOptionalLong();
} }
analysisConfig = in.readOptionalWriteable(AnalysisConfig::new); analysisConfig = in.readOptionalWriteable(AnalysisConfig::new);
@ -896,8 +893,7 @@ public class Job extends AbstractDiffable<Job> implements Writeable, ToXContentO
} else { } else {
out.writeBoolean(false); out.writeBoolean(false);
} }
// TODO: set to V_6_1_0 after backporting if (out.getVersion().onOrAfter(Version.V_6_1_0)) {
if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
out.writeOptionalLong(establishedModelMemory); out.writeOptionalLong(establishedModelMemory);
} }
out.writeOptionalWriteable(analysisConfig); out.writeOptionalWriteable(analysisConfig);

6
plugin/src/main/java/org/elasticsearch/xpack/ml/job/config/JobUpdate.java
View File

@ -124,8 +124,7 @@ public class JobUpdate implements Writeable, ToXContentObject {
} }
customSettings = in.readMap(); customSettings = in.readMap();
modelSnapshotId = in.readOptionalString(); modelSnapshotId = in.readOptionalString();
// TODO: set to V_6_1_0 after backporting if (in.getVersion().onOrAfter(Version.V_6_1_0)) {
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
establishedModelMemory = in.readOptionalLong(); establishedModelMemory = in.readOptionalLong();
} else { } else {
establishedModelMemory = null; establishedModelMemory = null;
@ -156,8 +155,7 @@ public class JobUpdate implements Writeable, ToXContentObject {
} }
out.writeMap(customSettings); out.writeMap(customSettings);
out.writeOptionalString(modelSnapshotId); out.writeOptionalString(modelSnapshotId);
// TODO: set to V_6_1_0 after backporting if (out.getVersion().onOrAfter(Version.V_6_1_0)) {
if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
out.writeOptionalLong(establishedModelMemory); out.writeOptionalLong(establishedModelMemory);
} }
} }