org.gradoop.common.model.impl.pojo.Vertex.getPropertyValue()方法的使用及代码示例

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

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

Vertex.getPropertyValue介绍

暂无

代码示例

代码示例来源：origin: dbs-leipzig/gradoop

@Override
 public boolean filter(V vertex) throws Exception {
  long degree = Long.parseLong(vertex.getPropertyValue(propertyNameOfDegree).toString());
  long maxDegree = Long.parseLong(vertex.getPropertyValue(propertyNameofMaxDegree).toString());
  return randomGenerator.nextFloat() <= (degree / (double) maxDegree) * threshold;
 }
}

代码示例来源：origin: dbs-leipzig/gradoop

@Override
 public Tuple3<Edge, Boolean, Boolean> join(Tuple3<Edge, GradoopId, Boolean> interim,
  Vertex vertex) {
  reuse.f0 = interim.f0;
  reuse.f1 = interim.f2;
  reuse.f2 = vertex.getPropertyValue(propertyKey).getBoolean();
  return reuse;
 }
}

代码示例来源：origin: org.gradoop/gradoop-flink

/**
  * {@inheritDoc}
  */
 @Override
 public boolean filter(V vertex) throws Exception {
  long degree = Long.parseLong(vertex.getPropertyValue(propertyNameOfDegree).toString());
  long maxDegree = Long.parseLong(vertex.getPropertyValue(propertyNameofMaxDegree).toString());
  return randomGenerator.nextFloat() <= (degree / (double) maxDegree) * threshold;
 }
}

代码示例来源：origin: org.gradoop/gradoop-flink

/**
  * {@inheritDoc}
  */
 @Override
 public Tuple3<Edge, Boolean, Boolean> join(Tuple3<Edge, GradoopId, Boolean> interim,
  Vertex vertex) {
  reuse.f0 = interim.f0;
  reuse.f1 = interim.f2;
  reuse.f2 = vertex.getPropertyValue(propertyKey).getBoolean();
  return reuse;
 }
}

代码示例来源：origin: dbs-leipzig/gradoop

@Override
 public boolean filter(V vertex) throws Exception {
  long degree = Long.parseLong(vertex.getPropertyValue(degreeType.getName()).toString());

  if (degree > degreeThreshold) {
   return true;
  } else {
   return randomGenerator.nextFloat() <= threshold;
  }
 }
}

代码示例来源：origin: org.gradoop/gradoop-flink

/**
  * @param vertex the given vertex
  * @return the degree of that vertex
  */
 @Override
 public Tuple1<Long> map(Vertex vertex) {
  return new Tuple1<>(Long.parseLong(vertex.getPropertyValue(nameOfDegreeProperty).toString()));
 }
}

代码示例来源：origin: org.gradoop/gradoop-flink

/**
  * {@inheritDoc}
  */
 @Override
 public boolean filter(V vertex) throws Exception {
  if (vertex.hasProperty(degreePropertyName)) {
   return Long.parseLong(vertex.getPropertyValue(degreePropertyName).toString()) != degree;
  } else {
   return true;
  }
 }
}

代码示例来源：origin: dbs-leipzig/gradoop

@Override
 public boolean filter(V vertex) throws Exception {
  if (vertex.hasProperty(degreePropertyName)) {
   return Long.parseLong(vertex.getPropertyValue(degreePropertyName).toString()) != degree;
  } else {
   return true;
  }
 }
}

代码示例来源：origin: dbs-leipzig/gradoop

/**
  * @param vertex the given vertex
  * @return the degree of that vertex
  */
 @Override
 public Tuple1<Long> map(Vertex vertex) {
  return new Tuple1<>(Long.parseLong(vertex.getPropertyValue(nameOfDegreeProperty).toString()));
 }
}

代码示例来源：origin: dbs-leipzig/gradoop

@Override
 public Tuple3<Edge, GradoopId, Boolean> join(Edge edge, Vertex vertex) throws Exception {
  reuse.f0 = edge;
  reuse.f1 = edge.getTargetId();
  reuse.f2 = vertex.getPropertyValue(propertyKey).getBoolean();
  return reuse;
 }
}

代码示例来源：origin: org.gradoop/gradoop-flink

/**
  * {@inheritDoc}
  */
 @Override
 public Tuple3<Edge, GradoopId, Boolean> join(Edge edge, Vertex vertex) throws Exception {
  reuse.f0 = edge;
  reuse.f1 = edge.getTargetId();
  reuse.f2 = vertex.getPropertyValue(propertyKey).getBoolean();
  return reuse;
 }
}

代码示例来源：origin: org.gradoop/gradoop-flink

@Override
 public org.apache.flink.graph.Vertex<GradoopId, PropertyValue> map(
  Vertex epgmVertex) throws Exception {
  reuseVertex.setId(epgmVertex.getId());
  reuseVertex.setValue(epgmVertex.getPropertyValue(propertyKey));
  return reuseVertex;
 }
}

代码示例来源：origin: dbs-leipzig/gradoop

@Override
 public org.apache.flink.graph.Vertex<GradoopId, PropertyValue> map(
  Vertex epgmVertex) throws Exception {
  reuseVertex.setId(epgmVertex.getId());
  reuseVertex.setValue(epgmVertex.getPropertyValue(propertyKey));
  return reuseVertex;
 }
}

代码示例来源：origin: org.gradoop/gradoop-flink

@Override
 public Edge join(Edge edge, Vertex vertex) throws Exception {
  PropertyValue newEdgeValue = vertex.getPropertyValue(propertyKey);
  if (edge.hasProperty(propertyKey)) {
   if (edge.getPropertyValue(propertyKey).compareTo(newEdgeValue) < 0) {
    return edge;
   }
  }
  edge.setProperty(propertyKey, newEdgeValue);
  return edge;
 }
}

代码示例来源：origin: dbs-leipzig/gradoop

static Vertex transformVertex(Vertex current, Vertex transformed) {
 transformed.setLabel(current.getLabel());
 if (current.getLabel().equals("A")) {
  transformed.setProperty("a", current.getPropertyValue("a").getInt() + 1);
  transformed.setProperty("b", current.getPropertyValue("b").getInt() - 1);
 } else if (current.getLabel().equals("B")) {
  transformed.setProperty("d", current.getPropertyValue("c"));
 }
 return transformed;
}

代码示例来源：origin: dbs-leipzig/gradoop

@Test
public void testDerivedNonOverlappingGraphs() throws Exception {
 FlinkAsciiGraphLoader loader = getLoaderFromString("g[(a {x: true}),(b {x: false})]");
 LogicalGraph baseGraph = loader.getLogicalGraphByVariable("g");
 LogicalGraph derivedGraph1 = baseGraph.vertexInducedSubgraph(v -> v.getPropertyValue("x").getBoolean());
 LogicalGraph derivedGraph2 = baseGraph.vertexInducedSubgraph(v -> !v.getPropertyValue("x").getBoolean());
 loader.appendToDatabaseFromString("expected[(a)]");
 LogicalGraph expected = loader.getLogicalGraphByVariable("expected");
 collectAndAssertTrue(derivedGraph1.exclude(derivedGraph2).equalsByElementIds(expected));
}

代码示例来源：origin: dbs-leipzig/gradoop

@Test
public void testDerivedNonOverlappingGraphs() throws Exception {
 FlinkAsciiGraphLoader loader = getLoaderFromString("g[(a {x: true}),(b {x: false})]");
 LogicalGraph baseGraph = loader.getLogicalGraphByVariable("g");
 LogicalGraph derivedGraph1 = baseGraph.vertexInducedSubgraph(v -> v.getPropertyValue("x").getBoolean());
 LogicalGraph derivedGraph2 = baseGraph.vertexInducedSubgraph(v -> !v.getPropertyValue("x").getBoolean());
 loader.appendToDatabaseFromString("expected[]");
 LogicalGraph expected = loader.getLogicalGraphByVariable("expected");
 collectAndAssertTrue(derivedGraph1.overlap(derivedGraph2).equalsByElementIds(expected));
}

代码示例来源：origin: dbs-leipzig/gradoop

@Test
public void testDerivedNonOverlappingGraphs() throws Exception {
 FlinkAsciiGraphLoader loader = getLoaderFromString("g[(a {x: true}), (b {x: false})]");
 LogicalGraph baseGraph = loader.getLogicalGraphByVariable("g");
 LogicalGraph derivedGraph1 = baseGraph.vertexInducedSubgraph(v -> v.getPropertyValue("x").getBoolean());
 LogicalGraph derivedGraph2 = baseGraph.vertexInducedSubgraph(v -> !v.getPropertyValue("x").getBoolean());
 loader.appendToDatabaseFromString("expected[(a),(b)]");
 LogicalGraph expected = loader.getLogicalGraphByVariable("expected");
 collectAndAssertTrue(derivedGraph1.combine(derivedGraph2).equalsByElementIds(expected));
}

代码示例来源：origin: dbs-leipzig/gradoop

@Override
public void testNonConnectedGraph() throws Exception {
 validateGraphProperties(nonConnectedGraph);
 List<Vertex> vertices = nonConnectedGraph.getVertices().collect();
 for (Vertex v : vertices) {
  assertEquals(
   "Wrong local value for not connected vertex: " + v.getId().toString() + ", should be 0",
   0d,
   v.getPropertyValue(ClusteringCoefficientBase.PROPERTY_KEY_LOCAL).getDouble(), 0.0);
 }
}

代码示例来源：origin: dbs-leipzig/gradoop

@Override
public void testNonConnectedGraph() throws Exception {
 validateGraphProperties(nonConnectedGraph);
 List<Vertex> vertices = nonConnectedGraph.getVertices().collect();
 for (Vertex v : vertices) {
  assertEquals(
   "Wrong local value for not connected vertex: " + v.getId().toString() + ", should be 0",
   0d,
   v.getPropertyValue(ClusteringCoefficientBase.PROPERTY_KEY_LOCAL).getDouble(), 0.0);
 }
}

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

vertex

相关文章

    查看更多

    热门标签

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

    最新文章

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