Package com.hazelcast.jet.elastic

Class ElasticSinks

  • public final class ElasticSinks
extends java.lang.Object
    Provides factory methods for Elasticsearch sinks. Alternatively you can use ElasticSinkBuilder
    Since:
    Jet 4.2

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static ElasticSinkBuilder<java.lang.Void> builder()
      Returns new instance of ElasticSinkBuilder
      static <T> Sink<T> elastic​(FunctionEx<? super T,​? extends org.elasticsearch.action.DocWriteRequest<?>> mapToRequestFn)
      Creates an Elasticsearch sink, uses a local instance of Elasticsearch
      static <T> Sink<T> elastic​(SupplierEx<org.elasticsearch.client.RestClientBuilder> clientFn, FunctionEx<? super T,​? extends org.elasticsearch.action.DocWriteRequest<?>> mapToRequestFn)
      Creates an Elasticsearch sink, uses a client obtained from clientFn and maps items using given mapToRequestFn

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • elastic

        @Nonnull
public static <T> Sink<T> elastic​(@Nonnull
                                  FunctionEx<? super T,​? extends org.elasticsearch.action.DocWriteRequest<?>> mapToRequestFn)
        Creates an Elasticsearch sink, uses a local instance of Elasticsearch

        Usage: 

        Sink<Map<String, Object>> sink = ElasticSinks.elastic(
   map -> new IndexRequest("my-index").source(map)
 );
        Parameters:
        mapToRequestFn - function that maps an item from a pipeline to an indexing request

      • elastic

        @Nonnull
public static <T> Sink<T> elastic​(@Nonnull
                                  SupplierEx<org.elasticsearch.client.RestClientBuilder> clientFn,
                                  @Nonnull
                                  FunctionEx<? super T,​? extends org.elasticsearch.action.DocWriteRequest<?>> mapToRequestFn)
        Creates an Elasticsearch sink, uses a client obtained from clientFn and maps items using given mapToRequestFn

        Usage: 

        Sink> sink = ElasticSinks.elastic(
   () -> ElasticClients.client("es-host", 9200),
   map -> new IndexRequest("my-index").source(map)
 );
        Type Parameters:
        T - type of incoming items
        Parameters:
        clientFn - supplier function returning configured RestClientBuilder
        mapToRequestFn - function that maps an item from a pipeline to an indexing request