Avro支持Flink - scala

Question

如何閱讀avro來自Flink的scala？

是不是同一批次/流/表：StreamExecutionEnvironment/ExecutionEnvironment/TableEnvironment？

會是某事像：val custTS: TableSource = new AvroInputFormat("/path/to/file", ...)

下面是java的Avro中實現REF（connectors），但無法找到任何地方斯卡拉裁判：

AvroInputFormat<User> users = new AvroInputFormat<User>(in, User.class); 
    DataSet<User> usersDS = env.createInput(users); 

Answer 1

您可以使用弗林克的InputFormats，包括AvroInputFormat ，來自Java以及斯卡拉API：

• 流式傳輸&批量：val avroInputStream = env.createInput(new AvroInputFormat[User](in, classOf[User]))
• 表API：tableEnv.registerTable("table", avroInputStream.toTable)