Put static and dynamic entities in different directories

Author: szarnyasg

src/main/java/ldbc/snb/datagen/serializer/DynamicActivitySerializer.java

@@ -91,5 +91,9 @@ public void export(Like like) {
 
     abstract protected void serialize(final Like like);
 
+    @Override
+    protected boolean isDynamic() {
+        return true;
+    }
 
 }

src/main/java/ldbc/snb/datagen/serializer/DynamicPersonSerializer.java

@@ -104,4 +104,10 @@ public String buildEmail(TreeSet<String> emails) {
     abstract protected void serialize(final WorkAt workAt);
 
     abstract protected void serialize(final Person p, final Knows knows);
+
+    @Override
+    protected boolean isDynamic() {
+        return true;
+    }
+
 }

src/main/java/ldbc/snb/datagen/serializer/LDBCSerializer.java

@@ -20,7 +20,7 @@ abstract public class LDBCSerializer {
     public void initialize(Configuration conf, int reducerId) throws IOException {
         for (FileName f : getFileNames()) {
             writers.put(f, new HDFSCSVWriter(
-                    conf.get("ldbc.snb.datagen.serializer.socialNetworkDir") + "/dynamic/",
+                    conf.get("ldbc.snb.datagen.serializer.socialNetworkDir") + (isDynamic() ? "/dynamic/" : "/static/"),
                     f.toString() + "_" + reducerId,
                     conf.getInt("ldbc.snb.datagen.numPartitions", 1),
                     conf.getBoolean("ldbc.snb.datagen.serializer.compressed", false), "|",
@@ -30,6 +30,8 @@ public void initialize(Configuration conf, int reducerId) throws IOException {
         writeFileHeaders();
     }
 
+    protected abstract boolean isDynamic();
+
     public void close() {
         for (FileName f : getFileNames()) {
             writers.get(f).close();

src/main/java/ldbc/snb/datagen/serializer/StaticSerializer.java

@@ -73,4 +73,9 @@ public void export(final Tag tag) {
 
     abstract protected void serialize(final Tag tag);
 
+    @Override
+    protected boolean isDynamic() {
+        return false;
+    }
+
 }