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

Packages that use PulsarSchema

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

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

Modifier and Type	Method	Description
static PulsarSchema<ByteBuffer>	PulsarSchema.byteBuffer()	Returns the equivalent of Schema.BYTEBUFFER.
static PulsarSchema<byte[]>	PulsarSchema.bytes()	Returns the equivalent of Schema.BYTES.
static PulsarSchema<Double>	PulsarSchema.doubles()	Returns the equivalent of Schema.DOUBLE.
static PulsarSchema<Float>	PulsarSchema.floats()	Returns the equivalent of Schema.FLOAT.
static PulsarSchema<Short>	PulsarSchema.int16()	Returns the equivalent of Schema.INT16.
static PulsarSchema<Integer>	PulsarSchema.int32()	Returns the equivalent of Schema.INT32.
static PulsarSchema<Long>	PulsarSchema.int64()	Returns the equivalent of Schema.INT64.
static PulsarSchema<Byte>	PulsarSchema.int8()	Returns the equivalent of Schema.INT8.
static <T> PulsarSchema<T>	PulsarSchema.json(Class<T> clazz)	Returns the equivalent of Schema.JSON(Class).
static PulsarSchema<String>	PulsarSchema.string()	Returns the equivalent of Schema.STRING.

Methods in com.hazelcast.jet.pulsar with parameters of type PulsarSchema

Modifier and Type	Method	Description
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 <M> PulsarConsumerBuilder<M,org.apache.pulsar.client.api.Message<M>>	PulsarSources.pulsarConsumerBuilder(PulsarSchema<M> schema)	Returns a builder object that offers a step-by-step fluent API to build a custom Pulsar consumer StreamSource for the Pipeline API.
static <M, T> PulsarConsumerBuilder<M,T>	PulsarSources.pulsarConsumerBuilder(PulsarSchema<M> schema, 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 consumer 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.