Uses of Class
com.hazelcast.jet.elastic.ElasticSourceBuilder
Package | Description |
---|---|
com.hazelcast.jet.elastic |
Contains sources and sinks for Elasticsearch 7
|
-
Uses of ElasticSourceBuilder in com.hazelcast.jet.elastic
Methods in com.hazelcast.jet.elastic that return ElasticSourceBuilder Modifier and Type Method Description static ElasticSourceBuilder<Void>
ElasticSources. builder()
Returns new instance ofElasticSourceBuilder
ElasticSourceBuilder<T>
ElasticSourceBuilder. clientFn(SupplierEx<org.elasticsearch.client.RestClientBuilder> clientFn)
Set the client supplier functionElasticSourceBuilder<T>
ElasticSourceBuilder. enableCoLocatedReading()
Enable co-located reading Jet cluster member must run exactly on the same nodes as Elastic cluster.ElasticSourceBuilder<T>
ElasticSourceBuilder. enableSlicing()
Enable slicing<T_NEW> ElasticSourceBuilder<T_NEW>
ElasticSourceBuilder. mapToItemFn(FunctionEx<? super org.elasticsearch.search.SearchHit,T_NEW> mapToItemFn)
Set the function to map SearchHit to a pipeline itemElasticSourceBuilder<T>
ElasticSourceBuilder. optionsFn(FunctionEx<? super org.elasticsearch.action.ActionRequest,org.elasticsearch.client.RequestOptions> optionsFn)
Set the function that providesRequestOptions
ElasticSourceBuilder<T>
ElasticSourceBuilder. 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.ElasticSourceBuilder<T>
ElasticSourceBuilder. scrollKeepAlive(String scrollKeepAlive)
Set the keepAlive for Elastic search scrollElasticSourceBuilder<T>
ElasticSourceBuilder. searchRequestFn(SupplierEx<org.elasticsearch.action.search.SearchRequest> searchRequestFn)
Set the search request supplier function