java/tsfile/src/main/java/org/apache/tsfile/encoding/encoder/DoubleRLBE.java [93:110]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void encodeValue(double value, ByteArrayOutputStream out) {
    if (writeIndex == -1) {
      // when the first value hasn't encoded yet
      diffValue[++writeIndex] = value;
      LengthCode[writeIndex] = calBinarylength(value);
      previousValue = value;
      return;
    }
    // calculate delta value
    diffValue[++writeIndex] = value - previousValue;
    // caldulate the length of delta value
    LengthCode[writeIndex] = calBinarylength(diffValue[writeIndex]);
    previousValue = value;
    if (writeIndex == blockSize - 1) {
      // when encoded number reach to blocksize
      flush(out);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



java/tsfile/src/main/java/org/apache/tsfile/encoding/encoder/LongRLBE.java [76:93]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void encodeValue(long value, ByteArrayOutputStream out) {
    if (writeIndex == -1) {
      // when the first value hasn't encoded yet
      diffValue[++writeIndex] = value;
      LengthCode[writeIndex] = calBinarylength(value);
      previousValue = value;
      return;
    }
    // calculate delta value
    diffValue[++writeIndex] = value - previousValue;
    // caldulate the length of delta value
    LengthCode[writeIndex] = calBinarylength(diffValue[writeIndex]);
    previousValue = value;
    if (writeIndex == blockSize - 1) {
      // when encoded number reach to blocksize
      flush(out);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



java/tsfile/src/main/java/org/apache/tsfile/encoding/encoder/IntRLBE.java [81:98]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void encodeValue(int value, ByteArrayOutputStream out) {
    if (writeIndex == -1) {
      // when the first value hasn't encoded yet
      diffValue[++writeIndex] = value;
      LengthCode[writeIndex] = calBinarylength(value);
      previousValue = value;
      return;
    }
    // calculate delta value
    diffValue[++writeIndex] = value - previousValue;
    // caldulate the length of delta value
    LengthCode[writeIndex] = calBinarylength(diffValue[writeIndex]);
    previousValue = value;
    if (writeIndex == blockSize - 1) {
      // when encoded number reach to blocksize
      flush(out);
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -