Uses of Class
com.hazelcast.jet.elastic.ElasticSourceBuilder

Packages that use 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 and Description
static ElasticSourceBuilder<Void>	ElasticSources.builder() Returns new instance of ElasticSourceBuilder
ElasticSourceBuilder<T>	ElasticSourceBuilder.clientFn(SupplierEx<org.elasticsearch.client.RestClientBuilder> clientFn) Set the client supplier function
ElasticSourceBuilder<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 item
ElasticSourceBuilder<T>	ElasticSourceBuilder.optionsFn(FunctionEx<? super org.elasticsearch.action.ActionRequest,org.elasticsearch.client.RequestOptions> optionsFn) Set the function that provides RequestOptions
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 scroll
ElasticSourceBuilder<T>	ElasticSourceBuilder.searchRequestFn(SupplierEx<org.elasticsearch.action.search.SearchRequest> searchRequestFn) Set the search request supplier function