// Path: src/main/java/io/izenecloud/larser/offline/topn/IntDoublePairWritable.java
// public class IntDoublePairWritable implements
// 		WritableComparable<IntDoublePairWritable> {
// 
// 	private int key;
// 	private double value;
// 
// 	public IntDoublePairWritable() {
// 	}
// 
// 	public IntDoublePairWritable(int k, double v) {
// 		this.key = k;
// 		this.value = v;
// 	}
// 
// 	public void setKey(int k) {
// 		this.key = k;
// 	}
// 
// 	public void setValue(double v) {
// 		this.value = v;
// 	}
// 
// 	public void readFields(DataInput in) throws IOException {
// 		this.key = in.readInt();
// 		this.value = in.readDouble();
// 	}
// 
// 	public void write(DataOutput out) throws IOException {
// 		out.writeInt(key);
// 		out.writeDouble(value);
// 	}
// 
// 	public int getKey() {
// 		return key;
// 	}
// 
// 	public double getValue() {
// 		return value;
// 	}
// 
// 	public int compareTo(IntDoublePairWritable o) {
// 		if (this.value > o.value) {
// 			return 1;
// 		} else if (this.value < o.value) {
// 			return -1;
// 		}
// 		return 0;
// 	}
// }


import io.izenecloud.larser.offline.topn.IntDoublePairWritable;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import org.msgpack.annotation.Message;
package io.izenecloud.msgpack;




@Message
public class PriorityQueue {
	private String user;
	private Map<Integer, Float> cluster;
	
	public PriorityQueue() {
		
	}

	public PriorityQueue(String user,
			io.izenecloud.larser.offline.topn.PriorityQueue queue) {
		this.user = user;
		this.cluster = new HashMap<Integer, Float>();
		Iterator<IntDoublePairWritable> iterator = queue.iterator();
		while (iterator.hasNext()) {
// Path: src/main/java/io/izenecloud/larser/offline/topn/IntDoublePairWritable.java
// public class IntDoublePairWritable implements
// 		WritableComparable<IntDoublePairWritable> {
// 
// 	private int key;
// 	private double value;
// 
// 	public IntDoublePairWritable() {
// 	}
// 
// 	public IntDoublePairWritable(int k, double v) {
// 		this.key = k;
// 		this.value = v;
// 	}
// 
// 	public void setKey(int k) {
// 		this.key = k;
// 	}
// 
// 	public void setValue(double v) {
// 		this.value = v;
// 	}
// 
// 	public void readFields(DataInput in) throws IOException {
// 		this.key = in.readInt();
// 		this.value = in.readDouble();
// 	}
// 
// 	public void write(DataOutput out) throws IOException {
// 		out.writeInt(key);
// 		out.writeDouble(value);
// 	}
// 
// 	public int getKey() {
// 		return key;
// 	}
// 
// 	public double getValue() {
// 		return value;
// 	}
// 
// 	public int compareTo(IntDoublePairWritable o) {
// 		if (this.value > o.value) {
// 			return 1;
// 		} else if (this.value < o.value) {
// 			return -1;
// 		}
// 		return 0;
// 	}
// }


// Path: src/main/java/io/izenecloud/msgpack/PriorityQueue.java
import io.izenecloud.larser.offline.topn.IntDoublePairWritable;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import org.msgpack.annotation.Message;

package io.izenecloud.msgpack;




@Message
public class PriorityQueue {
	private String user;
	private Map<Integer, Float> cluster;
	
	public PriorityQueue() {
		
	}

	public PriorityQueue(String user,
			io.izenecloud.larser.offline.topn.PriorityQueue queue) {
		this.user = user;
		this.cluster = new HashMap<Integer, Float>();
		Iterator<IntDoublePairWritable> iterator = queue.iterator();
		while (iterator.hasNext()) {
			IntDoublePairWritable v = iterator.next();