public class SplitPartitionedWritable extends Object implements org.apache.hadoop.io.WritableComparable<SplitPartitionedWritable>
Hashcode is defined the way that all records of the same split go to the same reducer.
In addition, we are defining a grouping comparator allowing group one split into the same reducer group.
Modifier and Type | Class and Description |
---|---|
static class |
SplitPartitionedWritable.SplitGroupingComparator |
Constructor and Description |
---|
SplitPartitionedWritable() |
SplitPartitionedWritable(org.apache.hadoop.mapreduce.Mapper.Context mapperContext) |
Modifier and Type | Method and Description |
---|---|
int |
compareTo(SplitPartitionedWritable o) |
boolean |
equals(Object obj) |
int |
getTaskId() |
long |
getTaskItemOrdinal() |
int |
hashCode() |
void |
incrementItemOrdinal() |
void |
readFields(DataInput in) |
void |
setTaskItemOrdinal(long taskItemOrdinal) |
void |
write(DataOutput out) |
public SplitPartitionedWritable(org.apache.hadoop.mapreduce.Mapper.Context mapperContext)
public SplitPartitionedWritable()
public int getTaskId()
public long getTaskItemOrdinal()
public void incrementItemOrdinal()
public void setTaskItemOrdinal(long taskItemOrdinal)
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
public int compareTo(SplitPartitionedWritable o)
compareTo
in interface Comparable<SplitPartitionedWritable>
Copyright © 2008–2017 The Apache Software Foundation. All rights reserved.