代码之家 › 专栏 › 技术社区 › Pasq

具有泛型类型问题的Avro序列化

avro4s avro generics scala

Pasq · 技术社区 · 6 年前

我需要在Scala中编写一个函数,返回一个用AvroOutputStream序列化的字节数组,但在Scala中,我无法获取传入输入的泛型对象的类。下面是我的util类:

class AvroUtils {

    def createByteArray[T](obj: T): Array[Byte] = {
        val byteArrayStream = new ByteArrayOutputStream()
        val output = AvroOutputStream.binary[T](byteArrayStream)
        output.write(obj)
        output.close()
        byteArrayStream.toByteArray()
    }
}

您可以看到,如果要测试这段代码,AvroOutputStream无法识别t类,因此无法为其生成模式。希望你能帮忙!谢谢

PS:已经尝试过TypeTag和ClassTag,但没有任何效果。

1 回复 | 直到 6 年前

Yuval Itzchakov 6 年前

您需要为添加适当的隐式 T 即 SchemaFor 和 ToRecord :

def createByteArray[T : SchemaFor : ToRecord](obj: T): Array[Byte] = {
  val byteArrayStream = new ByteArrayOutputStream()
  val output = AvroOutputStream.binary[T](byteArrayStream)
  output.write(obj)
  output.close()
  byteArrayStream.toByteArray()
}

推荐文章

user9750148 · Scala-如何从Avro模式中获取所有字段的名称?

6 年前

user9750148 · 如何从Avro模式创建有效的JSON示例?

6 年前

Suchita · 如何使用Avro反序列化器和Avro序列化器为KafkaStreams编写Junit测试用例

6 年前

CuriousMind · Hadoop自身的序列化及其与AVRO序列化的关系?

6 年前

revy · 配置单元AVRO表创建语法

6 年前

cscan ssice · 反序列化Avro序列化Kafka流时出现问题

6 年前

Atul Ojha · java上使用Avro发送和接收日期类型

6 年前

Pasq · 具有泛型类型问题的Avro序列化

6 年前

Souhaib Guitouni · 将Spark结构化流媒体与融合模式注册表集成

6 年前

M80 · 通过为包含JSON的列定义模式来创建配置单元表的视图

7 年前