public KuduSourceEnumerator()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java [103:120]

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

    public KuduSourceEnumerator(
            KuduTableInfo tableInfo,
            KuduReaderConfig readerConfig,
            Boundedness boundedness,
            Duration discoveryInterval,
            SplitEnumeratorContext<KuduSourceSplit> context,
            KuduSourceEnumeratorState enumState) {
        this.boundedness = checkNotNull(boundedness);
        this.discoveryInterval = discoveryInterval;
        this.context = checkNotNull(context);
        this.readersAwaitingSplit = new ArrayList<>();
        this.unassigned = enumState.getUnassigned();
        this.pending = enumState.getPending();
        this.splitGenerator = new KuduSplitGenerator(readerConfig, tableInfo);
        this.lastEndTimestamp = enumState.getLastEndTimestamp();

        validateConfiguration();
    }