Interface GenericSchema<T extends GenericRecord>
-
- All Superinterfaces:
java.lang.Cloneable
,Schema<T>
@Public @Stable public interface GenericSchema<T extends GenericRecord> extends Schema<T>
A schema that serializes and deserializes betweenGenericRecord
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
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.List<Field>
getFields()
Returns the list of fields.GenericRecordBuilder
newRecordBuilder()
Create a builder to buildGenericRecord
.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, encode, getNativeSchema, getSchemaInfo, requireFetchingSchemaInfo, setSchemaInfoProvider, supportSchemaVersioning, validate
-
-
-
-
Method Detail
-
getFields
java.util.List<Field> getFields()
Returns the list of fields.- Returns:
- the list of fields of generic record.
-
newRecordBuilder
GenericRecordBuilder newRecordBuilder()
Create a builder to buildGenericRecord
.- Returns:
- generic record builder
-
of
static GenericSchema of(SchemaInfo schemaInfo)
-
of
static GenericSchema of(SchemaInfo schemaInfo, boolean useProvidedSchemaAsReaderSchema)
-
-