Skip to content

Commit b6d65f4

Browse files
szarnyasgszarnyasg
committed
Fixed compile errors
1 parent fd3cda7 commit b6d65f4

File tree

8 files changed

+62
-27
lines changed

8 files changed

+62
-27
lines changed

‎src/main/java/ldbc/snb/datagen/hadoop/serializer/HadoopPersonSerializer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ protected void setup(Context context) {
9999
public void reduce(TupleKey key, Iterable<Person> valueSet, Context context)
100100
throws IOException, InterruptedException {
101101
// SN.machineId = key.block;
102-
dynamicPersonSerializer_.reset();
102+
// dynamicPersonSerializer_.reset();
103103
for (Person p : valueSet) {
104104
if (p.creationDate() < Dictionaries.dates.getUpdateThreshold() || !DatagenParams.updateStreams) {
105105
dynamicPersonSerializer_.export(p);

‎src/main/java/ldbc/snb/datagen/hadoop/serializer/HadoopPersonSortAndSerializer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ protected void setup(Context context) {
105105
public void reduce(BlockKey key, Iterable<Person> valueSet, Context context)
106106
throws IOException, InterruptedException {
107107
SN.machineId = key.block;
108-
dynamicPersonSerializer_.reset();
108+
// dynamicPersonSerializer_.reset();
109109
for (Person p : valueSet) {
110110
if (p.creationDate() < Dictionaries.dates.getUpdateThreshold() || !DatagenParams.updateStreams) {
111111
dynamicPersonSerializer_.export(p);

‎src/main/java/ldbc/snb/datagen/serializer/empty/EmptyDynamicPersonSerializer.java

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -40,15 +40,27 @@ Linked Data Benchmark Council (http://www.ldbcouncil.org)
4040
import ldbc.snb.datagen.entities.dynamic.relations.StudyAt;
4141
import ldbc.snb.datagen.entities.dynamic.relations.WorkAt;
4242
import ldbc.snb.datagen.serializer.DynamicPersonSerializer;
43+
import ldbc.snb.datagen.serializer.snb.csv.FileName;
4344
import org.apache.hadoop.conf.Configuration;
4445

4546
import java.io.IOException;
47+
import java.util.List;
4648

4749
/**
4850
* Created by aprat on 30/01/15.
4951
*/
5052
public class EmptyDynamicPersonSerializer extends DynamicPersonSerializer {
5153

54+
@Override
55+
public List<FileName> getFileNames() {
56+
return null;
57+
}
58+
59+
@Override
60+
public void writeFileHeaders() {
61+
62+
}
63+
5264
@Override
5365
public void initialize(Configuration conf, int reducerId) throws IOException {
5466
//Intentionally left empty
@@ -79,9 +91,4 @@ protected void serialize(final Person p, final Knows knows) {
7991
//Intentionally left empty
8092
}
8193

82-
@Override
83-
public void reset() {
84-
//Intentionally left empty
85-
}
86-
8794
}

‎src/main/java/ldbc/snb/datagen/serializer/graphalytics/CSVDynamicPersonSerializer.java

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,10 +43,12 @@ Linked Data Benchmark Council (http://www.ldbcouncil.org)
4343
import ldbc.snb.datagen.entities.dynamic.relations.WorkAt;
4444
import ldbc.snb.datagen.hadoop.writer.HDFSCSVWriter;
4545
import ldbc.snb.datagen.serializer.DynamicPersonSerializer;
46+
import ldbc.snb.datagen.serializer.snb.csv.FileName;
4647
import org.apache.hadoop.conf.Configuration;
4748

4849
import java.io.IOException;
4950
import java.util.ArrayList;
51+
import java.util.List;
5052

5153
public class CSVDynamicPersonSerializer extends DynamicPersonSerializer {
5254

@@ -66,6 +68,16 @@ public String toString() {
6668
}
6769
}
6870

71+
@Override
72+
public List<FileName> getFileNames() {
73+
return null;
74+
}
75+
76+
@Override
77+
public void writeFileHeaders() {
78+
79+
}
80+
6981
@Override
7082
public void initialize(Configuration conf, int reducerId) throws IOException {
7183
int numFiles = FileNames.values().length;
@@ -116,8 +128,4 @@ protected void serialize(final Person p, Knows knows) {
116128
writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);
117129
}
118130

119-
@Override
120-
public void reset() {
121-
//Intentionally left empty
122-
}
123131
}

‎src/main/java/ldbc/snb/datagen/serializer/graphalytics/CSVDynamicPersonSerializerExtended.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -142,8 +142,4 @@ protected void serialize(Person p, Knows knows) {
142142
writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);
143143
}
144144

145-
@Override
146-
public void reset() {
147-
//Intentionally left empty
148-
}
149145
}

‎src/main/java/ldbc/snb/datagen/serializer/graphalytics/pgx/CSVDynamicPersonSerializer.java

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,10 +43,12 @@ Linked Data Benchmark Council (http://www.ldbcouncil.org)
4343
import ldbc.snb.datagen.entities.dynamic.relations.WorkAt;
4444
import ldbc.snb.datagen.hadoop.writer.HDFSCSVWriter;
4545
import ldbc.snb.datagen.serializer.DynamicPersonSerializer;
46+
import ldbc.snb.datagen.serializer.snb.csv.FileName;
4647
import org.apache.hadoop.conf.Configuration;
4748

4849
import java.io.IOException;
4950
import java.util.ArrayList;
51+
import java.util.List;
5052

5153
public class CSVDynamicPersonSerializer extends DynamicPersonSerializer {
5254

@@ -66,6 +68,16 @@ public String toString() {
6668
}
6769
}
6870

71+
@Override
72+
public List<FileName> getFileNames() {
73+
return null;
74+
}
75+
76+
@Override
77+
public void writeFileHeaders() {
78+
79+
}
80+
6981
@Override
7082
public void initialize(Configuration conf, int reducerId) throws IOException {
7183
int numFiles = FileNames.values().length;
@@ -109,8 +121,4 @@ protected void serialize(final Person p, Knows knows) {
109121
writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);
110122
}
111123

112-
@Override
113-
public void reset() {
114-
//Intentionally left empty
115-
}
116124
}

‎src/main/java/ldbc/snb/datagen/serializer/snb/csv/dynamicserializer/person/CSVCompositeMergeForeignDynamicPersonSerializer.java

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -42,11 +42,13 @@ Linked Data Benchmark Council (http://www.ldbcouncil.org)
4242
import ldbc.snb.datagen.entities.dynamic.relations.WorkAt;
4343
import ldbc.snb.datagen.hadoop.writer.HDFSCSVWriter;
4444
import ldbc.snb.datagen.serializer.DynamicPersonSerializer;
45+
import ldbc.snb.datagen.serializer.snb.csv.FileName;
4546
import org.apache.hadoop.conf.Configuration;
4647

4748
import java.io.IOException;
4849
import java.util.ArrayList;
4950
import java.util.Iterator;
51+
import java.util.List;
5052

5153
/**
5254
* Created by aprat on 17/02/15.
@@ -73,6 +75,16 @@ public String toString() {
7375
}
7476
}
7577

78+
@Override
79+
public List<FileName> getFileNames() {
80+
return null;
81+
}
82+
83+
@Override
84+
public void writeFileHeaders() {
85+
86+
}
87+
7688
public void initialize(Configuration conf, int reducerId) throws IOException {
7789
int numFiles = FileNames.values().length;
7890
writers = new HDFSCSVWriter[numFiles];
@@ -214,8 +226,4 @@ protected void serialize(final Person p, Knows knows) {
214226
writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);
215227
}
216228

217-
@Override
218-
public void reset() {
219-
// Intentionally left empty
220-
}
221229
}

‎src/main/java/ldbc/snb/datagen/serializer/snb/csv/dynamicserializer/person/CSVDynamicPersonSerializer.java

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -45,11 +45,13 @@ Linked Data Benchmark Council (http://www.ldbcouncil.org)
4545
import ldbc.snb.datagen.entities.dynamic.relations.WorkAt;
4646
import ldbc.snb.datagen.hadoop.writer.HDFSCSVWriter;
4747
import ldbc.snb.datagen.serializer.DynamicPersonSerializer;
48+
import ldbc.snb.datagen.serializer.snb.csv.FileName;
4849
import org.apache.hadoop.conf.Configuration;
4950

5051
import java.io.IOException;
5152
import java.util.ArrayList;
5253
import java.util.Iterator;
54+
import java.util.List;
5355

5456
public class CSVDynamicPersonSerializer extends DynamicPersonSerializer {
5557

@@ -76,6 +78,16 @@ public String toString() {
7678
}
7779
}
7880

81+
@Override
82+
public List<FileName> getFileNames() {
83+
return null;
84+
}
85+
86+
@Override
87+
public void writeFileHeaders() {
88+
89+
}
90+
7991
@Override
8092
public void initialize(Configuration conf, int reducerId) throws IOException {
8193
int numFiles = FileNames.values().length;
@@ -232,8 +244,4 @@ protected void serialize(final Person p, Knows knows) {
232244
writers[FileNames.PERSON_KNOWS_PERSON.ordinal()].writeEntry(arguments);
233245
}
234246

235-
@Override
236-
public void reset() {
237-
// Intentionally left empty
238-
}
239247
}

0 commit comments

Comments
 (0)