You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ma...@apache.org on 2018/04/06 21:34:59 UTC
git commit: updated refs/heads/trunk to 3273f25
Repository: giraph
Updated Branches:
refs/heads/trunk 5c418ff33 -> 3273f2572
GIRAPH-1184
closes #68
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/3273f257
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/3273f257
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/3273f257
Branch: refs/heads/trunk
Commit: 3273f2572f79bfcfc9abe1d821a9743108c65ebb
Parents: 5c418ff
Author: Maja Kabiljo <ma...@fb.com>
Authored: Thu Apr 5 12:14:08 2018 -0700
Committer: Maja Kabiljo <ma...@fb.com>
Committed: Fri Apr 6 14:34:16 2018 -0700
----------------------------------------------------------------------
.../org/apache/giraph/conf/GiraphConfiguration.java | 10 ----------
.../conf/ImmutableClassesGiraphConfiguration.java | 13 +++++++++++++
2 files changed, 13 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/3273f257/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java b/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java
index e269de4..17c48a5 100644
--- a/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java
+++ b/giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java
@@ -990,16 +990,6 @@ public class GiraphConfiguration extends Configuration
}
/**
- * Use message size encoding? This feature may help with complex message
- * objects.
- *
- * @return Whether to use message size encoding
- */
- public boolean useMessageSizeEncoding() {
- return USE_MESSAGE_SIZE_ENCODING.get(this);
- }
-
- /**
* Set the checkpoint frequeuncy of how many supersteps to wait before
* checkpointing
*
http://git-wip-us.apache.org/repos/asf/giraph/blob/3273f257/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java b/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
index dfd24d0..7f04e54 100644
--- a/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
+++ b/giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
@@ -136,6 +136,8 @@ public class ImmutableClassesGiraphConfiguration<I extends WritableComparable,
private final boolean useBigDataIOForMessages;
/** Is the graph static (meaning there is no mutation)? */
private final boolean isStaticGraph;
+ /** Whether or not to use message size encoding */
+ private final boolean useMessageSizeEncoding;
/**
* Constructor. Takes the configuration and then gets the classes out of
@@ -156,6 +158,7 @@ public class ImmutableClassesGiraphConfiguration<I extends WritableComparable,
valueFactories = new ValueFactories<I, V, E>(this);
outEdgesFactory = VERTEX_EDGES_FACTORY_CLASS.newInstance(this);
inputOutEdgesFactory = INPUT_VERTEX_EDGES_FACTORY_CLASS.newInstance(this);
+ useMessageSizeEncoding = USE_MESSAGE_SIZE_ENCODING.get(conf);
}
/**
@@ -1375,4 +1378,14 @@ public class ImmutableClassesGiraphConfiguration<I extends WritableComparable,
public String getJobId() {
return get("mapred.job.id", "UnknownJob");
}
+
+ /**
+ * Use message size encoding? This feature may help with complex message
+ * objects.
+ *
+ * @return Whether to use message size encoding
+ */
+ public boolean useMessageSizeEncoding() {
+ return useMessageSizeEncoding;
+ }
}