honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Internal: adjusted TermVectorRequest serialization to not serialize and de-serialize the index twice 

Closes #7221
This commit is contained in:
javanna 2014-08-11 17:57:46 +02:00 committed by Luca Cavanna
parent 983c14b41a
commit 98fa8f9ba4
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/org/elasticsearch/action/termvector/TermVectorRequest.java
View File

@ -21,6 +21,7 @@ package org.elasticsearch.action.termvector;
import com.google.common.collect.Sets;
import org.elasticsearch.ElasticsearchParseException;
import org.elasticsearch.Version;
import org.elasticsearch.action.ActionRequestValidationException;
import org.elasticsearch.action.ValidateActions;
import org.elasticsearch.action.support.single.shard.SingleShardOperationRequest;
@ -287,7 +288,10 @@ public class TermVectorRequest extends SingleShardOperationRequest<TermVectorReq
@Override
public void readFrom(StreamInput in) throws IOException {
super.readFrom(in);
index = in.readString();
if (in.getVersion().before(Version.V_1_4_0)) {
//term vector used to read & write the index twice, here and in the parent class
in.readString();
}
type = in.readString();
id = in.readString();
routing = in.readOptionalString();
@ -312,7 +316,10 @@ public class TermVectorRequest extends SingleShardOperationRequest<TermVectorReq
@Override
public void writeTo(StreamOutput out) throws IOException {
super.writeTo(out);
out.writeString(index);
if (out.getVersion().before(Version.V_1_4_0)) {
//term vector used to read & write the index twice, here and in the parent class
out.writeString(index);
}
out.writeString(type);
out.writeString(id);
out.writeOptionalString(routing);
@ -330,7 +337,6 @@ public class TermVectorRequest extends SingleShardOperationRequest<TermVectorReq
} else {
out.writeVInt(0);
}
}
public static enum Flag {