org.apache.giraph.graph.Vertex.getValue()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(7.0k)|赞(0)|评价(0)|浏览(189)

本文整理了Java中org.apache.giraph.graph.Vertex.getValue()方法的一些代码示例，展示了Vertex.getValue()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Vertex.getValue()方法的具体详情如下：
包路径：org.apache.giraph.graph.Vertex
类名称：Vertex
方法名：getValue

Vertex.getValue介绍

[英]Get the vertex value (data stored with vertex)
[中]获取顶点值（与顶点一起存储的数据）

代码示例

代码示例来源：origin: apache/giraph

  1. @Override
  2.  public V get(Vertex<I, V, E> vertex) {
  3.   return vertex.getValue();
  4.  }
  5. };

代码示例来源：origin: org.apache.giraph/giraph-examples

  1. @Override
  2.  public void writeVertex(
  3.   Vertex<LongWritable, DoubleWritable, DoubleWritable> vertex)
  4.   throws IOException, InterruptedException {
  5.   StringBuilder output = new StringBuilder();
  6.   output.append(vertex.getId().get());
  7.   output.append('\t');
  8.   output.append(vertex.getValue().get());
  9.   getRecordWriter().write(new Text(output.toString()), null);
  10.  }
  11. }

代码示例来源：origin: org.apache.giraph/giraph-examples

  1. @Override
  2.  public void writeVertex(
  3.    Vertex<LongWritable, DoubleWritable, NullWritable> vertex)
  4.   throws IOException, InterruptedException {
  5.   StringBuilder output = new StringBuilder();
  6.   output.append(vertex.getId().get());
  7.   output.append('\t');
  8.   output.append(vertex.getValue().get());
  9.   getRecordWriter().write(new Text(output.toString()), null);
  10.  }
  11. }

代码示例来源：origin: grafos-ml/okapi

  1. private void requestMigration(
  2.     Vertex<LongWritable, VertexValue, EdgeValue> vertex,
  3.     int numberOfEdges, short currentPartition, short newPartition) {
  4.   vertex.getValue().setNewPartition(newPartition);
  5.   aggregate(demandAggregatorNames[newPartition], new LongWritable(
  6.       numberOfEdges));
  7.   loads[newPartition] += numberOfEdges;
  8.   loads[currentPartition] -= numberOfEdges;
  9. }

代码示例来源：origin: grafos-ml/okapi

  1. @Override
  2. protected Text convertVertexToLine(
  3.     Vertex<LongWritable, KMeansVertexValue, NullWritable> vertex)
  4.     throws IOException {
  5.   StringBuffer sb = new StringBuffer(vertex.getId().toString());
  6.   sb.append(delimiter);
  7.   sb.append(vertex.getValue().getClusterId().toString());
  8.   return new Text(sb.toString());
  9. }

代码示例来源：origin: apache/giraph

  1. /**
  2.  * Get Vertex Value for a given id.
  3.  */
  4. public V getValue(Number vertexId) {
  5.  return testGraph.getVertex(numberToVertexId(vertexId)).getValue();
  6. }

代码示例来源：origin: grafos-ml/okapi

  1. @Override
  2.  public void compute(
  3.    Vertex<LongWritable, VertexValue, DoubleWritable> vertex,
  4.    Iterable<DoubleWritable> messages) throws IOException {
  5.   if (vertex.getValue().isTrusted()) {
  6.    aggregate(AGGREGATOR_NUM_TRUSTED, ONE);
  7.   }
  8.  }
  9. }

代码示例来源：origin: grafos-ml/okapi

  1. /**
  2.  * We override this function as we need a special treatment for item biases. See the class documentation for the explanation.
  3.  */
  4. protected void initFactorsIfNeeded(Vertex<CfLongId,FloatMatrixWritable,FloatWritable> vertex) {
  5.   if (null == vertex.getValue() || vertex.getValue().columns != d+1){
  6.     vertex.setValue(new FloatMatrixWritable(FloatMatrix.rand(d + 1)));
  7.   }
  8.   if (vertex.getId().isUser()){//In BPR the first factor of the user is always 1, its to have item baselines
  9.     vertex.getValue().put(0, 1f);
  10.   }
  11. }

代码示例来源：origin: org.apache.giraph/giraph-core

  1. /**
  2.  * The backing store of the current vertex id is now released.
  3.  * Further calls to getCurrentVertexId () without calling next()
  4.  * will return null.
  5.  *
  6.  * @return Current vertex id that was released
  7.  */
  8. public I releaseCurrentVertexId() {
  9.  I releasedVertexId = vertex.getId();
  10.  vertex.initialize(null, vertex.getValue());
  11.  return releasedVertexId;
  12. }

代码示例来源：origin: grafos-ml/okapi

  1. @Override
  2.   protected Text convertVertexToLine(
  3.       Vertex<CfLongId, FloatMatrixWritable, BooleanWritable> vertex)
  4.       throws IOException {
  5.     if (outputEdge.equals(vertex.getId())){
  6.       return new Text(vertex.getValue().toString());
  7.     }
  8.     return null;
  9.   }
  10. };

代码示例来源：origin: apache/giraph

  1. @Override
  2.  public void apply(Vertex<LongWritable, LongWritable, Writable> vertex,
  3.    Iterable<LongWritable> messages) {
  4.   long max = 0;
  5.   for (LongWritable v : messages) {
  6.    max = Math.max(max, v.get());
  7.   }
  8.   vertex.getValue().set(max);
  9.  }
  10. });

代码示例来源：origin: org.apache.giraph/giraph-examples

  1. @Override
  2.  public void writeVertex(
  3.   Vertex<LongWritable, IntWritable, FloatWritable> vertex)
  4.   throws IOException, InterruptedException {
  5.   getRecordWriter().write(
  6.     new Text(vertex.getId().toString()),
  7.     new Text(vertex.getValue().toString()));
  8.  }
  9. }

代码示例来源：origin: org.apache.giraph/giraph-examples

  1. @Override
  2.  public void writeVertex(
  3.    Vertex<LongWritable, DoubleWritable, FloatWritable> vertex)
  4.   throws IOException, InterruptedException {
  5.   getRecordWriter().write(
  6.     new Text(vertex.getId().toString()),
  7.     new Text(vertex.getValue().toString()));
  8.  }
  9. }

代码示例来源：origin: org.apache.giraph/giraph-examples

  1. @Override
  2.  public void writeVertex(Vertex<LongWritable, IntWritable,
  3.    FloatWritable> vertex) throws IOException, InterruptedException {
  4.   getRecordWriter().write(
  5.     new Text(vertex.getId().toString()),
  6.     new Text(vertex.getValue().toString()));
  7.  }
  8. }

代码示例来源：origin: org.apache.giraph/giraph-examples

  1. /**
  2.  * Traverse the transposed graph and keep the maximum vertex value.
  3.  * @param vertex Current vertex.
  4.  */
  5. private void backwardTraversalStart(
  6.   Vertex<LongWritable, SccVertexValue, NullWritable> vertex) {
  7.  SccVertexValue vertexValue = vertex.getValue();
  8.  if (vertexValue.get() == vertex.getId().get()) {
  9.   messageValue.set(vertexValue.get());
  10.   sendMessageToAllParents(vertex, messageValue);
  11.  }
  12. }

代码示例来源：origin: org.apache.giraph/giraph-examples

  1. @Override
  2.  public void compute(
  3.    Vertex<LongWritable, LongWritable, DoubleWritable> vertex,
  4.    Iterable<DoubleWritable> messages) throws IOException {
  5.   LongWritable vertexValue = vertex.getValue();
  6.   vertexValue.set(vertex.getNumEdges());
  7.   vertex.setValue(vertexValue);
  8.   vertex.voteToHalt();
  9.  }
  10. }

代码示例来源：origin: grafos-ml/okapi

  1. @Override
  2.  public void compute(
  3.      Vertex<LongWritable, KMeansVertexValue, NullWritable> vertex,
  4.      Iterable<NullWritable> messages) throws IOException {
  5.    ArrayListOfDoubleArrayListWritable value = new ArrayListOfDoubleArrayListWritable();
  6.    value.add(vertex.getValue().getPointCoordinates());
  7.    aggregate(INITIAL_CENTERS, value);
  8.    }
  9. }

代码示例来源：origin: org.apache.giraph/giraph-examples

  1. @Override
  2. public void compute(
  3.   Vertex<LongWritable, DoubleWritable, FloatWritable> vertex,
  4.   Iterable<DoubleWritable> messages) throws IOException {
  5.  double oldSum = getSuperstep() == 0 ? 0 : vertex.getValue().get();
  6.  double newValue = this.<DoubleWritable>getAggregatedValue(SMC_AGG).get();
  7.  double newSum = oldSum + newValue;
  8.  vertex.setValue(new DoubleWritable(newSum));
  9.  SimpleMasterComputeWorkerContext workerContext = getWorkerContext();
  10.  workerContext.setFinalSum(newSum);
  11.  LOG.info("Current sum: " + newSum);
  12. }

代码示例来源：origin: org.apache.giraph/giraph-examples

  1. @Override
  2.  public void compute(
  3.    Vertex<LongWritable, DoubleWritable, FloatWritable> vertex,
  4.    Iterable<DoubleWritable> messages) throws IOException {
  5.   double oldSum = getSuperstep() == 0 ? 0 : vertex.getValue().get();
  6.   double newValue = this.<DoubleWritable>getAggregatedValue(SMC_AGG).get();
  7.   double newSum = oldSum + newValue;
  8.   vertex.setValue(new DoubleWritable(newSum));
  9.   SimpleMigrationMasterWorkerContext workerContext = getWorkerContext();
  10.   workerContext.setFinalSum(newSum);
  11.   LOG.info("Current sum: " + newSum);
  12.  }
  13. }

代码示例来源：origin: grafos-ml/okapi

  1. public void computeScoreAndSendBack(
  2.   Vertex<CfLongId, FloatMatrixWritable, BooleanWritable> vertex,
  3.   Iterable<FloatMatrixMessage> messages) {
  4.  if (vertex.getId().isItem()){//only items send messages
  5.   for(FloatMatrixMessage msg : messages){
  6.    float score = msg.getFactors().dot(vertex.getValue());
  7.    FloatMatrixMessage msgToSendBack = 
  8.      new FloatMatrixMessage(vertex.getId(), emptyList, score);
  9.    sendMessage(msg.getSenderId(), msgToSendBack);
  10.   }
  11.  }
  12. }

内容来源于网络，如有侵权，请联系作者删除！

vertex

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com