private void startKuduReader()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/format/AbstractKuduInputFormat.java [112:122]

11 lines of code
2 McCabe index (conditional complexity)


    private void startKuduReader() throws IOException {
        if (kuduReader == null) {
            kuduReader =
                    new KuduReader<>(
                            tableInfo,
                            readerConfig,
                            rowResultConverter,
                            tableFilters,
                            tableProjections);
        }
    }