Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import com.google.protobuf.ByteString
- object Test {
- def main(args: Array[String]): Unit = {
- import me.lyh.protobuf.generic.proto.Schemas.Optional
- import me.lyh.protobuf.{generic => pg}
- val jsonSchema = pg.Schema.of[Optional].toJson
- val bytes = Optional.newBuilder()
- .setStringField("hello world")
- .setBytesField(ByteString.copyFromUtf8("bytes"))
- .setInt32Field(1)
- .setDoubleField(1.0)
- .setBoolField(true)
- .build()
- .toByteArray
- // generic reader
- val schema = pg.Schema.fromJson(jsonSchema)
- val reader = pg.GenericReader.of(schema)
- val record = reader.read(bytes)
- println(schema.toJson)
- println(record.get("string_field").asInstanceOf[String])
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement