Uses of Class
org.apache.flink.cdc.connectors.elasticsearch.v2.Elasticsearch8AsyncSinkBuilder

Packages that use Elasticsearch8AsyncSinkBuilder

Package	Description
org.apache.flink.cdc.connectors.elasticsearch.v2

Uses of Elasticsearch8AsyncSinkBuilder in org.apache.flink.cdc.connectors.elasticsearch.v2

Methods in org.apache.flink.cdc.connectors.elasticsearch.v2 that return Elasticsearch8AsyncSinkBuilder

Modifier and Type	Method	Description
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder.allowInsecure()	Allows to bypass the certificates chain validation and connect to insecure network endpoints (for example, servers which use self-signed certificates).
static <T> Elasticsearch8AsyncSinkBuilder<T>	Elasticsearch8AsyncSinkBuilder.builder()
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder.setCertificateFingerprint(String certificateFingerprint)	Set the certificate fingerprint to be used to verify the HTTPS connection.
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder.setElementConverter(org.apache.flink.connector.base.sink.writer.ElementConverter<InputT,co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant> elementConverter)	setElementConverter set the element converter that will be called at every stream element to be processed and buffered.
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder.setHeaders(org.apache.http.Header... headers)	setHeaders set the headers to be sent with the requests made to Elasticsearch cluster..
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder.setHosts(org.apache.http.HttpHost... hosts)	setHosts set the hosts where the Elasticsearch cluster is reachable.
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder.setPassword(String password)	setPassword set the password to authenticate the connection with the Elasticsearch cluster.
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder.setSslContextSupplier(org.apache.flink.util.function.SerializableSupplier<SSLContext> sslContextSupplier)	Sets the supplier for getting an SSLContext instance.
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder.setSslHostnameVerifier(org.apache.flink.util.function.SerializableSupplier<HostnameVerifier> sslHostnameVerifierSupplier)	Sets the supplier for getting an SSL HostnameVerifier instance.
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder.setUsername(String username)	setUsername set the username to authenticate the connection with the Elasticsearch cluster.