According to the Flink document, it's possible to load Avro file like the following:
AvroInputFormat<User> users = new AvroInputFormat<User>(in, User.class);DataSet<User> usersDS = env.createInput(users); It's a bit confusing for me. I guess the User is a predefined class. My question is can Flink detect the Avro file schema automatically? How can I load Avro file without any predefined class?
