Uses of Class
com.hazelcast.jet.elastic.ElasticSinkBuilder

Packages that use ElasticSinkBuilder
Package
Description
com.hazelcast.jet.elastic
Contains sources and sinks for Elasticsearch 7

  • Uses of ElasticSinkBuilder in com.hazelcast.jet.elastic

    Methods in com.hazelcast.jet.elastic that return ElasticSinkBuilder
    Modifier and Type
    Method
    Description
    static ElasticSinkBuilder<Void>
    ElasticSinks.builder()
    Deprecated, for removal: This API element is subject to removal in a future version.
    Returns new instance of ElasticSinkBuilder
    ElasticSinkBuilder<T>
    ElasticSinkBuilder.bulkRequestFn(SupplierEx<org.elasticsearch.action.bulk.BulkRequest> bulkRequestFn)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Set the supplier function for BulkRequest, defaults to new BulkRequest()
    ElasticSinkBuilder<T>
    ElasticSinkBuilder.clientFn(SupplierEx<org.elasticsearch.client.RestClientBuilder> clientFn)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Set the client supplier function
    <T_NEW> ElasticSinkBuilder<T_NEW>
    ElasticSinkBuilder.mapToRequestFn(FunctionEx<? super T_NEW,? extends org.elasticsearch.action.DocWriteRequest<?>> mapToRequestFn)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Set the function mapping the item from a pipeline item to an index request
    ElasticSinkBuilder<T>
    ElasticSinkBuilder.optionsFn(FunctionEx<? super org.elasticsearch.action.ActionRequest,org.elasticsearch.client.RequestOptions> optionsFn)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Set the function that provides RequestOptions
    ElasticSinkBuilder<T>
    ElasticSinkBuilder.retries(int retries)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Number of retries the connector will do in addition to Elastic client retries