public AbstractKuduInputFormat()

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

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

    public AbstractKuduInputFormat(
            KuduReaderConfig readerConfig,
            RowResultConverter<T> rowResultConverter,
            KuduTableInfo tableInfo,
            List<KuduFilterInfo> tableFilters,
            List<String> tableProjections) {

        this.readerConfig = checkNotNull(readerConfig, "readerConfig could not be null");
        this.rowResultConverter =
                checkNotNull(rowResultConverter, "rowResultConvertor could not be null");
        this.tableInfo = checkNotNull(tableInfo, "tableInfo could not be null");
        this.tableFilters = checkNotNull(tableFilters, "tableFilters could not be null");
        this.tableProjections = tableProjections;

        this.endReached = false;
    }