Package io.quarkus.pulsar.schema

Class JsonArraySchema

java.lang.Object
org.apache.pulsar.client.impl.schema.AbstractSchema<io.vertx.core.json.JsonArray>
io.quarkus.pulsar.schema.JsonArraySchema
All Implemented Interfaces:
Cloneable, org.apache.pulsar.client.api.Schema<io.vertx.core.json.JsonArray>
public class JsonArraySchema extends org.apache.pulsar.client.impl.schema.AbstractSchema<io.vertx.core.json.JsonArray>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final JsonArraySchema
    INSTANCE
     

    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

  • Constructor Summary

    Constructors
    Constructor
    Description
    JsonArraySchema()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.vertx.core.json.JsonArray
    decode(io.netty.buffer.ByteBuf byteBuf)
     
    byte[]
    encode(io.vertx.core.json.JsonArray message)
     
    org.apache.pulsar.common.schema.SchemaInfo
    getSchemaInfo()
     

    Methods inherited from class org.apache.pulsar.client.impl.schema.AbstractSchema

    atSchemaVersion, clone, decode

    Methods inherited from class java.lang.Object

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

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

    configureSchemaInfo, decode, decode, decode, decode, getNativeSchema, requireFetchingSchemaInfo, setSchemaInfoProvider, supportSchemaVersioning, validate

  • Field Details

  • Constructor Details

    • JsonArraySchema

      public JsonArraySchema()

  • Method Details

    • decode

      public io.vertx.core.json.JsonArray decode(io.netty.buffer.ByteBuf byteBuf)
      Specified by:
      decode in class org.apache.pulsar.client.impl.schema.AbstractSchema<io.vertx.core.json.JsonArray>

    • encode

      public byte[] encode(io.vertx.core.json.JsonArray message)

    • getSchemaInfo

      public org.apache.pulsar.common.schema.SchemaInfo getSchemaInfo()