本文整理了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
暂无
代码示例来源: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());
}
内容来源于网络,如有侵权,请联系作者删除!