Browse files

incorporate code review.

  • Loading branch information...
1 parent c03cd51 commit 28a919e7202595eb95c1db40cada57c9b1f19742 @yuxutw yuxutw committed Apr 25, 2012
View
2 src/java/com/hadoop/compression/lzo/LzopCodec.java
@@ -58,7 +58,7 @@ public CompressionOutputStream createIndexedOutputStream(OutputStream out,
throws IOException {
//get a compressor which will be returned to the pool when the output stream
//is closed.
- return createIndexedOutputStream(out, indexOut,CodecPool.getCompressor(this, getConf()));
+ return createIndexedOutputStream(out, indexOut, CodecPool.getCompressor(this, getConf()));
}
@Override
View
6 src/java/com/hadoop/compression/lzo/LzopOutputStream.java
@@ -111,10 +111,10 @@ public void close() throws IOException {
indexOut.close();
}
closed = true;
+ //return the compressor to the pool for later reuse;
+ //the returnCompressor handles nulls.
+ CodecPool.returnCompressor(compressor);
}
- //return the compressor to the pool for later reuse;
- //the returnCompressor handles nulls.
- CodecPool.returnCompressor(compressor);
}
@Override

0 comments on commit 28a919e

Please sign in to comment.