Uses of Class
com.hazelcast.jet.elastic.ElasticSinkBuilder
Package | Description |
---|---|
com.hazelcast.jet.elastic |
Contains sources and sinks for Elasticsearch 7
|
-
Uses of ElasticSinkBuilder in com.hazelcast.jet.elastic
Methods in com.hazelcast.jet.elastic that return ElasticSinkBuilder Modifier and Type Method Description static ElasticSinkBuilder<Void>
ElasticSinks. builder()
Returns new instance ofElasticSinkBuilder
ElasticSinkBuilder<T>
ElasticSinkBuilder. bulkRequestFn(SupplierEx<org.elasticsearch.action.bulk.BulkRequest> bulkRequestFn)
Set the supplier function for BulkRequest, defaults to newBulkRequest()
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 requestElasticSinkBuilder<T>
ElasticSinkBuilder. optionsFn(FunctionEx<? super org.elasticsearch.action.ActionRequest,org.elasticsearch.client.RequestOptions> optionsFn)
Set the function that providesRequestOptions
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.