Hi Arun,
TestCodec only writes once to the deflateFilter, that's why the test
works with LzoCodec.
I've tried out the change mentioned below, on streaming data as well as
compressing files, and it works.
I have one app that sends ~200MB (uncompressed size) lzo-compressed data
over http
Espen Amble Kolstad wrote:
Hi,
I changed LzoCompressor.finished() from:
public synchronized boolean finished() {
// ...
return (finished compressedDirectBuf.remaining() == 0);
}
to:
public synchronized boolean finished() {
// ...
return (finish
Hi,
I changed LzoCompressor.finished() from:
public synchronized boolean finished() {
// ...
return (finished compressedDirectBuf.remaining() == 0);
}
to:
public synchronized boolean finished() {
// ...
return (finish compressedDirectBuf.remaining() == 0);
}
And it
Hi,
I've been trying to use LzoCodec to write a compressed file:
public class LzoTest {
public static void main(String[] args) throws Exception {
final LzoCodec codec = new LzoCodec();
codec.setConf(new Configuration());
final CompressionOutputStream out =
