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.batchReceivePolicy(org.apache.pulsar.client.api.BatchReceivePolicy batchReceivePolicy)
PulsarReaderBuilder<M,T>	PulsarReaderBuilder.connectionSupplier(SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier)
PulsarReaderBuilder<M,T>	PulsarReaderBuilder.dataConnectionRef(DataConnectionRef dataConnectionRef)
PulsarReaderBuilder<M,T>	PulsarReaderBuilder.preferredLocalParallelism(int preferredLocalParallelism)	Preferred local parallelism for every processor created by this builder.
<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.readerCustomizer(ConsumerEx<@NonNull org.apache.pulsar.client.api.ReaderBuilder<M>> readerCustomizer)	Allows additional customization and invocation of other ReaderBuilder method, that doesn't have a representative here.
PulsarReaderBuilder<M,T>	PulsarReaderBuilder.topic(String... topics)