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(PulsarSchema<M> schema, 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 <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.httpServiceUrl(String httpServiceUrl)
<NEW_E> PulsarSinkBuilder<NEW_E,M>	PulsarSinkBuilder.inputType(Class<NEW_E> type)	Helper function to force type interference.
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.preferredLocalParallelism(int preferredLocalParallelism)	Preferred local parallelism for every processor created by this builder.
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.producerConfig(Map<String,Object> producerConfig)
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.producerCustomizer(ConsumerEx<@NonNull org.apache.pulsar.client.api.ProducerBuilder<M>> producerCustomizer)	Customizer of the ProducerBuilder created by this sink.
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.topic(String topic)
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.transactionTimeout(Duration transactionTimeout)
PulsarSinkBuilder<E,M>	PulsarSinkBuilder.useTransactions(boolean enable)	Enables or disables the exactly-once behavior of the sink using two-phase commit of state snapshots.