public void open()

in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/MapElasticsearchEmitter.java [56:62]

• 7 lines of code
• 2 McCabe index (conditional complexity)

    public void open() throws Exception {
        if (isDynamicIndex) {
            indexProvider = doc -> doc.get(index).toString();
        } else {
            indexProvider = doc -> index;
        }
    }