public static BigDecimal toBigDecimal()

in src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java [209:218]

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

    public static BigDecimal toBigDecimal(byte[] bytes, int offset, int length) {
        if (bytes != null && length >= 5 && offset + length <= bytes.length) {
            int scale = toInt(bytes, offset);
            byte[] tcBytes = new byte[length - 4];
            System.arraycopy(bytes, offset + 4, tcBytes, 0, length - 4);
            return new BigDecimal(new BigInteger(tcBytes), scale);
        } else {
            return null;
        }
    }