public class WorkerGCPiece extends PieceWithWorkerContext<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object,NoMessage,Object>
AbstractPiece.InnerVertexReceiver, AbstractPiece.InnerVertexSender
MESSAGE_ENCODE_AND_STORE_TYPE_MIN_FORCE
Constructor and Description |
---|
WorkerGCPiece() |
Modifier and Type | Method and Description |
---|---|
void |
workerContextSend(BlockWorkerContextSendApi<org.apache.hadoop.io.WritableComparable,NoMessage> workerContextApi,
Object executionStage,
Object workerValue)
Override to have worker context send computation.
|
getWorkerValue
allowOneMessageToManyIdsEncoding, getMessageClass, getMessageClasses, getMessageCombiner, getMessageFactory, getVertexSender, getWrappedVertexSender, receiveIgnoreExistingVertices, reduceDouble, reduceFloat, reduceInt, reduceLong, registerReducers, wrappedRegisterReducers
equals, forAllPossiblePieces, getPieceCount, getVertexReceiver, hashCode, iterator, masterCompute, nextExecutionStage, registerAggregators, toString, workerContextReceive
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
forEach, spliterator
public void workerContextSend(BlockWorkerContextSendApi<org.apache.hadoop.io.WritableComparable,NoMessage> workerContextApi, Object executionStage, Object workerValue)
AbstractPiece
workerContextSend
in class AbstractPiece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object,NoMessage,Object>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.