Uses of Class
com.hazelcast.jet.elastic.ElasticSinkBuilder
Packages that use ElasticSinkBuilder
-
Uses of ElasticSinkBuilder in com.hazelcast.jet.elastic
Methods in com.hazelcast.jet.elastic that return ElasticSinkBuilderModifier and TypeMethodDescriptionstatic ElasticSinkBuilder<Void>
ElasticSinks.builder()
Returns new instance ofElasticSinkBuilder
ElasticSinkBuilder.bulkRequestFn
(SupplierEx<org.elasticsearch.action.bulk.BulkRequest> bulkRequestFn) Set the supplier function for BulkRequest, defaults to newBulkRequest()
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.optionsFn
(FunctionEx<? super org.elasticsearch.action.ActionRequest, org.elasticsearch.client.RequestOptions> optionsFn) Set the function that providesRequestOptions
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.