Uses of Class
com.hazelcast.jet.elastic.ElasticSourceBuilder
Packages that use ElasticSourceBuilder
-
Uses of ElasticSourceBuilder in com.hazelcast.jet.elastic
Methods in com.hazelcast.jet.elastic that return ElasticSourceBuilderModifier and TypeMethodDescriptionstatic ElasticSourceBuilder<Void>
ElasticSources.builder()
Returns new instance ofElasticSourceBuilder
ElasticSourceBuilder.clientFn
(SupplierEx<org.elasticsearch.client.RestClientBuilder> clientFn) Set the client supplier functionElasticSourceBuilder.enableCoLocatedReading()
Enable co-located readingElasticSourceBuilder.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.optionsFn
(FunctionEx<? super org.elasticsearch.action.ActionRequest, org.elasticsearch.client.RequestOptions> optionsFn) Set the function that providesRequestOptions
ElasticSourceBuilder.retries
(int retries) Number of retries the connector will do in addition to Elastic client retriesElasticSourceBuilder.scrollKeepAlive
(String scrollKeepAlive) Set the keepAlive for Elastic search scrollElasticSourceBuilder.searchRequestFn
(SupplierEx<org.elasticsearch.action.search.SearchRequest> searchRequestFn) Set the search request supplier function