Package com.hazelcast.jet.pulsar

Class PulsarReaderBuilder<M,T>

java.lang.Object

com.hazelcast.jet.pulsar.PulsarReaderBuilder<M,T>

Type Parameters:

M - the type of the message read by pulsarReader

T - the type of data emitted from StreamSource

public final class PulsarReaderBuilder<M,T>
extends Object

See PulsarSources.pulsarReaderBuilder(String, SupplierEx, SupplierEx, FunctionEx)

Since:

6.0

Constructor Summary

Constructors

Constructor	Description
PulsarReaderBuilder(SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier)
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)	Required fields of Pulsar reader

Method Summary

Modifier and Type	Method	Description
PulsarReaderBuilder<M,T>	batchReceivePolicy(org.apache.pulsar.client.api.BatchReceivePolicy batchReceivePolicy)
StreamSource<T>	build()	Creates and returns the Pulsar Reader StreamSource with using builder configurations set before.
PulsarReaderBuilder<M,T>	connectionSupplier(SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier)
PulsarReaderBuilder<M,T>	dataConnectionRef(DataConnectionRef dataConnectionRef)
PulsarReaderBuilder<M,T>	preferredLocalParallelism(int preferredLocalParallelism)	Preferred local parallelism for every processor created by this builder.
<NEW_T> PulsarReaderBuilder<M,NEW_T>	projectionFn(FunctionEx<org.apache.pulsar.client.api.Message<M>,NEW_T> projectionFn)
PulsarReaderBuilder<M,T>	readerConfig(Map<String,Object> readerConfig)
PulsarReaderBuilder<M,T>	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>	topic(String... topics)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PulsarReaderBuilder

public PulsarReaderBuilder(SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier)

PulsarReaderBuilder

public PulsarReaderBuilder(@Nonnull
 String topic,
 @Nonnull
 SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier,
 @Nonnull
 SupplierEx<org.apache.pulsar.client.api.Schema<M>> schemaSupplier,
 @Nonnull
 FunctionEx<org.apache.pulsar.client.api.Message<M>,T> projectionFn)

Required fields of Pulsar reader

Parameters:

topic - Pulsar topic name to consume from

connectionSupplier - Pulsar client supplier

schemaSupplier - Pulsar messaging schema supplier.

projectionFn - converts a Pulsar message to an emitted item.

Method Details

topic

@Nonnull
public PulsarReaderBuilder<M,T> topic(@Nonnull
 String... topics)

connectionSupplier

@Nonnull
public PulsarReaderBuilder<M,T> connectionSupplier(@Nonnull
 SupplierEx<org.apache.pulsar.client.api.PulsarClient> connectionSupplier)

dataConnectionRef

@Nonnull
public PulsarReaderBuilder<M,T> dataConnectionRef(@Nonnull
 DataConnectionRef dataConnectionRef)

projectionFn

@Nonnull
public <NEW_T> PulsarReaderBuilder<M,NEW_T> projectionFn(@Nonnull
 FunctionEx<org.apache.pulsar.client.api.Message<M>,NEW_T> projectionFn)

readerCustomizer

@Nonnull
public PulsarReaderBuilder<M,T> readerCustomizer(@Nonnull
 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.

readerConfig

@Nonnull
public PulsarReaderBuilder<M,T> readerConfig(@Nonnull
 Map<String,Object> readerConfig)

Parameters:

readerConfig - Pulsar reader configurations that must contain reader name

preferredLocalParallelism

public PulsarReaderBuilder<M,T> preferredLocalParallelism(int preferredLocalParallelism)

Preferred local parallelism for every processor created by this builder.

batchReceivePolicy

@Nonnull
public PulsarReaderBuilder<M,T> batchReceivePolicy(@Nonnull
 org.apache.pulsar.client.api.BatchReceivePolicy batchReceivePolicy)

Parameters:

batchReceivePolicy - batch receive policy for the Reader

build

@Nonnull
public StreamSource<T> build()

Creates and returns the Pulsar Reader StreamSource with using builder configurations set before.