public RowElasticsearchEmitter()

in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/RowElasticsearchEmitter.java [54:65]

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

    public RowElasticsearchEmitter(
            IndexGenerator indexGenerator,
            SerializationSchema<RowData> serializationSchema,
            XContentType contentType,
            @Nullable String documentType,
            Function<RowData, String> createKey) {
        this.indexGenerator = checkNotNull(indexGenerator);
        this.serializationSchema = checkNotNull(serializationSchema);
        this.contentType = checkNotNull(contentType);
        this.documentType = documentType;
        this.createKey = checkNotNull(createKey);
    }