Index

B C E M O R S
All Classes and Interfaces|All Packages|Serialized Form

B

build() - Method in class com.hazelcast.jet.elastic.ElasticSinkBuilder

Create a sink that writes data into Elasticsearch based on this builder configuration

build() - Method in class com.hazelcast.jet.elastic.ElasticSourceBuilder

Build Elasticsearch BatchSource with supplied parameters

builder() - Static method in class com.hazelcast.jet.elastic.ElasticSinks

Returns new instance of ElasticSinkBuilder

builder() - Static method in class com.hazelcast.jet.elastic.ElasticSources

Returns new instance of ElasticSourceBuilder

bulkRequestFn(SupplierEx<BulkRequest>) - Method in class com.hazelcast.jet.elastic.ElasticSinkBuilder

Set the supplier function for BulkRequest, defaults to new BulkRequest()

C

client() - Static method in class com.hazelcast.jet.elastic.ElasticClients

Create Elastic client for an instance running on localhost on default port (9200)

client(String) - Static method in class com.hazelcast.jet.elastic.ElasticClients

Convenience method to create RestClientBuilder with given string, it must contain host, and optionally the scheme and a port.

client(String, int) - Static method in class com.hazelcast.jet.elastic.ElasticClients

Convenience method to create RestClientBuilder with given hostname and port

client(String, String, String, int) - Static method in class com.hazelcast.jet.elastic.ElasticClients

Convenience method to create RestClientBuilder with basic authentication and given hostname and port

client(String, String, String, int, String) - Static method in class com.hazelcast.jet.elastic.ElasticClients

Convenience method to create RestClientBuilder with basic authentication and given hostname, port and scheme.

clientFn(SupplierEx<RestClientBuilder>) - Method in class com.hazelcast.jet.elastic.ElasticSinkBuilder

Set the client supplier function

clientFn(SupplierEx<RestClientBuilder>) - Method in class com.hazelcast.jet.elastic.ElasticSourceBuilder

Set the client supplier function

com.hazelcast.jet.elastic - package com.hazelcast.jet.elastic

Contains sources and sinks for Elasticsearch 7

E

elastic() - Static method in class com.hazelcast.jet.elastic.ElasticSources

Creates a source which queries local instance of Elasticsearch for all documents

elastic(FunctionEx<? super SearchHit, T>) - Static method in class com.hazelcast.jet.elastic.ElasticSources

Creates a source which queries local instance of Elasticsearch for all documents.

elastic(FunctionEx<? super T, ? extends DocWriteRequest<?>>) - Static method in class com.hazelcast.jet.elastic.ElasticSinks

Creates an Elasticsearch sink, uses a local instance of Elasticsearch

elastic(SupplierEx<RestClientBuilder>) - Static method in class com.hazelcast.jet.elastic.ElasticSources

Creates a source which queries Elasticsearch using client obtained from RestClientBuilder supplier function.

elastic(SupplierEx<RestClientBuilder>, FunctionEx<? super SearchHit, T>) - Static method in class com.hazelcast.jet.elastic.ElasticSources

Creates a source which queries Elasticsearch using client obtained from RestClientBuilder supplier function.

elastic(SupplierEx<RestClientBuilder>, FunctionEx<? super T, ? extends DocWriteRequest<?>>) - Static method in class com.hazelcast.jet.elastic.ElasticSinks

Creates an Elasticsearch sink, uses a client obtained from clientFn and maps items using given mapToRequestFn

elastic(SupplierEx<RestClientBuilder>, SupplierEx<SearchRequest>, FunctionEx<? super SearchHit, T>) - Static method in class com.hazelcast.jet.elastic.ElasticSources

Creates a source which queries Elasticsearch using client obtained from RestHighLevelClient supplier.

ElasticClients - Class in com.hazelcast.jet.elastic

Collection of convenience factory methods for Elastic's RestClientBuilder

ElasticSinkBuilder<T> - Class in com.hazelcast.jet.elastic

Builder for Elasticsearch Sink

ElasticSinkBuilder() - Constructor for class com.hazelcast.jet.elastic.ElasticSinkBuilder

ElasticSinks - Class in com.hazelcast.jet.elastic

Provides factory methods for Elasticsearch sinks.

ElasticSourceBuilder<T> - Class in com.hazelcast.jet.elastic

Builder for Elasticsearch source which reads data from Elasticsearch and converts SearchHits using provided mapToItemFn

ElasticSourceBuilder() - Constructor for class com.hazelcast.jet.elastic.ElasticSourceBuilder

ElasticSources - Class in com.hazelcast.jet.elastic

Provides factory methods for Elasticsearch sources.

enableCoLocatedReading() - Method in class com.hazelcast.jet.elastic.ElasticSourceBuilder

Enable co-located reading Jet cluster member must run exactly on the same nodes as Elastic cluster.

enableSlicing() - Method in class com.hazelcast.jet.elastic.ElasticSourceBuilder

Enable slicing

M

mapToItemFn(FunctionEx<? super SearchHit, T_NEW>) - Method in class com.hazelcast.jet.elastic.ElasticSourceBuilder

Set the function to map SearchHit to a pipeline item

mapToRequestFn(FunctionEx<? super T_NEW, ? extends DocWriteRequest<?>>) - Method in class com.hazelcast.jet.elastic.ElasticSinkBuilder

Set the function mapping the item from a pipeline item to an index request

O

optionsFn(FunctionEx<? super ActionRequest, RequestOptions>) - Method in class com.hazelcast.jet.elastic.ElasticSinkBuilder

Set the function that provides RequestOptions

optionsFn(FunctionEx<? super ActionRequest, RequestOptions>) - Method in class com.hazelcast.jet.elastic.ElasticSourceBuilder

Set the function that provides RequestOptions

R

retries(int) - Method in class com.hazelcast.jet.elastic.ElasticSinkBuilder

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.

retries(int) - Method in class com.hazelcast.jet.elastic.ElasticSourceBuilder

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.

S

scrollKeepAlive(String) - Method in class com.hazelcast.jet.elastic.ElasticSourceBuilder

Set the keepAlive for Elastic search scroll

searchRequestFn(SupplierEx<SearchRequest>) - Method in class com.hazelcast.jet.elastic.ElasticSourceBuilder

Set the search request supplier function

B C E M O R S
All Classes and Interfaces|All Packages|Serialized Form