No worries. Just by the way, I realized after I sent that that using the
public static int numPreprocessingSteps to store the value in the
MasterCompute class doesn't work; you need to register a permanent
aggregator to hold on to it, if you need to.
Best,
Matthew
On Wed, Sep 10, 2014 at 3:15
Matt,
I'm not sure if you've resolved this problem already or not, but if you
haven't: The initialize() method isn't limited to registering aggregators,
and in fact, in my project I use it to do exactly what you're describing to
check and load custom configuration parameters. Inside the
Hi again. My application needs to pass in a String argument to the
computation which each Vertex needs access to. (The argument is a list of
the form [item1, item2, ...].) I found --customArguments (which I set in
my tests via conf.set(arg_name, arg_val)) but I need to check that it's
properly
