iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeLZ4Compressor.java [38:52]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @Override
  public byte[] compress(byte[] data) throws IOException {
    return COMPRESSOR.compress(data);
  }

  @Override
  public byte[] decompress(byte[] byteArray) throws IOException {
    return DECOMPRESSOR.uncompress(byteArray);
  }

  @Override
  public byte[] decompress(byte[] byteArray, int decompressedLength) throws IOException {
    byte[] uncompressed = new byte[decompressedLength];
    DECOMPRESSOR.uncompress(byteArray, 0, byteArray.length, uncompressed, 0);
    return uncompressed;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeLZMA2Compressor.java [38:52]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @Override
  public byte[] compress(byte[] data) throws IOException {
    return COMPRESSOR.compress(data);
  }

  @Override
  public byte[] decompress(byte[] byteArray) throws IOException {
    return DECOMPRESSOR.uncompress(byteArray);
  }

  @Override
  public byte[] decompress(byte[] byteArray, int decompressedLength) throws IOException {
    byte[] uncompressed = new byte[decompressedLength];
    DECOMPRESSOR.uncompress(byteArray, 0, byteArray.length, uncompressed, 0);
    return uncompressed;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -