code: @Override
  	public synchronized void  close() throws IOException {
  	try {
  	   if (this.ebr != null) {
  	        ebr.close();
  	      }
  	    } finally {
  	      if (decompressor != null) {
  	        CodecPool.returnDecompressor(decompressor);
  	        decompressor = null;
  	      }
  	    }
  	  }
docs: /*
  Clean up InputStream and Decompressor after use
  
  
  @throws java.io.IOException in case of errors reading from the filestream provided by Hadoop