S
- Single value typeR
- Reduced value typepublic abstract class ReducersForPieceHandler.ReduceHandleImpl<S,R extends org.apache.hadoop.io.Writable> extends Object implements ReducerHandle<S,R>, VertexSenderObserver
Modifier and Type | Field and Description |
---|---|
protected ReduceOperation<S,R> |
reduceOp |
Modifier and Type | Method and Description |
---|---|
BroadcastHandle<R> |
broadcastValue(BlockMasterApi master)
Broadcast reduced value from master
|
String |
getName() |
R |
getReducedValue(MasterGlobalCommUsage master)
Get reduced value
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
reduce
vertexSenderWorkerPostprocess, vertexSenderWorkerPreprocess
protected final ReduceOperation<S,R extends org.apache.hadoop.io.Writable> reduceOp
public String getName()
public R getReducedValue(MasterGlobalCommUsage master)
ReducerHandle
getReducedValue
in interface ReducerHandle<S,R extends org.apache.hadoop.io.Writable>
public BroadcastHandle<R> broadcastValue(BlockMasterApi master)
ReducerHandle
broadcastValue
in interface ReducerHandle<S,R extends org.apache.hadoop.io.Writable>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.