You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2015/04/29 12:22:24 UTC
svn commit: r1676708 -
/hama/trunk/ml/src/main/java/org/apache/hama/ml/kcore/KCoreVertex.java
Author: edwardyoon
Date: Wed Apr 29 10:22:24 2015
New Revision: 1676708
URL: http://svn.apache.org/r1676708
Log:
HAMA-894: writeInt() is used to write the integer core data.
Modified:
hama/trunk/ml/src/main/java/org/apache/hama/ml/kcore/KCoreVertex.java
Modified: hama/trunk/ml/src/main/java/org/apache/hama/ml/kcore/KCoreVertex.java
URL: http://svn.apache.org/viewvc/hama/trunk/ml/src/main/java/org/apache/hama/ml/kcore/KCoreVertex.java?rev=1676708&r1=1676707&r2=1676708&view=diff
==============================================================================
--- hama/trunk/ml/src/main/java/org/apache/hama/ml/kcore/KCoreVertex.java (original)
+++ hama/trunk/ml/src/main/java/org/apache/hama/ml/kcore/KCoreVertex.java Wed Apr 29 10:22:24 2015
@@ -101,8 +101,7 @@ public class KCoreVertex extends
}
@Override
- public void readFields(DataInput in) throws IOException {
- super.readFields(in);
+ public void readState(DataInput in) throws IOException {
core = in.readInt();
changed = in.readBoolean();
@@ -118,9 +117,8 @@ public class KCoreVertex extends
}
@Override
- public void write(DataOutput out) throws IOException {
- super.write(out);
- out.writeDouble(core);
+ public void writeState(DataOutput out) throws IOException {
+ out.writeInt(core);
out.writeBoolean(changed);
if (this.estimates == null) {