溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章給大家介紹Pulsar IO 中怎么調用Schema ，內容非常詳細，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。
Schema 是一種描述數據的數據
。例如，數據庫中表的信息和字段類型等都是 Schema。Pulsar 對 Schema 也有比較好的支持。
public class SensorReading {public float temperature;public SensorReading(float temperature) {this.temperature = temperature;}// A no-arg constructor is requiredpublic SensorReading() {}public float getTemperature() {return temperature;}public void setTemperature(float temperature) {this.temperature = temperature;}}Producer<SensorReading> producer = client.newProducer(JSONSchema.of(SensorReading.class)).topic("my-topic").create();Consumer consumer = client.newConsumer(JSONSchema.of(SensorReading.class)).topic("my-topic").subscriptionName("my-subscription").subscribe();
if (conf.getSerdeClassName() != null && !conf.getSerdeClassName().isEmpty()) {
schema = (Schema<T>) topicSchema.getSchema(topic, typeArg, conf.getSerdeClassName(), true);
} else {
schema = (Schema<T>) topicSchema.getSchema(topic, typeArg, conf.getSchemaType(), true);
}
case NONE:return (Schema<T>) Schema.BYTES;case AUTO_CONSUME:case AUTO:return (Schema<T>) Schema.AUTO_CONSUME();case STRING:return (Schema<T>) Schema.STRING;case AVRO:return AvroSchema.of(SchemaDefinition.<T>builder().withPojo(clazz).build());case JSON:return JSONSchema.of(SchemaDefinition.<T>builder().withPojo(clazz).build());case KEY_VALUE:return (Schema<T>)Schema.KV_BYTES();case PROTOBUF:return ProtobufSchema.ofGenericClass(clazz, Collections.emptyMap());}
關于Pulsar IO 中怎么調用Schema 就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
