Toggle navigation
Home
org.apache.giraph.block_app.framework.api.local.VertexSaver to org.apache.giraph.io.SimpleVertexWriter
No. of Instances - 5
No. of Commits - 1
No. of Projects - {'giraph'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Rename Method invocation
saveVertex
to
writeVertex
saveVertex
to
writeVertex
Add or Remove Method invocation
vertexSaver.saveVertex(vertex)
to
vertexSaver.writeVertex(vertex)
Update Anonymous class
{ @Override public void run(){ try { boolean anyCurVertexAlive=false; BlockWorkerPieces localPieces=KryoWritableWrapper.wrapAndCopy(workerPieces); BlockWorkerLogic localLogic=new BlockWorkerLogic(localPieces); localLogic.preSuperstep(internalWorkerApi,internalWorkerApi); for ( Vertex<I,V,E> vertex : curVertices) { Iterable messages=internalApi.takeMessages(vertex.getId()); if (vertex.isHalted() && !Iterables.isEmpty(messages)) { vertex.wakeUp(); } if (!vertex.isHalted()) { localLogic.compute(vertex,messages); if (doOutputDuringComputation) { vertexSaver.saveVertex(vertex); } } if (!vertex.isHalted()) { anyCurVertexAlive=true; } } if (anyCurVertexAlive) { anyVertexAlive.set(true); } localLogic.postSuperstep(); } catch ( Throwable t) { t.printStackTrace(); exception.set(t); } latch.countDown(); } }
to
{ @Override public void run(){ try { boolean anyCurVertexAlive=false; BlockWorkerPieces localPieces=KryoWritableWrapper.wrapAndCopy(workerPieces); BlockWorkerLogic localLogic=new BlockWorkerLogic(localPieces); localLogic.preSuperstep(internalWorkerApi,internalWorkerApi); for ( Vertex<I,V,E> vertex : partition) { Iterable messages=internalApi.takeMessages(vertex.getId()); if (vertex.isHalted() && !Iterables.isEmpty(messages)) { vertex.wakeUp(); } if (!vertex.isHalted()) { localLogic.compute(vertex,messages); vertex.unwrapMutableEdges(); if (vertex instanceof Trimmable) { ((Trimmable)vertex).trim(); } if (doOutputDuringComputation) { vertexSaver.writeVertex(vertex); } partition.saveVertex(vertex); } if (!vertex.isHalted()) { anyCurVertexAlive=true; } } if (anyCurVertexAlive) { anyVertexAlive.set(true); } localLogic.postSuperstep(); } catch ( Throwable t) { t.printStackTrace(); exception.set(t); } latch.countDown(); } }