S
- Single value typeR
- Reduced value typepublic class ReducersForPieceHandler.GlobalReduceHandle<S,R extends org.apache.hadoop.io.Writable> extends ReducersForPieceHandler.ReduceHandleImpl<S,R>
reduceOp
Constructor and Description |
---|
GlobalReduceHandle(ReduceOperation<S,R> reduceOp) |
Modifier and Type | Method and Description |
---|---|
void |
reduce(S valueToReduce)
Reduce single value
|
void |
vertexSenderWorkerPostprocess(WorkerReduceUsage usage) |
void |
vertexSenderWorkerPreprocess(WorkerReduceUsage usage) |
broadcastValue, getName, getReducedValue
public GlobalReduceHandle(ReduceOperation<S,R> reduceOp)
public void vertexSenderWorkerPreprocess(WorkerReduceUsage usage)
public void reduce(S valueToReduce)
ReducerHandle
public void vertexSenderWorkerPostprocess(WorkerReduceUsage usage)
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.