public KuduDynamicTableSource()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/KuduDynamicTableSource.java [71:82]

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

    public KuduDynamicTableSource(
            KuduReaderConfig.Builder configBuilder,
            KuduTableInfo tableInfo,
            DataType physicalRowDataType,
            int lookupMaxRetryTimes,
            @Nullable LookupCache cache) {
        this.configBuilder = configBuilder;
        this.tableInfo = tableInfo;
        this.physicalRowDataType = physicalRowDataType;
        this.lookupMaxRetryTimes = lookupMaxRetryTimes;
        this.cache = cache;
    }