Package com.hazelcast.jet.pulsar

Class PulsarSinkBuilder<E,M>

java.lang.Object

com.hazelcast.jet.pulsar.PulsarSinkBuilder<E,M>

Type Parameters:

E - the type of stream item

M - the type of the message published by PulsarProducer

All Implemented Interfaces:

Serializable

public final class PulsarSinkBuilder<E,M>
extends Object
implements Serializable

See PulsarSinks.builder(String, SupplierEx, SupplierEx, FunctionEx)

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
PulsarSinkBuilder(String topic, SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier, SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier, FunctionEx<? super E,M> extractValueFn)	Required fields of Pulsar sink

Method Summary

Modifier and Type	Method	Description
Sink<E>	build()	Creates and returns the Pulsar Sink with using builder configurations set before.
PulsarSinkBuilder<E,M>	extractKeyFn(FunctionEx<? super E,String> extractKeyFn)
PulsarSinkBuilder<E,M>	extractPropertiesFn(FunctionEx<? super E,Map<String,String>> extractPropertiesFn)
PulsarSinkBuilder<E,M>	extractTimestampFn(FunctionEx<? super E,Long> extractTimestampFn)
PulsarSinkBuilder<E,M>	preferredLocalParallelism(int preferredLocalParallelism)	See SinkBuilder.preferredLocalParallelism(int).
PulsarSinkBuilder<E,M>	producerConfig(Map<String,Object> producerConfig)

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarSinkBuilder

public PulsarSinkBuilder(@Nonnull
 String topic,
 @Nonnull
 SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier,
 @Nonnull
 SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier,
 @Nonnull
 FunctionEx<? super E,M> extractValueFn)

Required fields of Pulsar sink

Parameters:

topic - Pulsar topic name to publish to

connectionSupplier - Pulsar client supplier

extractValueFn - extracts the message value from the emitted items.

schemaSupplier - Pulsar messaging schema supplier.

Method Details

producerConfig

@Nonnull
public PulsarSinkBuilder<E,M> producerConfig(Map<String,Object> producerConfig)

Parameters:

producerConfig - The configurations for PulsarProducer

extractKeyFn

@Nonnull
public PulsarSinkBuilder<E,M> extractKeyFn(FunctionEx<? super E,String> extractKeyFn)

Parameters:

extractKeyFn - extracts the message key from the emitted items.

extractPropertiesFn

@Nonnull
public PulsarSinkBuilder<E,M> extractPropertiesFn(FunctionEx<? super E,Map<String,String>> extractPropertiesFn)

Parameters:

extractPropertiesFn - extracts the message properties from the emitted items.

extractTimestampFn

@Nonnull
public PulsarSinkBuilder<E,M> extractTimestampFn(FunctionEx<? super E,Long> extractTimestampFn)

Parameters:

extractTimestampFn - the function that extracts the timestamp from the emitted item.

preferredLocalParallelism

@Nonnull
public PulsarSinkBuilder<E,M> preferredLocalParallelism(int preferredLocalParallelism)

See SinkBuilder.preferredLocalParallelism(int).

build

@Nonnull
public Sink<E> build()

Creates and returns the Pulsar Sink with using builder configurations set before.