package edu.uci.ics.hivesterix.runtime.inspector;

import edu.uci.ics.hivesterix.serde.lazy.LazyUtils;
import edu.uci.ics.hivesterix.serde.lazy.LazyUtils.VInt;
import edu.uci.ics.hyracks.algebricks.data.IBinaryIntegerInspector;

public class HiveBinaryIntegerInspector implements IBinaryIntegerInspector {
	private VInt value = new VInt();

	HiveBinaryIntegerInspector() {
	}

	@Override
	public int getIntegerValue(byte[] bytes, int offset, int length) {
		LazyUtils.readVInt(bytes, offset, value);
		if (value.length != length)
			throw new IllegalArgumentException(
					"length mismatch in int hash function actual: " + length
							+ " expected " + value.length);
		return value.value;
	}

}