org.apache.giraph.worker

Interface WorkerReduceUsage

All Known Subinterfaces:

Computation<I,V,E,M1,M2>, WorkerGlobalCommUsage, WorkerThreadGlobalCommUsage

All Known Implementing Classes:

AbstractComputation, AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader, AggregatorsBenchmark.AggregatorsBenchmarkComputation, AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext, BasicComputation, BasicVertexValueReader, DefaultWorkerContext, EdgeReader, EdgeReaderWrapper, IntIntNullTextInputFormat.IntIntNullVertexReader, IntIntNullTextVertexInputFormat.IntIntNullVertexReader, IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader, IntNullNullTextInputFormat.IntNullNullNullVertexReader, IntNullTextEdgeInputFormat.IntNullTextEdgeReader, JsonBase64VertexInputFormat.JsonBase64VertexReader, JythonGiraphComputation, LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader, LongLongNullTextInputFormat.LongLongNullVertexReader, MappingReader, MappingReaderWrapper, PageRankComputation, RandomMessageBenchmark.RandomMessageBenchmarkWorkerContext, RandomMessageBenchmark.RandomMessageComputation, ReducersBenchmark.ReducersBenchmarkComputation, ReducersBenchmark.ReducersBenchmarkWorkerContext, ReverseEdgeDuplicator, SequenceFileVertexInputFormat.SequenceFileVertexReader, ShortestPathsComputation, TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader, TextEdgeInputFormat.TextEdgeReader, TextEdgeInputFormat.TextEdgeReaderFromEachLine, TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed, TextVertexInputFormat.TextVertexReader, TextVertexInputFormat.TextVertexReaderFromEachLine, TextVertexInputFormat.TextVertexReaderFromEachLineProcessed, TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions, TextVertexValueInputFormat.TextVertexValueReader, TextVertexValueInputFormat.TextVertexValueReaderFromEachLine, TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed, VertexReader, VertexReaderWrapper, VertexValueReader, WeightedPageRankComputation, WorkerAggregatorDelegator, WorkerAggregatorHandler, WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage, WorkerContext, WrappedEdgeReader, WrappedMappingReader, WrappedVertexReader

public interface WorkerReduceUsage

Methods on worker can provide values to reduce through this interface

Method Summary

Modifier and Type	Method and Description
void	reduce(String name, Object value) Reduce given value.
void	reduceMerge(String name, org.apache.hadoop.io.Writable value) Reduce given partial value.

Method Detail

reduce

void reduce(String name,
            Object value)

Reduce given value.

Parameters:

name - Name of the reducer

value - Single value to reduce

reduceMerge

void reduceMerge(String name,
                 org.apache.hadoop.io.Writable value)

Reduce given partial value.

Parameters:

name - Name of the reducer

value - Single value to reduce