code: @Override
    public Compressor createCompressor() {
      if (!isNativeSnappyLoaded(conf)) {
        throw new CodecUnavailableException("native snappy library not available");
      }
      int bufferSize = conf.getInt(
          IO_COMPRESSION_CODEC_SNAPPY_BUFFERSIZE_KEY,
          IO_COMPRESSION_CODEC_SNAPPY_BUFFERSIZE_DEFAULT);
      return new SnappyCompressor(bufferSize);
    }
docs: Create a new {@link Compressor} for use by this {@link CompressionCodec}.
  
  @return a new compressor for use by this codec