org.apache.giraph.block_app.library.gc

Class WorkerGCPiece

java.lang.Object

org.apache.giraph.block_app.framework.piece.AbstractPiece<I,V,E,M,WV,WM,S>

org.apache.giraph.block_app.framework.piece.DefaultParentPiece<I,V,E,M,WV,WM,S>

org.apache.giraph.block_app.framework.piece.PieceWithWorkerContext<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object,NoMessage,Object>

org.apache.giraph.block_app.library.gc.WorkerGCPiece

All Implemented Interfaces:

Iterable<AbstractPiece>, Block

public class WorkerGCPiece
extends PieceWithWorkerContext<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object,NoMessage,Object>

Dummy piece to hint System.gc()

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.giraph.block_app.framework.piece.AbstractPiece

AbstractPiece.InnerVertexReceiver, AbstractPiece.InnerVertexSender

Field Summary

Fields inherited from class org.apache.giraph.block_app.framework.piece.DefaultParentPiece

MESSAGE_ENCODE_AND_STORE_TYPE_MIN_FORCE

Constructor Summary

Constructors

Constructor and Description
WorkerGCPiece()

Method Summary

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.

Methods inherited from class org.apache.giraph.block_app.framework.piece.PieceWithWorkerContext

getWorkerValue

Methods inherited from class org.apache.giraph.block_app.framework.piece.DefaultParentPiece

allowOneMessageToManyIdsEncoding, getMessageClass, getMessageClasses, getMessageCombiner, getMessageFactory, getVertexSender, getWrappedVertexSender, receiveIgnoreExistingVertices, reduceDouble, reduceFloat, reduceInt, reduceLong, registerReducers, wrappedRegisterReducers

Methods inherited from class org.apache.giraph.block_app.framework.piece.AbstractPiece

equals, forAllPossiblePieces, getPieceCount, getVertexReceiver, hashCode, iterator, masterCompute, nextExecutionStage, registerAggregators, toString, workerContextReceive

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

WorkerGCPiece

public WorkerGCPiece()

Method Detail

workerContextSend

public void workerContextSend(BlockWorkerContextSendApi<org.apache.hadoop.io.WritableComparable,NoMessage> workerContextApi,
                              Object executionStage,
                              Object workerValue)

Description copied from class: AbstractPiece

Override to have worker context send computation. Called once per worker, after all vertices have been processed with getVertexSender.

Overrides:

workerContextSend in class AbstractPiece<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable,NoMessage,Object,NoMessage,Object>