private String getValue()

in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java [252:267]

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

    private String getValue(BytesMessage message, String[] data, String line, int index) {
        String fieldValue = null;
        if (isHeaderField(index)) {
            fieldValue = getHeaderValue(message, index);
        } else {
            if (dataColumnSize == 1) {
                fieldValue = line;
            } else {
                if (index < data.length) {
                    fieldValue = data[index];
                }
            }
        }

        return fieldValue;
    }