public ElasticsearchDynamicSource()

in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSource.java [36:53]

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

    public ElasticsearchDynamicSource(
            DecodingFormat<DeserializationSchema<RowData>> format,
            ElasticsearchConfiguration config,
            DataType physicalRowDataType,
            int lookupMaxRetryTimes,
            String summaryString,
            ElasticsearchApiCallBridge<?> apiCallBridge,
            @Nullable LookupCache lookupCache,
            @Nullable String docType) {
        this.format = format;
        this.config = config;
        this.physicalRowDataType = physicalRowDataType;
        this.lookupMaxRetryTimes = lookupMaxRetryTimes;
        this.summaryString = summaryString;
        this.apiCallBridge = apiCallBridge;
        this.lookupCache = lookupCache;
        this.docType = docType;
    }