giraph-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m...@apache.org
Subject git commit: updated refs/heads/trunk to 3273f25
Date Fri, 06 Apr 2018 21:34:59 GMT
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 <majakabiljo@fb.com>
Authored: Thu Apr 5 12:14:08 2018 -0700
Committer: Maja Kabiljo <majakabiljo@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;
+  }
 }


Mime
View raw message