Skip to content

Commit 70ba975

Browse files
committed
Added TupleKey partitioner to person serializer hadoop job
1 parent 02a2c17 commit 70ba975

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,9 @@ public void run( String inputFileName ) throws Exception {
103103
job.setNumReduceTasks(numThreads);
104104
job.setInputFormatClass(SequenceFileInputFormat.class);
105105
job.setOutputFormatClass(SequenceFileOutputFormat.class);
106-
106+
107+
job.setPartitionerClass(HadoopTuplePartitioner.class);
108+
107109
/*job.setSortComparatorClass(BlockKeyComparator.class);
108110
job.setGroupingComparatorClass(BlockKeyGroupComparator.class);
109111
job.setPartitionerClass(HadoopBlockPartitioner.class);

0 commit comments

Comments
 (0)