public void open()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/function/lookup/KuduRowDataLookupFunction.java [117:129]

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

    public void open(FunctionContext context) {
        try {
            super.open(context);
            this.kuduReader =
                    new KuduReader<>(this.tableInfo, this.kuduReaderConfig, this.convertor);
            // build kudu cache
            this.kuduReader.setTableProjections(
                    CollectionUtil.isNullOrEmpty(projectedFields) ? null : projectedFields);
        } catch (Exception ioe) {
            LOG.error("Exception while creating connection to Kudu.", ioe);
            throw new RuntimeException("Cannot create connection to Kudu.", ioe);
        }
    }