GIRAPH-1184
closes #68
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 @@
}
/**
- * 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
*
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 @@
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 @@
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 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;
+ }
}
