Skip to content

Commit aa560f9

Browse files
committed
Remove unused parameter cellSize
1 parent 597163a commit aa560f9

File tree

4 files changed

+0
-8
lines changed

4 files changed

+0
-8
lines changed

src/main/java/ldbc/snb/datagen/DatagenParams.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,6 @@ private enum ParameterNames {
7878
BASE_CORRELATED("ldbc.snb.datagen.generator.baseProbCorrelated"),
7979
BEST_UNIVERSTY_RATIO("ldbc.snb.datagen.generator.probTopUniv"),
8080
BLOCK_SIZE("ldbc.snb.datagen.generator.blockSize"),
81-
CELL_SIZE("ldbc.snb.datagen.generator.cellSize"),
8281
COMPANY_UNCORRELATED_RATIO("ldbc.snb.datagen.generator.probUnCorrelatedCompany"),
8382
DIFFERENT_IP_IN_TRAVEL_RATIO("ldbc.snb.datagen.generator.probDiffIPinTravelSeason"),
8483
DIFFERENT_IP_NOT_TRAVEL_RATIO("ldbc.snb.datagen.generator.probDiffIPnotTravelSeason"),
@@ -171,7 +170,6 @@ public String toString() {
171170
public static double tagCountryCorrProb = 0.0;
172171
public static double updatePortion = 0.0;
173172
public static int blockSize = 0;
174-
public static int cellSize = 0; // Number of user in one cell
175173
public static int flashmobTagsPerMonth = 0;
176174
public static int maxCommentSize = 0;
177175
public static int maxCompanies = 0;
@@ -234,7 +232,6 @@ public static void readConf(Configuration conf) {
234232
}
235233
}
236234

237-
cellSize = Short.parseShort(conf.get(ParameterNames.CELL_SIZE.toString()));
238235
minNumFriends = Integer.parseInt(conf.get(ParameterNames.MIN_FRIENDS.toString()));
239236
maxNumFriends = Integer.parseInt(conf.get(ParameterNames.MAX_FRIENDS.toString()));
240237
friendRejectRatio = Double.parseDouble(conf.get(ParameterNames.FRIEND_REJECT.toString()));

src/main/java/ldbc/snb/datagen/hadoop/generator/HadoopPersonGenerator.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -83,9 +83,6 @@ public void map(LongWritable key, Text value, Context context)
8383
int threadId = Integer.parseInt(value.toString());
8484
System.out.println("Generating user at mapper " + threadId);
8585
LdbcDatagen.initializeContext(conf);
86-
if (DatagenParams.numPersons % DatagenParams.cellSize != 0) {
87-
throw new InterruptedException("Number of users should be a multiple of the cellsize");
88-
}
8986

9087
// Here we determine the blocks in the "block space" that this mapper is responsible for.
9188
int numBlocks = (int) (Math.ceil(DatagenParams.numPersons / (double) DatagenParams.blockSize));

src/main/resources/params_default.ini

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@ ldbc.snb.datagen.generator.probDiffIPnotTravelSeason:0.02
3939
ldbc.snb.datagen.generator.probUnCorrelatedOrganization:0.005
4040
ldbc.snb.datagen.generator.probUnCorrelatedCompany:0.05
4141
ldbc.snb.datagen.generator.probTopUniv:0.9
42-
ldbc.snb.datagen.generator.cellSize:1
4342
ldbc.snb.datagen.generator.baseProbCorrelated:0.95
4443
ldbc.snb.datagen.generator.limitProCorrelated:0.2
4544
ldbc.snb.datagen.generator.flashmobTagsPerMonth:5

src/main/resources/params_test.ini

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@ ldbc.snb.datagen.generator.probDiffIPnotTravelSeason:0.02
3939
ldbc.snb.datagen.generator.probUnCorrelatedOrganization:0.005
4040
ldbc.snb.datagen.generator.probUnCorrelatedCompany:0.05
4141
ldbc.snb.datagen.generator.probTopUniv:0.9
42-
ldbc.snb.datagen.generator.cellSize:1
4342
ldbc.snb.datagen.generator.baseProbCorrelated:0.95
4443
ldbc.snb.datagen.generator.limitProCorrelated:0.2
4544
ldbc.snb.datagen.generator.flashmobTagsPerMonth:50

0 commit comments

Comments
 (0)