org.apache.giraph.block_app.framework.api

Interface BlockMasterApi

All Superinterfaces:

AggregatorUsage, BlockApi, BlockConfApi, BlockOutputApi, MasterAggregatorUsage, MasterGlobalCommUsage, MasterGlobalCommUsageAggregators, StatusReporter

public interface BlockMasterApi
extends MasterAggregatorUsage, MasterGlobalCommUsage, StatusReporter, BlockApi, BlockOutputApi

Block computation API available for the master methods. Interface to the MasterCompute methods.

Method Summary

Modifier and Type	Method and Description
<T extends org.apache.hadoop.io.Writable> BroadcastHandle<T>	broadcast(T value) Broadcast given value to all workers for next computation.
void	logToCommandLine(String line) Call this to log a line to command line of the job.
<A extends org.apache.hadoop.io.Writable> boolean	registerPersistentAggregator(String name, Class<? extends Aggregator<A>> aggregatorClass) Deprecated.

Methods inherited from interface org.apache.giraph.master.MasterAggregatorUsage

registerAggregator, setAggregatedValue

Methods inherited from interface org.apache.giraph.aggregators.AggregatorUsage

getAggregatedValue

Methods inherited from interface org.apache.giraph.master.MasterGlobalCommUsageAggregators

broadcast, getReduced, registerReducer, registerReducer

Methods inherited from interface org.apache.giraph.block_app.framework.api.StatusReporter

getCounter, progress, setStatus

Methods inherited from interface org.apache.giraph.block_app.framework.api.BlockApi

getTotalNumEdges, getTotalNumVertices, getWorkerCount

Methods inherited from interface org.apache.giraph.block_app.framework.api.BlockConfApi

getConf

Methods inherited from interface org.apache.giraph.block_app.framework.api.BlockOutputApi

getOutputDesc, getWriter

Method Detail

registerPersistentAggregator

@Deprecated
<A extends org.apache.hadoop.io.Writable> boolean registerPersistentAggregator(String name,
                                                                                           Class<? extends Aggregator<A>> aggregatorClass)
                                                                                    throws InstantiationException,
                                                                                           IllegalAccessException

Deprecated.

No need to use it, and introduces global dependencies. Store data locally within the piece, or use ObjectHolder.

Specified by:

registerPersistentAggregator in interface MasterAggregatorUsage

Type Parameters:

A - Aggregator type

Parameters:

name - of aggregator

aggregatorClass - Class type of the aggregator

Returns:

True iff aggregator wasn't already registered

Throws:

InstantiationException

IllegalAccessException

broadcast

<T extends org.apache.hadoop.io.Writable> BroadcastHandle<T> broadcast(T value)

Broadcast given value to all workers for next computation.

Parameters:

value - Value to broadcast

logToCommandLine

void logToCommandLine(String line)

Call this to log a line to command line of the job. Use in moderation - it's a synchronous call to Job client

Parameters:

line - Line to print