hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java [143:180]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  void readDictionaryIds(
      int total,
      WritableIntVector values,
      WritableColumnVector nulls,
      int rowId,
      int level,
      RunLengthDecoder data) {
    int left = total;
    while (left > 0) {
      if (this.currentCount == 0) {
        this.readNextGroup();
      }
      int n = Math.min(left, this.currentCount);
      switch (mode) {
        case RLE:
          if (currentValue == level) {
            data.readDictionaryIdData(n, values, rowId);
          } else {
            nulls.setNulls(rowId, n);
          }
          break;
        case PACKED:
          for (int i = 0; i < n; ++i) {
            if (currentBuffer[currentBufferIdx++] == level) {
              values.setInt(rowId + i, data.readInteger());
            } else {
              nulls.setNullAt(rowId + i);
            }
          }
          break;
        default:
          throw new AssertionError();
      }
      rowId += n;
      left -= n;
      currentCount -= n;
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java [143:180]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  void readDictionaryIds(
      int total,
      WritableIntVector values,
      WritableColumnVector nulls,
      int rowId,
      int level,
      RunLengthDecoder data) {
    int left = total;
    while (left > 0) {
      if (this.currentCount == 0) {
        this.readNextGroup();
      }
      int n = Math.min(left, this.currentCount);
      switch (mode) {
        case RLE:
          if (currentValue == level) {
            data.readDictionaryIdData(n, values, rowId);
          } else {
            nulls.setNulls(rowId, n);
          }
          break;
        case PACKED:
          for (int i = 0; i < n; ++i) {
            if (currentBuffer[currentBufferIdx++] == level) {
              values.setInt(rowId + i, data.readInteger());
            } else {
              nulls.setNullAt(rowId + i);
            }
          }
          break;
        default:
          throw new AssertionError();
      }
      rowId += n;
      left -= n;
      currentCount -= n;
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java [143:180]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  void readDictionaryIds(
      int total,
      WritableIntVector values,
      WritableColumnVector nulls,
      int rowId,
      int level,
      RunLengthDecoder data) {
    int left = total;
    while (left > 0) {
      if (this.currentCount == 0) {
        this.readNextGroup();
      }
      int n = Math.min(left, this.currentCount);
      switch (mode) {
        case RLE:
          if (currentValue == level) {
            data.readDictionaryIdData(n, values, rowId);
          } else {
            nulls.setNulls(rowId, n);
          }
          break;
        case PACKED:
          for (int i = 0; i < n; ++i) {
            if (currentBuffer[currentBufferIdx++] == level) {
              values.setInt(rowId + i, data.readInteger());
            } else {
              nulls.setNullAt(rowId + i);
            }
          }
          break;
        default:
          throw new AssertionError();
      }
      rowId += n;
      left -= n;
      currentCount -= n;
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java [143:180]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  void readDictionaryIds(
      int total,
      WritableIntVector values,
      WritableColumnVector nulls,
      int rowId,
      int level,
      RunLengthDecoder data) {
    int left = total;
    while (left > 0) {
      if (this.currentCount == 0) {
        this.readNextGroup();
      }
      int n = Math.min(left, this.currentCount);
      switch (mode) {
        case RLE:
          if (currentValue == level) {
            data.readDictionaryIdData(n, values, rowId);
          } else {
            nulls.setNulls(rowId, n);
          }
          break;
        case PACKED:
          for (int i = 0; i < n; ++i) {
            if (currentBuffer[currentBufferIdx++] == level) {
              values.setInt(rowId + i, data.readInteger());
            } else {
              nulls.setNullAt(rowId + i);
            }
          }
          break;
        default:
          throw new AssertionError();
      }
      rowId += n;
      left -= n;
      currentCount -= n;
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java [143:180]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  void readDictionaryIds(
      int total,
      WritableIntVector values,
      WritableColumnVector nulls,
      int rowId,
      int level,
      RunLengthDecoder data) {
    int left = total;
    while (left > 0) {
      if (this.currentCount == 0) {
        this.readNextGroup();
      }
      int n = Math.min(left, this.currentCount);
      switch (mode) {
        case RLE:
          if (currentValue == level) {
            data.readDictionaryIdData(n, values, rowId);
          } else {
            nulls.setNulls(rowId, n);
          }
          break;
        case PACKED:
          for (int i = 0; i < n; ++i) {
            if (currentBuffer[currentBufferIdx++] == level) {
              values.setInt(rowId + i, data.readInteger());
            } else {
              nulls.setNullAt(rowId + i);
            }
          }
          break;
        default:
          throw new AssertionError();
      }
      rowId += n;
      left -= n;
      currentCount -= n;
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -