| 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.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 © 2021 Hazelcast, Inc.. All rights reserved.