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

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

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

Vertex.getId介绍

[英]Get the vertex id.
[中]获取顶点id。

代码示例

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

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

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

  1. /**
  2.  * Set vertex, replace if there was already a vertex with same id added
  3.  *
  4.  * @param vertex Vertex
  5.  * @return this
  6.  */
  7. public TestGraph<I, V, E> setVertex(Vertex<I, V, E> vertex) {
  8.  vertices.put(vertex.getId(), vertex);
  9.  return this;
  10. }

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

  1. @Override
  2.  public void setClass() {
  3.   setClass(_vertex.getId().getClass());
  4.  }
  5. };

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

  1. @Override
  2.  public void setClass() {
  3.   setClass(_vertex.getId().getClass());
  4.  }
  5. };

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

  1. @Override
  2.   public void compute(
  3.       Vertex<LongWritable, VertexValue, EdgeValue> vertex,
  4.       Iterable<LongWritable> messages) throws IOException {
  5.     sendMessageToAllEdges(vertex, vertex.getId());
  6.   }
  7. }

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

  1. @Override
  2.  public void setClass() {
  3.   setClass(_vertex.getId().getClass());
  4.  }
  5. };

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

  1. /**
  2.  * Is this vertex the source id?
  3.  *
  4.  * @return True if the source id
  5.  */
  6. private boolean isSource(
  7.   Vertex<LongWritable, DoubleWritable, FloatWritable> vertex) {
  8.  return vertex.getId().get() ==
  9.    getContext().getConfiguration().getLong(SOURCE_ID,
  10.      SOURCE_ID_DEFAULT);
  11. }

代码示例来源：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: org.apache.giraph/giraph-core

  1. /**
  2.  * Check if vertex is source from which to calculate shortest paths.
  3.  *
  4.  * @param vertex Vertex
  5.  * @return True iff vertex is source for shortest paths
  6.  */
  7. private boolean isSource(
  8.   Vertex<LongWritable, DoubleWritable, DoubleWritable> vertex) {
  9.  return vertex.getId().get() ==
  10.    getConf().getLong(SOURCE_ID, SOURCE_ID_DEFAULT);
  11. }

代码示例来源：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: 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: org.apache.giraph/giraph-core

  1. @Override
  2.  public void writeVertex(
  3.   Vertex<WritableComparable, Writable, Writable> vertex)
  4.   throws IOException, InterruptedException {
  5.   StringBuilder sb = new StringBuilder(vertex.getNumEdges() * 10);
  6.   for (Edge<WritableComparable, Writable> edge : vertex.getEdges()) {
  7.    addEdge(sb, vertex.getId(), edge);
  8.   }
  9.   addNodeInfo(vertex, sb);
  10.   getRecordWriter().write(new Text(sb.toString()), null);
  11.  }
  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: 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(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: 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. }

代码示例来源：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: grafos-ml/okapi

  1. @Override
  2.  public void compute(
  3.    Vertex<LongWritable, NullWritable, DoubleWritable> vertex,
  4.    Iterable<LongIdBloomFilter> messages) throws IOException {
  5.   
  6.   BloomFilter filter = new BloomFilter(numBits, numFunctions, hashType);
  7.   for (Edge<LongWritable, DoubleWritable> e : vertex.getEdges()) {
  8.    filter.add(new Key(Longs.toByteArray(e.getTargetVertexId().get())));
  9.   }
  10.   sendMessageToAllEdges(vertex, 
  11.     new LongIdBloomFilter(vertex.getId(), filter, vertex.getNumEdges()));
  12.  }
  13. }

代码示例来源：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. }

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

vertex

相关文章

    查看更多

    热门标签

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

    最新文章

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