com.hazelcast.jet.elastic

Class ElasticClients

java.lang.Object

com.hazelcast.jet.elastic.ElasticClients

public final class ElasticClients
extends Object

Collection of convenience factory methods for Elastic's RestClientBuilder

Supposed to be used as a parameter to ElasticSourceBuilder.clientFn(SupplierEx) and ElasticSinkBuilder.clientFn(SupplierEx), for example:

 builder.clientFn(() -> client());
 

Method Summary

Modifier and Type	Method and Description
static org.elasticsearch.client.RestClientBuilder	client() Create Elastic client for an instance running on localhost on default port (9200)
static org.elasticsearch.client.RestClientBuilder	client(String location) Convenience method to create RestClientBuilder with given string, it must contain host, and optionally the scheme and a port.
static org.elasticsearch.client.RestClientBuilder	client(String hostname, int port) Convenience method to create RestClientBuilder with given hostname and port
static org.elasticsearch.client.RestClientBuilder	client(String username, String password, String hostname, int port) Convenience method to create RestClientBuilder with basic authentication and given hostname and port

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

client

@Nonnull
public static org.elasticsearch.client.RestClientBuilder client()

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

client

@Nonnull
public static org.elasticsearch.client.RestClientBuilder client(@Nonnull
                                                                         String location)

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

 elastic-host
 elastic-host:9200
 http://elastic-host:9200

Since:

Jet 4.3

See Also:

HttpHost.create(String)

client

@Nonnull
public static org.elasticsearch.client.RestClientBuilder client(@Nonnull
                                                                         String hostname,
                                                                         int port)

Convenience method to create RestClientBuilder with given hostname and port

client

@Nonnull
public static org.elasticsearch.client.RestClientBuilder client(@Nonnull
                                                                         String username,
                                                                         @Nonnull
                                                                         String password,
                                                                         @Nonnull
                                                                         String hostname,
                                                                         int port)

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

Usage:

 BatchSource<SearchHit> source = elastic(() -> client("user", "password", "host", 9200));