public SinkWriter createWriter()

in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSink.java [87:98]

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

    public SinkWriter<IN> createWriter(WriterInitContext context) throws IOException {
        return new ElasticsearchWriter<>(
                hosts,
                emitter,
                deliveryGuarantee == DeliveryGuarantee.AT_LEAST_ONCE,
                buildBulkProcessorConfig,
                bulkProcessorBuilderFactory,
                bulkResponseInspectorFactory.apply(context::metricGroup),
                networkClientConfig,
                context.metricGroup(),
                context.getMailboxExecutor());
    }