public boolean containsOffset()

in src/main/java/com/aliyun/odps/kafka/connect/SinkStatusContext.java [36:40]

• 4 lines of code
• 3 McCabe index (conditional complexity)

  public boolean containsOffset(long offset) {
    // 判断offset区间是否包含某个record的offset
    Long floorKey = offsetIntervalSet.floorKey(offset);
    return (floorKey != null && offset >= floorKey && offset <= offsetIntervalSet.get(floorKey));
  }