org.apache.flink.streaming.connectors.elasticsearch7

Interface RestClientFactory

All Superinterfaces:

Serializable

@PublicEvolving
public interface RestClientFactory
extends Serializable

A factory that is used to configure the RestHighLevelClient internally used in the ElasticsearchSink.

Method Summary

Modifier and Type	Method and Description
void	configureRestClientBuilder(org.elasticsearch.client.RestClientBuilder restClientBuilder) Configures the rest client builder.

Method Detail

configureRestClientBuilder

void configureRestClientBuilder(org.elasticsearch.client.RestClientBuilder restClientBuilder)

Configures the rest client builder.

Parameters:

restClientBuilder - the configured rest client builder.