Skip to content

Commit c6844ea

Browse files
committed
Cleanup activity serializers
1 parent 70ab40e commit c6844ea

File tree

3 files changed

+6
-31
lines changed

3 files changed

+6
-31
lines changed

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -79,9 +79,6 @@ public void export(Like like) {
7979

8080
}
8181

82-
83-
abstract public void reset();
84-
8582
abstract protected void serialize(final Forum forum);
8683

8784
abstract protected void serialize(final Post post);

src/main/java/ldbc/snb/datagen/serializer/snb/csv/dynamicserializer/activity/CSVDynamicActivitySerializer.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -37,19 +37,20 @@ Linked Data Benchmark Council (http://www.ldbcouncil.org)
3737

3838
import com.google.common.collect.ImmutableList;
3939
import ldbc.snb.datagen.dictionary.Dictionaries;
40+
import ldbc.snb.datagen.entities.dynamic.Forum;
4041
import ldbc.snb.datagen.entities.dynamic.messages.Comment;
4142
import ldbc.snb.datagen.entities.dynamic.messages.Photo;
4243
import ldbc.snb.datagen.entities.dynamic.messages.Post;
4344
import ldbc.snb.datagen.entities.dynamic.relations.ForumMembership;
4445
import ldbc.snb.datagen.entities.dynamic.relations.Like;
45-
import ldbc.snb.datagen.entities.dynamic.Forum;
4646
import ldbc.snb.datagen.serializer.DynamicActivitySerializer;
4747
import ldbc.snb.datagen.serializer.snb.csv.FileName;
48-
import static ldbc.snb.datagen.serializer.snb.csv.FileName.*;
4948

5049
import java.util.Arrays;
5150
import java.util.List;
5251

52+
import static ldbc.snb.datagen.serializer.snb.csv.FileName.*;
53+
5354
/**
5455
* @author aprat
5556
*/
@@ -153,8 +154,4 @@ protected void serialize(final Like like) {
153154
}
154155
}
155156

156-
public void reset() {
157-
// Intentionally left empty
158-
}
159-
160157
}

src/main/java/ldbc/snb/datagen/serializer/snb/csv/dynamicserializer/activity/CSVMergeForeignDynamicActivitySerializer.java

Lines changed: 3 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -37,24 +37,19 @@ Linked Data Benchmark Council (http://www.ldbcouncil.org)
3737

3838
import com.google.common.collect.ImmutableList;
3939
import ldbc.snb.datagen.dictionary.Dictionaries;
40-
import ldbc.snb.datagen.hadoop.writer.HDFSCSVWriter;
40+
import ldbc.snb.datagen.entities.dynamic.Forum;
4141
import ldbc.snb.datagen.entities.dynamic.messages.Comment;
4242
import ldbc.snb.datagen.entities.dynamic.messages.Photo;
4343
import ldbc.snb.datagen.entities.dynamic.messages.Post;
4444
import ldbc.snb.datagen.entities.dynamic.relations.ForumMembership;
4545
import ldbc.snb.datagen.entities.dynamic.relations.Like;
46-
import ldbc.snb.datagen.entities.dynamic.Forum;
4746
import ldbc.snb.datagen.serializer.DynamicActivitySerializer;
48-
import static ldbc.snb.datagen.serializer.snb.csv.FileName.*;
49-
5047
import ldbc.snb.datagen.serializer.snb.csv.FileName;
51-
import org.apache.hadoop.conf.Configuration;
5248

53-
import java.io.IOException;
54-
import java.util.ArrayList;
5549
import java.util.Arrays;
5650
import java.util.List;
57-
import java.util.Map;
51+
52+
import static ldbc.snb.datagen.serializer.snb.csv.FileName.*;
5853

5954
/**
6055
* Created by aprat on 17/02/15.
@@ -180,18 +175,4 @@ protected void serialize(final Like like) {
180175
}
181176
}
182177

183-
public void reset() {
184-
// Intentionally left empty
185-
}
186-
187-
@Override
188-
public void initialize(Configuration conf, int reducerId) throws IOException {
189-
190-
}
191-
192-
@Override
193-
public void close() {
194-
195-
}
196-
197178
}

0 commit comments

Comments
 (0)