Package 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 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 createRestClientBuilder
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 createRestClientBuilder
with given hostname and portstatic org.elasticsearch.client.RestClientBuilder
client(String username, String password, String hostname, int port)
Convenience method to createRestClientBuilder
with basic authentication and given hostname and port
-
Method Details
-
client
Create Elastic client for an instance running on localhost on default port (9200) -
client
Convenience method to createRestClientBuilder
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:
- 4.3
- See Also:
HttpHost.create(String)
-
client
@Nonnull public static org.elasticsearch.client.RestClientBuilder client(@Nonnull String hostname, int port)Convenience method to createRestClientBuilder
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 createRestClientBuilder
with basic authentication and given hostname and portUsage:
BatchSource<SearchHit> source = elastic(() -> client("user", "password", "host", 9200));
-