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	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