| Package | Description | 
|---|---|
| com.hazelcast.jet.elastic | Contains sources and sinks for Elasticsearch 7 | 
| Modifier and Type | Method and Description | 
|---|---|
| static ElasticSinkBuilder<Void> | ElasticSinks. builder()Returns new instance of  ElasticSinkBuilder | 
| ElasticSinkBuilder<T> | ElasticSinkBuilder. bulkRequestFn(SupplierEx<org.elasticsearch.action.bulk.BulkRequest> bulkRequestFn)Set the supplier function for BulkRequest, defaults to new  BulkRequest() | 
| ElasticSinkBuilder<T> | ElasticSinkBuilder. clientFn(SupplierEx<org.elasticsearch.client.RestClientBuilder> clientFn)Set the client supplier function | 
| <T_NEW> ElasticSinkBuilder<T_NEW> | ElasticSinkBuilder. mapToRequestFn(FunctionEx<? super T_NEW,? extends org.elasticsearch.action.DocWriteRequest<?>> mapToRequestFn)Set the function mapping the item from a pipeline item to an index
 request | 
| ElasticSinkBuilder<T> | ElasticSinkBuilder. optionsFn(FunctionEx<? super org.elasticsearch.action.ActionRequest,org.elasticsearch.client.RequestOptions> optionsFn)Set the function that provides  RequestOptions | 
| ElasticSinkBuilder<T> | ElasticSinkBuilder. retries(int retries)Number of retries the connector will do in addition to Elastic client
 retries
 Elastic client tries to connect to a node only once for each request. | 
Copyright © 2022 Hazelcast, Inc.. All rights reserved.