org.gradoop.common.model.impl.pojo.Vertex类的使用及代码示例

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

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

Vertex介绍

[英]POJO Implementation of an EPGM vertex.
[中]EPGM顶点的POJO实现。

代码示例

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

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

@Override
public Vertex initVertex(final GradoopId id, final String label,
 final Properties properties, final GradoopIdSet graphs) {
 Preconditions.checkNotNull(id, "Identifier was null");
 Preconditions.checkNotNull(label, "Label was null");
 return new Vertex(id, label, properties, graphs);
}

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

@Override
 public GraphTransaction map(GraphTransaction graphTransaction)
   throws Exception {
  String label;
  for (Vertex vertex : graphTransaction.getVertices()) {
   label = vertexDictionary.get(Integer.parseInt(vertex.getLabel()));
   if (label != null) {
    vertex.setLabel(label);
   } else {
    vertex.setLabel(vertex.getLabel() + TLFConstants.EMPTY_LABEL);
   }
  }
  return graphTransaction;
 }
}

代码示例来源：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: org.gradoop/gradoop-flink

@Override
 public void flatMap(Vertex vertex, Collector<VertexString> collector)
   throws Exception {

  GradoopId vertexId = vertex.getId();
  String vertexLabel = "(" + vertex.getId() + ")";

  for (GradoopId graphId : vertex.getGraphIds()) {
   collector.collect(new VertexString(graphId, vertexId, vertexLabel));
  }

 }
}

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

Vertex row = new Vertex();
row.setId(GradoopId.fromString(source.getTopKey().getRow().toString()));
row.setGraphIds(new GradoopIdSet());
while (source.hasTop()) {
 Key key = source.getTopKey();
 Value value = source.getTopValue();
 if (!Objects.equals(row.getId().toString(), key.getRow().toString())) {
  break;
  row.setLabel(value.toString());
  break;
 case AccumuloTables.KEY.PROPERTY:
  row.setProperty(key.getColumnQualifier().toString(),
   PropertyValue.fromRawBytes(value.get()));
  break;
 case AccumuloTables.KEY.GRAPH:
  row.getGraphIds().add(GradoopId.fromString(key.getColumnQualifier().toString()));
  break;
 default:
return row.getLabel() == null ? null : row;

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

/**
 * Returns the gdl formatted vertex including the properties and the label on first occurrence
 * or otherwise just the variable name.
 *
 * @param v The vertex that should be formatted.
 * @param idToVertexName Maps GradoopId of a vertex to a string that represents the gdl
 *                       variable name
 * @return A GDL formatted vertex string.
 */
private String vertexToGDLString(Vertex v, Map<GradoopId, String> idToVertexName)  {
 return String.format("(%s:%s %s)",
  idToVertexName.get(v.getId()),
  v.getLabel(),
  propertiesToGDLString(v.getProperties()));
}

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

@Override
 public CSVVertex map(Vertex vertex) throws Exception {
  csvVertex.setId(vertex.getId().toString());
  csvVertex.setGradoopIds(collectionToCsvString(vertex.getGraphIds()));
  csvVertex.setLabel(StringEscaper.escape(vertex.getLabel(), CSVConstants.ESCAPED_CHARACTERS));
  csvVertex.setProperties(getPropertyString(vertex, MetaDataSource.VERTEX_TYPE));
  return csvVertex;
 }
}

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

@Override
 public void flatMap(Vertex vertex, Collector<Tuple2<PropertyValue, GradoopId>> out) {
  if (vertex.getProperties() != null &&
   vertex.getProperties().containsKey(originalPropertyName)) {
   PropertyValue pv = vertex.getPropertyValue(originalPropertyName);
   reuseTuple.f1 = vertex.getId();

   if (pv.isList()) {
    for (PropertyValue value : pv.getList()) {
     reuseTuple.f0 = value;
     out.collect(reuseTuple);
    }
   } else {
    reuseTuple.f0 = pv;
    out.collect(reuseTuple);
   }
  }
 }
}

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

/**
 * Relabel vertices and to drop properties.
 *
 * @param current current vertex
 * @param transformed copy of current except label and properties
 * @return current vertex with a new label depending on its type
 */
private static Vertex relabelVerticesAndRemoveProperties(Vertex current,
 Vertex transformed) {
 String label;
 if (current
  .getPropertyValue(BusinessTransactionGraphs.SUPERTYPE_KEY).getString()
  .equals(BusinessTransactionGraphs.SUPERCLASS_VALUE_TRANSACTIONAL)) {
  label = TRANSACTIONAL_PREFIX + current.getLabel();
 } else {
  label = MASTER_PREFIX + current.getPropertyValue(SOURCEID_KEY).toString();
 }
 transformed.setLabel(label);
 return transformed;
}

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

/**
 * Find all person who's age is not smaller than 35
 *
 * @throws Throwable if error
 */
@Test
public void findPersonByAge() throws Throwable {
 doTest(TEST02, (loader, store, config) -> {
  //vertex label and property query
  List<Vertex> inputVertices = loader.getVertices()
   .stream()
   .filter(it -> Objects.equals(it.getLabel(), "Person"))
   .filter(it -> it.getProperties() != null)
   .filter(it -> it.getProperties().get("age") != null)
   .filter(it -> it.getProperties().get("age").getInt() >= 35)
   .collect(Collectors.toList());
  List<Vertex> queryResult = store
   .getVertexSpace(
    Query.elements()
     .fromAll()
     .where(AccumuloFilters.propLargerThan("age", 35, true)))
   .readRemainsAndClose();
  validateEPGMElementCollections(inputVertices, queryResult);
 });
}

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

/**
  * {@inheritDoc}
  */
 @Override
 public Vertex cross(Tuple1<Long> longTuple1, Vertex vertex) {
  vertex.setProperty(nameOfMaxDegreeProperty, longTuple1.f0);
  return vertex;
 }
}

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

@Override
 public void flatMap(GraphTransaction graphTransaction, Collector<String> collector)
  throws Exception {
  for (Vertex vertex : graphTransaction.getVertices()) {
   collector.collect(vertex.getLabel());
  }
 }
}

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

/**
  * {@inheritDoc}
  */
 @Override
 public Tuple2<Vertex, GradoopId> map(Vertex vertex) throws Exception {
  reuse.f0 = vertex;
  reuse.f1 = vertex.getId();
  return reuse;
 }
}

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

@Override
 public void validateGraphProperties(LogicalGraph graph) throws Exception {
  List<Vertex> vertices = graph.getVertices().collect();
  for (Vertex v : vertices) {
   assertTrue("No local value stored in vertex: " + v.getId().toString(),
    v.hasProperty(ClusteringCoefficientBase.PROPERTY_KEY_LOCAL));
  }
 }
}

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

switch (String.valueOf(v.getPropertyValue("name"))) {
case "foo":
 assertNotNull(v.getProperties());
 assertEquals(4, v.getProperties().size());
 assertEquals("453", v.getPropertyValue("value1").getString());
 assertEquals("true", v.getPropertyValue("value2").getString());
 assertEquals("71.03", v.getPropertyValue("value3").getString());
 break;
case "bar":
 assertNotNull(v.getProperties());
 assertEquals(4, v.getProperties().size());
 assertEquals("76", v.getPropertyValue("value1").getString());
 assertEquals("false", v.getPropertyValue("value2").getString());
 assertEquals("33.4", v.getPropertyValue("value3").getString());
 break;
case "bla":
 assertNotNull(v.getProperties());
 assertEquals(3, v.getProperties().size());
 assertEquals("4568", v.getPropertyValue("value1").toString());
 assertFalse(v.hasProperty("value2"));
 assertEquals("9.42", v.getPropertyValue("value3").toString());
 break;
default:

代码示例来源：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: dbs-leipzig/gradoop

private GraphTransaction getGraphTransaction() {
  GraphHead graphHead = new GraphHead(GradoopId.get(), "Test", null);

  GradoopIdSet graphIds = GradoopIdSet.fromExisting(graphHead.getId());
  Set<Vertex> vertices = Sets.newHashSet();
  Set<Edge> edges = Sets.newHashSet();

  Properties aProperties = new Properties();
  aProperties.set("x", 1);
  Vertex v1 = new Vertex(GradoopId.get(), "A", aProperties, graphIds);
  Vertex v2 = new Vertex(GradoopId.get(), "B", null, graphIds);

  vertices.add(v1);
  vertices.add(v2);

  Properties loopProperties = new Properties();

  edges.add(new Edge(GradoopId.get(), "loop", v1.getId(), v1.getId(), loopProperties, graphIds));
  edges.add(new Edge(GradoopId.get(), "m", v1.getId(), v2.getId(), null, graphIds));
  edges.add(new Edge(GradoopId.get(), "m", v1.getId(), v2.getId(), null, graphIds));
  edges.add(new Edge(GradoopId.get(), "m", v2.getId(), v1.getId(), null, graphIds));

  return new GraphTransaction(graphHead, vertices, edges);
 }
}

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

@Override
 public Vertex cross(GraphHead searchGraphHead, GraphHead patternGraphSeachHead) throws Exception {
  REUSABLE_VERTEX.setLabel(patternGraphSeachHead.getLabel());
  REUSABLE_VERTEX.setProperties(patternGraphSeachHead.getProperties());
  REUSABLE_VERTEX.setId(newVertexId);
  REUSABLE_VERTEX.addGraphId(searchGraphHead.getId());
  return REUSABLE_VERTEX;
 }
}

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

vertex

相关文章

    查看更多

    热门标签

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

    最新文章

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