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

Packages that use PulsarReaderBuilder

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 PulsarReaderBuilder in com.hazelcast.jet.pulsar

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

Modifier and Type	Method	Description
PulsarReaderBuilder<M,T>	PulsarReaderBuilder.connectionSupplier(SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier)
PulsarReaderBuilder<M,T>	PulsarReaderBuilder.dataConnectionRef(DataConnectionRef dataConnectionRef)
<NEW_T> PulsarReaderBuilder<M,NEW_T>	PulsarReaderBuilder.projectionFn(FunctionEx<org.apache.pulsar.client.api.Message<M>,NEW_T> projectionFn)
static <M, T> PulsarReaderBuilder<M,T>	PulsarSources.pulsarReaderBuilder(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 reader StreamSource for the Pipeline API.
static <M, T> PulsarReaderBuilder<M,T>	PulsarSources.pulsarReaderBuilder(PulsarSchema<M> schema)	Returns a builder object that offers a step-by-step fluent API to build a custom Pulsar reader StreamSource for the Pipeline API.
static <M, T> PulsarReaderBuilder<M,T>	PulsarSources.pulsarReaderBuilder(String topic, SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier, SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier, FunctionEx<org.apache.pulsar.client.api.Message<M>,T> projectionFn)	Returns a builder object that offers a step-by-step fluent API to build a custom Pulsar reader StreamSource for the Pipeline API.
PulsarReaderBuilder<M,T>	PulsarReaderBuilder.readerConfig(Map<String,Object> readerConfig)
PulsarReaderBuilder<M,T>	PulsarReaderBuilder.topic(String... topics)