Flink - scalaのAvroサポート

Question

avroをFlinkからscalaに読み込む方法はありますか？

バッチ/ストリーム/テーブルで同じですか：StreamExecutionEnvironment/ExecutionEnvironment/TableEnvironment？

それはのようなSTHのようになります。val custTS: TableSource = new AvroInputFormat("/path/to/file", ...)以下

は、javaアブロ実装REF（connectors）ですが、どこにもScalaの参照を見つけることができません。

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

Answer 1

あなたはAvroInputFormat含め、FLINKのInputFormatsを使用することができますScala APIだけでなく、Javaからも、次のようになります。

• ストリーミング&バッチ：val avroInputStream = env.createInput(new AvroInputFormat[User](in, classOf[User]))
• 表API：tableEnv.registerTable("table", avroInputStream.toTable)