package backtype.storm.utils;
import java.io.IOException;
import java.io.OutputStream;
import java.util.zip.CRC32;
public class CRC32OutputStream extends OutputStream {
private CRC32 hasher;
public CRC32OutputStream() {
hasher = new CRC32();
}
public long getValue() {
return hasher.getValue();
}
@Override
public void write(int i) throws IOException {
hasher.update(i);
}
@Override
public void write(byte[] bytes, int start, int end) throws IOException {
hasher.update(bytes, start, end);
}
}