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 <majakabi...@fb.com> Authored: Thu Apr 5 12:14:08 2018 -0700 Committer: Maja Kabiljo <majakabi...@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; + } }