Package com.hazelcast.jet.elastic
Class ElasticClients
java.lang.Object
com.hazelcast.jet.elastic.ElasticClients
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 TypeMethodDescriptionstatic org.elasticsearch.client.RestClientBuilder
client()
Create Elastic client for an instance running on localhost on default port (9200)static org.elasticsearch.client.RestClientBuilder
Convenience method to createRestClientBuilder
with given string, it must contain host, and optionally the scheme and a port.static org.elasticsearch.client.RestClientBuilder
Convenience method to createRestClientBuilder
with given hostname and portstatic org.elasticsearch.client.RestClientBuilder
Convenience method to createRestClientBuilder
with basic authentication and given hostname and portstatic org.elasticsearch.client.RestClientBuilder
Convenience method to createRestClientBuilder
with basic authentication and given hostname, port and scheme.
-
Method Details
-
client
@Nonnull public static org.elasticsearch.client.RestClientBuilder 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:
- 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 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));
-
client
@Nonnull public static org.elasticsearch.client.RestClientBuilder client(@Nonnull String username, @Nonnull String password, @Nonnull String hostname, int port, @Nonnull String scheme) Convenience method to createRestClientBuilder
with basic authentication and given hostname, port and scheme. Valid schemes are "http" and "https".Usage:
BatchSource<SearchHit> source = elastic(() -> client("user", "password", "host", 9200, "https"));
-