Created
February 26, 2014 07:05
-
-
Save rishav-rohit/9224985 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.hadoop.imcdp; | |
| import java.io.*; | |
| import java.util.Set; | |
| import java.lang.Integer; | |
| import org.apache.hadoop.io.*; | |
| public class IntPair implements WritableComparable<IntPair>{ | |
| private IntWritable first; | |
| private IntWritable second; | |
| public IntPair() { | |
| set(new IntWritable(), new IntWritable()); | |
| } | |
| public IntPair(Integer first, Integer second) { | |
| set(new IntWritable(first), new IntWritable(second)); | |
| } | |
| public void set(IntWritable first, IntWritable second) { | |
| this.first = first; | |
| this.second = second; | |
| } | |
| public IntWritable getFirst() { | |
| return first; | |
| } | |
| public Integer getFirstInt() { | |
| return new Integer(first.toString()); | |
| } | |
| public Integer getSecondInt() { | |
| return new Integer(second.toString()); | |
| } | |
| public IntWritable getSecond() { | |
| return second; | |
| } | |
| @Override | |
| public void write(DataOutput out) throws IOException { | |
| first.write(out); | |
| second.write(out); | |
| } | |
| @Override | |
| public void readFields(DataInput in) throws IOException { | |
| first.readFields(in); | |
| second.readFields(in); | |
| } | |
| @Override | |
| public int hashCode() { | |
| return first.hashCode() * 163 + second.hashCode(); | |
| } | |
| @Override | |
| public boolean equals(Object o) { | |
| if (o instanceof IntPair) { | |
| IntPair tp = (IntPair) o; | |
| return first.equals(tp.first) && second.equals(tp.second); | |
| } | |
| return false; | |
| } | |
| @Override | |
| public int compareTo(IntPair tp) { | |
| int cmp = first.compareTo(tp.first); | |
| if (cmp != 0) { | |
| return cmp; | |
| } | |
| return second.compareTo(tp.second); | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment