Package org.apache.pulsar.client.api.schema

Interface GenericSchema<T extends GenericRecord>

All Superinterfaces:

Cloneable, Schema<T>

@Public
@Stable
public interface GenericSchema<T extends GenericRecord>
extends Schema<T>

A schema that serializes and deserializes between GenericRecord and bytes.

Field Summary

Fields inherited from interface org.apache.pulsar.client.api.Schema

BOOL, BYTEBUFFER, BYTES, DATE, DOUBLE, FLOAT, INSTANT, INT16, INT32, INT64, INT8, LOCAL_DATE, LOCAL_DATE_TIME, LOCAL_TIME, STRING, TIME, TIMESTAMP

Method Summary

Modifier and Type	Method	Description
List<Field>	getFields()	Returns the list of fields.
GenericRecordBuilder	newRecordBuilder()	Create a builder to build GenericRecord.
static GenericSchema	of(SchemaInfo schemaInfo)
static GenericSchema	of(SchemaInfo schemaInfo, boolean useProvidedSchemaAsReaderSchema)

Methods inherited from interface org.apache.pulsar.client.api.Schema

clone, configureSchemaInfo, decode, decode, decode, decode, encode, getNativeSchema, getSchemaInfo, requireFetchingSchemaInfo, setSchemaInfoProvider, supportSchemaVersioning, validate

Method Details

getFields

List<Field> getFields()

Returns the list of fields.

Returns:

the list of fields of generic record.

newRecordBuilder

GenericRecordBuilder newRecordBuilder()

Create a builder to build GenericRecord.

Returns:

generic record builder

of

static GenericSchema of(SchemaInfo schemaInfo)

of

static GenericSchema of(SchemaInfo schemaInfo,
 boolean useProvidedSchemaAsReaderSchema)