Added ids as properties to RDF data

Author: ArnauPrat

src/main/java/ldbc/socialnet/dbgen/generator/MRGenerateUsers.java

@@ -570,8 +570,8 @@ public int runGenerateJob(Configuration conf) throws Exception {
 	    long end = System.currentTimeMillis();
 	    System.out.println(((end - start) / 1000)
 	                    + " total seconds");
-        fs.copyToLocalFile(new Path(socialNetDir + "/m0factors.txt"), new Path("./"));
         for( int i = 0; i < numThreads; ++i ) {
+            fs.copyToLocalFile(new Path(socialNetDir + "/m"+i+"factors.txt"), new Path("./"));
             fs.copyToLocalFile(new Path(socialNetDir + "/m0friendList"+i+".csv"), new Path("./"));
         }
 	    return res;

src/main/java/ldbc/socialnet/dbgen/serializer/Turtle.java

@@ -208,6 +208,9 @@ public void serialize(UserInfo info) {
         String prefix = SN.getPersonURI(info.user.getAccountId());
         AddTriple(result, true, false, prefix, RDF.type, SNVOC.Person);
 
+        AddTriple(result, false, false, prefix, SNVOC.id,
+                createLiteral(Long.toString(info.user.getAccountId())));
+
         AddTriple(result, false, false, prefix, SNVOC.firstName,
                 createLiteral(info.extraInfo.getFirstName()));
 
@@ -289,6 +292,10 @@ public void serialize(Post post) {
         String prefix = SN.getPostURI(post.getMessageId());
 
         AddTriple(result, true, false, prefix, RDF.type, SNVOC.Post);
+
+        AddTriple(result, false, false, prefix, SNVOC.id,
+                createLiteral(SN.formId(post.getMessageId())));
+
         AddTriple(result, false, false, prefix, SNVOC.creationDate,
                 createDataTypeLiteral(dateString, XSD.DateTime));
         if (post.getIpAddress() != null) {
@@ -360,6 +367,10 @@ public void serialize(Photo photo) {
 
         String prefix = SN.getPostURI(photo.getMessageId());
         AddTriple(result, true, false, prefix, RDF.type, SNVOC.Post);
+
+        AddTriple(result, false, false, prefix, SNVOC.id,
+                createLiteral(SN.formId(photo.getMessageId())));
+
         AddTriple(result, false, false, prefix, SNVOC.hasImage, createLiteral(photo.getContent()));
         date.setTimeInMillis(photo.getCreationDate());
         String dateString = DateGenerator.formatDateDetail(date);
@@ -398,6 +409,10 @@ public void serialize(Comment comment) {
         String dateString = DateGenerator.formatDateDetail(date);
 
         AddTriple(result, true, false, prefix, RDF.type, SNVOC.Comment);
+
+        AddTriple(result, false, false, prefix, SNVOC.id,
+                createLiteral(SN.formId(comment.getMessageId())));
+
         AddTriple(result, false, false, prefix, SNVOC.creationDate, createDataTypeLiteral(dateString, XSD.DateTime));
         if (comment.getIpAddress() != null) {
             AddTriple(result, false, false, prefix, SNVOC.ipaddress,
@@ -442,6 +457,10 @@ public void serialize(Group group) {
 
         String forumPrefix = SN.getForumURI(group.getGroupId());
         AddTriple(result, true, false, forumPrefix, RDF.type, SNVOC.Forum);
+
+        AddTriple(result, false, false, forumPrefix, SNVOC.id,
+                createLiteral(SN.formId(group.getGroupId())));
+
         AddTriple(result, false, false, forumPrefix, SNVOC.title, createLiteral(group.getGroupName()));
         AddTriple(result, false, true, forumPrefix, SNVOC.creationDate,
                 createDataTypeLiteral(dateString, XSD.DateTime));
@@ -511,6 +530,7 @@ public void serialize(Organization organization) {
         StringBuffer result = new StringBuffer(19000);
         writeDBPData(DBP.fullPrefixed(organization.name), RDF.type, DBPOWL.Organisation);
         writeDBPData(DBP.fullPrefixed(organization.name), FOAF.Name, createLiteral(organization.name));
+        writeDBPData(DBP.fullPrefixed(organization.name), SNVOC.id, createLiteral(Long.toString(organization.id)));
         createTripleSPO(result, DBP.fullPrefixed(organization.name),
                 SNVOC.locatedIn, DBP.fullPrefixed(locationDic.getLocationName(organization.location)));
         toWriter(result.toString());
@@ -520,6 +540,7 @@ public void serialize(Organization organization) {
     public void serialize(Tag tag) {
         StringBuffer result = new StringBuffer(350);
         writeDBPData(DBP.fullPrefixed(tag.name), FOAF.Name, createLiteral(tag.name));
+        writeDBPData(DBP.fullPrefixed(tag.name), SNVOC.id, createLiteral(Long.toString(tag.id)));
         Integer tagClass = tag.tagClass;
         writeDBPData(DBP.fullPrefixed(tag.name), RDF.type, DBPOWL.prefixed(tagDic.getClassName(tagClass)));
     }
@@ -539,6 +560,7 @@ public void serialize(Location location) {
         writeDBPData(DBP.fullPrefixed(name), RDF.type, DBPOWL.Place);
         writeDBPData(DBP.fullPrefixed(name), RDF.type, type);
         writeDBPData(DBP.fullPrefixed(name), FOAF.Name, createLiteral(name));
+        writeDBPData(DBP.fullPrefixed(name), SNVOC.id, createLiteral(Long.toString(location.getId())));
         if (location.getType() != Location.CONTINENT) {
             String countryName = locationDic.getLocationName(locationDic.belongsTo(location.getId()));
             createTripleSPO(result, DBP.fullPrefixed(name), SNVOC.isPartOf, DBP.fullPrefixed(countryName));

src/main/java/ldbc/socialnet/dbgen/vocabulary/SNVOC.java

@@ -43,7 +43,9 @@ public class SNVOC{
 
 	public static final String NAMESPACE = "http://www.ldbc.eu/ldbc_socialnet/1.0/vocabulary/";
 	public static final String PREFIX = "snvoc:";
-	
+
+
+
 	//person
     public static final String Person          =  PREFIX+"Person";
     public static final String creationDate    =  PREFIX+"creationDate";
@@ -66,7 +68,7 @@ public class SNVOC{
     public static final String workFrom        =  PREFIX+"workFrom";
     public static final String hasOrganisation =  PREFIX+"hasOrganisation";
     public static final String hasPost         =  PREFIX+"hasPost";
-    public static final String hasComment         =  PREFIX+"hasComment";
+    public static final String hasComment      =  PREFIX+"hasComment";
 
     //Forum
     public static final String Forum        =  PREFIX+"Forum";
@@ -90,6 +92,8 @@ public class SNVOC{
     public static final String length      =  PREFIX+"length"; 
 
     //Others
+    public static final String id           = PREFIX+"id";
+    public static final String Name           = PREFIX+"Name";
     public static final String Organisation =  PREFIX+"Organisation";
     public static final String Tag          =  PREFIX+"Tag";
     public static final String TagClass     =  PREFIX+"TagClass";