List of finishThreadComputation() Examples

Examples of finishThreadComputation()

org.apache.giraph.worker.WorkerThreadAggregatorUsage.finishThreadComputation()
Call this after thread's computation is finished, i.e. when all vertices have provided their values to aggregators
org.apache.giraph.worker.WorkerThreadGlobalCommUsage.finishThreadComputation()
Call this after thread's computation is finished, i.e. when all vertices have provided their values to aggregators

Examples of org.apache.giraph.worker.WorkerThreadAggregatorUsage.finishThreadComputation()

          partitionStatsList.size() + " partitions on superstep " +
          graphState.getSuperstep() + ".  Flushing started");
    }
    try {
      workerClientRequestProcessor.flush();
      aggregatorUsage.finishThreadComputation();
    } catch (IOException e) {
      throw new IllegalStateException("call: Flushing failed.", e);
    }
    return partitionStatsList;
  }

View Full Code Here

Examples of org.apache.giraph.worker.WorkerThreadGlobalCommUsage.finishThreadComputation()

          workerClientRequestProcessor.resetMessageBytesCount();
        partitionStatsList.get(partitionStatsList.size() - 1).
          addMessageBytesSentCount(partitionMsgBytes);
        messageBytesSentCounter.inc(partitionMsgBytes);
      }
      aggregatorUsage.finishThreadComputation();
    } catch (IOException e) {
      throw new IllegalStateException("call: Flushing failed.", e);
    }
    return partitionStatsList;
  }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.