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 ofElasticSourceBuilderElasticSourceBuilder.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 providesRequestOptionsElasticSourceBuilder.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