Skip to content

Commit ca2ba63

Browse files
authored
Updated Mergeforeign to merge has_type foreign key into tag (#63)
1 parent 7206f5d commit ca2ba63

File tree

1 file changed

+2
-11
lines changed

1 file changed

+2
-11
lines changed

src/main/java/ldbc/snb/datagen/serializer/snb/interactive/CSVMergeForeignInvariantSerializer.java

Lines changed: 2 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,6 @@ public class CSVMergeForeignInvariantSerializer extends InvariantSerializer {
5858

5959
private enum FileNames {
6060
TAG("tag"),
61-
TAG_HAS_TYPE_TAGCLASS("tag_hasType_tagclass"),
6261
TAGCLASS("tagclass"),
6362
PLACE("place"),
6463
ORGANIZATION("organisation");
@@ -89,13 +88,9 @@ public void initialize(Configuration conf, int reducerId) throws IOException {
8988
arguments.add("id");
9089
arguments.add("name");
9190
arguments.add("url");
91+
arguments.add("hasType");
9292
writers[FileNames.TAG.ordinal()].writeHeader(arguments);
9393

94-
arguments.clear();
95-
arguments.add("Tag.id");
96-
arguments.add("TagClass.id");
97-
writers[FileNames.TAG_HAS_TYPE_TAGCLASS.ordinal()].writeHeader(arguments);
98-
9994
arguments.clear();
10095
arguments.add("id");
10196
arguments.add("name");
@@ -180,12 +175,8 @@ protected void serialize(final Tag tag) {
180175
arguments.add(Integer.toString(tag.id));
181176
arguments.add(tag.name);
182177
arguments.add(DBP.getUrl(tag.name));
183-
writers[FileNames.TAG.ordinal()].writeEntry(arguments);
184-
185-
arguments.clear();
186-
arguments.add(Integer.toString(tag.id));
187178
arguments.add(Integer.toString(tag.tagClass));
188-
writers[FileNames.TAG_HAS_TYPE_TAGCLASS.ordinal()].writeEntry(arguments);
179+
writers[FileNames.TAG.ordinal()].writeEntry(arguments);
189180
}
190181

191182
public void reset() {

0 commit comments

Comments
 (0)