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