public KuduReader()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/reader/KuduReader.java [72:87]

• 16 lines of code
• 1 McCabe index (conditional complexity)

    public KuduReader(
            KuduTableInfo tableInfo,
            KuduReaderConfig readerConfig,
            RowResultConverter<T> rowResultConverter,
            List<KuduFilterInfo> tableFilters,
            List<String> tableProjections)
            throws IOException {
        this.tableInfo = tableInfo;
        this.readerConfig = readerConfig;
        this.tableFilters = tableFilters;
        this.tableProjections = tableProjections;
        this.rowResultConverter = rowResultConverter;
        this.client = obtainClient();
        this.session = obtainSession();
        this.table = obtainTable();
    }