本文整理了Java中org.gradoop.common.model.impl.pojo.Vertex.getId()
方法的一些代码示例,展示了Vertex.getId()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Vertex.getId()
方法的具体详情如下:
包路径:org.gradoop.common.model.impl.pojo.Vertex
类名称:Vertex
方法名:getId
暂无
代码示例来源: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 Tuple2<Vertex, GradoopId> map(Vertex vertex) throws Exception {
reuse.f0 = vertex;
reuse.f1 = vertex.getId();
return reuse;
}
}
代码示例来源:origin: dbs-leipzig/gradoop
@Override
public Tuple2<GradoopId, Mutation> map(Vertex vertex) throws Exception {
GradoopId key = vertex.getId();
Put put = new Put(vertexHandler.getRowKey(vertex.getId()));
put = vertexHandler.writeVertex(put, vertex);
reuseTuple.f0 = key;
reuseTuple.f1 = put;
return reuseTuple;
}
}
代码示例来源:origin: org.gradoop/gradoop-flink
@Override
public org.apache.flink.graph.Vertex<GradoopId, NullValue> map(Vertex epgmVertex) {
reuseVertex.setId(epgmVertex.getId());
return reuseVertex;
}
}
代码示例来源:origin: dbs-leipzig/gradoop
@Override
public org.apache.flink.graph.Vertex<GradoopId, NullValue> map(Vertex epgmVertex) {
reuseVertex.setId(epgmVertex.getId());
return reuseVertex;
}
}
代码示例来源: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
@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: org.gradoop/gradoop-flink
@Override
public org.apache.flink.graph.Vertex<GradoopId, GradoopId> map(Vertex epgmVertex) {
GradoopId id = epgmVertex.getId();
reuseVertex.setId(id);
reuseVertex.setValue(id);
return reuseVertex;
}
}
代码示例来源:origin: dbs-leipzig/gradoop
@Override
public org.apache.flink.graph.Vertex<GradoopId, GradoopId> map(Vertex epgmVertex) {
GradoopId id = epgmVertex.getId();
reuseVertex.setId(id);
reuseVertex.setValue(id);
return reuseVertex;
}
}
代码示例来源: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: org.gradoop/gradoop-flink
/**
* {@inheritDoc}
*/
@Override
public void flatMap(V vertex,
Collector<Tuple2<GradoopId, PropertyValue>> collector) throws Exception {
List<PropertyValue> splitValues = function.apply(vertex);
for (PropertyValue value : splitValues) {
collector.collect(new Tuple2<>(vertex.getId(), value));
}
}
}
代码示例来源:origin: dbs-leipzig/gradoop
@Override
public void flatMap(V vertex,
Collector<Tuple2<GradoopId, PropertyValue>> collector) throws Exception {
List<PropertyValue> splitValues = function.apply(vertex);
for (PropertyValue value : splitValues) {
collector.collect(new Tuple2<>(vertex.getId(), value));
}
}
}
代码示例来源:origin: org.gradoop/gradoop-flink
@Override
public void flatMap(Vertex vertex, Collector<VertexString> collector) throws Exception {
GradoopId vertexId = vertex.getId();
String vertexLabel = "(" + label(vertex) + ")";
for (GradoopId graphId : vertex.getGraphIds()) {
collector.collect(new VertexString(graphId, vertexId, vertexLabel));
}
}
}
代码示例来源:origin: org.gradoop/gradoop-flink
@Override
public IdWithCandidates<GradoopId> map(V v) throws Exception {
reuseTuple.setId(v.getId());
reuseTuple.setCandidates(getCandidates(vertexCount,
ElementMatcher.getMatches(v, queryVertices, DEFAULT_VERTEX_LABEL)));
return reuseTuple;
}
}
代码示例来源:origin: dbs-leipzig/gradoop
@Override
public Tuple2<GradoopIdSet, IdWithCandidates<GradoopId>> map(V v)
throws Exception {
reuseTuple.f0 = v.getGraphIds();
reuseTuple.f1.setId(v.getId());
reuseTuple.f1.setCandidates(getCandidates(vertexCount,
ElementMatcher.getMatches(v, queryVertices, DEFAULT_VERTEX_LABEL)));
return reuseTuple;
}
}
代码示例来源:origin: dbs-leipzig/gradoop
private void validateVertex(HBaseEPGMStore graphStore, Vertex originalVertex) throws IOException {
EPGMVertex loadedVertex = graphStore.readVertex(originalVertex.getId());
validateEPGMElements(originalVertex, loadedVertex);
validateEPGMGraphElements(originalVertex, loadedVertex);
}
代码示例来源: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 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
@Override
public void testFullyConnectedGraph() throws Exception {
validateGraphProperties(fullGraph);
List<Vertex> vertices = fullGraph.getVertices().collect();
for (Vertex v : vertices) {
assertEquals(
"Wrong local value for clique-vertex '" + v.getId().toString() + "', should be 1",
1d,
v.getPropertyValue(ClusteringCoefficientBase.PROPERTY_KEY_LOCAL).getDouble(), 0.0);
}
}
代码示例来源:origin: dbs-leipzig/gradoop
@Test
public void testVariableMappingCreation() throws Exception {
AddGraphElementToNewGraph<Vertex> udf =
new AddGraphElementToNewGraph<>(new GraphHeadFactory(), "a");
Vertex vertex = new VertexFactory().createVertex();
Tuple2<Vertex, GraphHead> result = udf.map(vertex);
assertTrue(result.f1.hasProperty(PatternMatching.VARIABLE_MAPPING_KEY));
Map<PropertyValue, PropertyValue> variableMapping =
result.f1.getPropertyValue(PatternMatching.VARIABLE_MAPPING_KEY).getMap();
assertEquals(vertex.getId(), variableMapping.get(PropertyValue.create("a")).getGradoopId());
}
}
内容来源于网络,如有侵权,请联系作者删除!