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 <M> PulsarSinkBuilder<M,M>	PulsarSinks.builder(SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier)	Returns a builder object that offers a step-by-step fluent API to build a custom Pulsar Sink for the Pipeline API.
static <E, M> PulsarSinkBuilder<E,M>	PulsarSinks.builder(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.
static <M> PulsarSinkBuilder<M,M>	PulsarSinks.builder(PulsarSchema<M> schema)	Returns a builder object that offers a step-by-step fluent API to build a custom Pulsar Sink for the Pipeline API.
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.connectionSupplier(SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier)
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.dataConnectionRef(DataConnectionRef dataConnectionRef)
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.extractValueFn(FunctionEx<? super E,M> extractValueFn)
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.preferredLocalParallelism(int preferredLocalParallelism)	See SinkBuilder.preferredLocalParallelism(int).
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.producerConfig(Map<String,Object> producerConfig)
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.topic(String topic)