Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package slim3.mapreduce.wordcount.writables;
- import java.io.DataInput;
- import java.io.DataOutput;
- import java.io.IOException;
- import org.apache.hadoop.io.WritableComparable;
- import com.google.appengine.tools.mapreduce.OutputKey;
- public class WordCountIntermediateValue extends OutputKey implements
- WritableComparable<WordCountIntermediateValue> {
- private long count = 0;
- public WordCountIntermediateValue() {
- }
- public WordCountIntermediateValue(long count) {
- set(count);
- }
- public void set(long count) {
- this.count = count;
- }
- public long getCount() {
- return count;
- }
- @Override
- public String getKeyString() {
- return String.valueOf(count);
- }
- @Override
- public void readFromKeyString(String keyString) {
- count = Long.parseLong(keyString);
- }
- public void write(DataOutput out) throws IOException {
- out.writeLong(count);
- }
- public void readFields(DataInput in) throws IOException {
- count = in.readLong();
- }
- public int compareTo(WordCountIntermediateValue other) {
- return Long.valueOf(this.count).compareTo(Long.valueOf(other.count));
- }
- }
Add Comment
Please, Sign In to add comment