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

All Implemented Interfaces:

Serializable

public final class PulsarReaderBuilder<M,T>
extends Object
implements Serializable

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

See Also:

• Serialized Form

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
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)
<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>	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)

readerConfig

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

Parameters:

readerConfig - Pulsar reader configurations that must contain reader name

build

@Nonnull
public StreamSource<T> build()

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