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

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

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

Vertex.addGraphId介绍

暂无

代码示例

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

/**
 * Initializes an EPGM vertex using the specified parameters and adds its label
 * if the given vertex was created for the return pattern.
 *
 * @param out flat map collector
 * @param graphHead graph head to assign vertex to
 * @param vertexId vertex identifier
 * @param label label associated with vertex
 */
private void initVertexWithData(Collector<Element> out, GraphHead graphHead, GradoopId vertexId,
                String label) {
 if (!processedIds.contains(vertexId)) {
  Vertex v = vertexFactory.initVertex(vertexId);
  v.addGraphId(graphHead.getId());
  v.setLabel(label);
  out.collect(v);
  processedIds.add(vertexId);
 }
}

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

/**
 * Initializes an EPGM vertex using the specified parameters and adds its label
 * if the given vertex was created for the return pattern.
 *
 * @param out flat map collector
 * @param graphHead graph head to assign vertex to
 * @param vertexId vertex identifier
 * @param label label associated with vertex
 */
private void initVertexWithData(Collector<Element> out, GraphHead graphHead, GradoopId vertexId,
                String label) {
 if (!processedIds.contains(vertexId)) {
  Vertex v = vertexFactory.initVertex(vertexId);
  v.addGraphId(graphHead.getId());
  v.setLabel(label);
  out.collect(v);
  processedIds.add(vertexId);
 }
}

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

idMap.put(Long.valueOf(fields[1]), gradoopId);
Vertex vertex = vertexFactory.initVertex(gradoopId, getLabel(fields, 2));
vertex.addGraphId(graphHead.getId());
vertices.add(vertex);

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

idMap.put(Long.valueOf(fields[1]), gradoopId);
Vertex vertex = vertexFactory.initVertex(gradoopId, getLabel(fields, 2));
vertex.addGraphId(graphHead.getId());
vertices.add(vertex);

代码示例来源: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;
 }
}

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

@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;
 }
}

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

if (!isProcessed(vertexMapping, i)) {
 Vertex v = vertexFactory.initVertex(vertexMapping[i]);
 v.addGraphId(graphHead.getId());
 out.collect(v);

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

if (!isProcessed(vertexMapping, i)) {
 Vertex v = vertexFactory.initVertex(vertexMapping[i]);
 v.addGraphId(graphHead.getId());
 out.collect(v);

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

@BeforeClass
public static void setup() {
 ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
 GradoopFlinkConfig config = GradoopFlinkConfig.createConfig(env);
 GraphHead g0 = config.getGraphHeadFactory().createGraphHead("A");
 GraphHead g1 = config.getGraphHeadFactory().createGraphHead("B");
 Vertex v0 = config.getVertexFactory().createVertex("A");
 Vertex v1 = config.getVertexFactory().createVertex("B");
 Vertex v2 = config.getVertexFactory().createVertex("C");
 Edge e0 = config.getEdgeFactory().createEdge("a", v0.getId(), v1.getId());
 Edge e1 = config.getEdgeFactory().createEdge("b", v1.getId(), v2.getId());
 v0.addGraphId(g0.getId());
 v1.addGraphId(g0.getId());
 v1.addGraphId(g1.getId());
 v2.addGraphId(g1.getId());
 e0.addGraphId(g0.getId());
 e1.addGraphId(g1.getId());
 tx0 = new GraphTransaction(g0, Sets.newHashSet(v0, v1), Sets.newHashSet(e0));
 tx1 = new GraphTransaction(g1, Sets.newHashSet(v1, v2), Sets.newHashSet(e1));
}

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

@BeforeClass
public static void setup() {
 ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
 GradoopFlinkConfig config = GradoopFlinkConfig.createConfig(env);
 g0 = config.getGraphHeadFactory().createGraphHead("A");
 g1 = config.getGraphHeadFactory().createGraphHead("B");
 v0 = config.getVertexFactory().createVertex("A");
 v1 = config.getVertexFactory().createVertex("B");
 v2 = config.getVertexFactory().createVertex("C");
 e0 = config.getEdgeFactory().createEdge("a", v0.getId(), v1.getId());
 e1 = config.getEdgeFactory().createEdge("b", v1.getId(), v2.getId());
 v0.addGraphId(g0.getId());
 v1.addGraphId(g0.getId());
 v1.addGraphId(g1.getId());
 v2.addGraphId(g1.getId());
 e0.addGraphId(g0.getId());
 e1.addGraphId(g1.getId());
}

相关文章