Skip to content
Permalink
Browse files
GIRAPH-1184
closes #68
  • Loading branch information
Maja Kabiljo committed Apr 6, 2018
1 parent 5c418ff commit 3273f2572f79bfcfc9abe1d821a9743108c65ebb
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 10 deletions.
@@ -989,16 +989,6 @@ public void useUnsafeSerialization(boolean useUnsafeSerialization) {
USE_UNSAFE_SERIALIZATION.set(this, useUnsafeSerialization);
}

/**
* 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
@@ -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 @@ public ImmutableClassesGiraphConfiguration(Configuration conf) {
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 boolean isStaticGraph() {
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;
}
}

0 comments on commit 3273f25

Please sign in to comment.