You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@drill.apache.org by ja...@apache.org on 2014/05/22 03:15:01 UTC
[24/24] git commit: fix to use delimited for protobuf serialization
fix to use delimited for protobuf serialization
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/c34a190f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/c34a190f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/c34a190f
Branch: refs/heads/diagnostics2
Commit: c34a190fc5547a31876a58eaceb3d11eae8b3ca5
Parents: e2740df
Author: Jacques Nadeau <ja...@apache.org>
Authored: Wed May 21 18:14:26 2014 -0700
Committer: Jacques Nadeau <ja...@apache.org>
Committed: Wed May 21 18:14:26 2014 -0700
----------------------------------------------------------------------
.../main/java/org/apache/drill/exec/cache/ProtoSerializable.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/c34a190f/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java b/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java
index 1538a85..0a2aa4a 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java
@@ -45,12 +45,12 @@ public abstract class ProtoSerializable<V extends Message> extends AbstractStrea
@Override
public void readFromStream(InputStream input) throws IOException {
- obj = protoParser.parseFrom(input);
+ obj = protoParser.parseDelimitedFrom(input);
}
@Override
public void writeToStream(OutputStream output) throws IOException {
- obj.writeTo(output);
+ obj.writeDelimitedTo(output);
}
public static class PlanFragmentSerializable extends ProtoSerializable<PlanFragment>{