Package com.hazelcast.jet.pulsar

Class PulsarSchema<E>

java.lang.Object

com.hazelcast.jet.pulsar.PulsarSchema<E>

public class PulsarSchema<E>
extends Object

Helper class that holds context info about Pulsar's Schema, without using Pulsar API directly.

Since:

6.0

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Details

bytes

@Nonnull
public static PulsarSchema<byte[]> bytes()

Returns the equivalent of Schema.BYTES.

string

@Nonnull
public static PulsarSchema<String> string()

Returns the equivalent of Schema.STRING.

doubles

@Nonnull
public static PulsarSchema<Double> doubles()

Returns the equivalent of Schema.DOUBLE.

floats

@Nonnull
public static PulsarSchema<Float> floats()

Returns the equivalent of Schema.FLOAT.

int8

@Nonnull
public static PulsarSchema<Byte> int8()

Returns the equivalent of Schema.INT8.

int16

@Nonnull
public static PulsarSchema<Short> int16()

Returns the equivalent of Schema.INT16.

int32

@Nonnull
public static PulsarSchema<Integer> int32()

Returns the equivalent of Schema.INT32.

int64

@Nonnull
public static PulsarSchema<Long> int64()

Returns the equivalent of Schema.INT64.

byteBuffer

@Nonnull
public static PulsarSchema<ByteBuffer> byteBuffer()

Returns the equivalent of Schema.BYTEBUFFER.

json

@Nonnull
public static <T> PulsarSchema<T> json(@Nonnull
 Class<T> clazz)

Returns the equivalent of Schema.JSON(Class).