Uses of Class
com.hazelcast.jet.pulsar.PulsarSinkBuilder

Packages that use PulsarSinkBuilder

Package	Description
com.hazelcast.jet.pulsar	Contains a connector for Apache Pulsar which enables Hazelcast Jet pipelines to produce and consume messages on Pulsar topics.

Uses of PulsarSinkBuilder in com.hazelcast.jet.pulsar

Methods in com.hazelcast.jet.pulsar that return PulsarSinkBuilder

Modifier and Type	Method	Description
static <E, M> PulsarSinkBuilder<E,M>	PulsarSinks.builder(String topic, SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier, SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier, FunctionEx<? super E,M> extractValueFn)	Returns a builder object that offers a step-by-step fluent API to build a custom Pulsar Sink for the Pipeline API.
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.extractKeyFn(FunctionEx<? super E,String> extractKeyFn)
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.extractPropertiesFn(FunctionEx<? super E,Map<String,String>> extractPropertiesFn)
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.extractTimestampFn(FunctionEx<? super E,Long> extractTimestampFn)
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.preferredLocalParallelism(int preferredLocalParallelism)	See SinkBuilder.preferredLocalParallelism(int).
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.producerConfig(Map<String,Object> producerConfig)