Hi flink team, is there any example implementation on using flink job to read avro files from s3 path? Can I use

AvroInputFormat

like this?

String s3Path =
        "s3://...";
    AvroInputFormat<Customer> avroInputFormat =
        new AvroInputFormat<>(new Path(s3Path), Customer.class);
    TypeInformation<Customer> typeInfo = TypeInformation.of(Customer.class);
    DataStream<Customer> datastream = env.createInput(avroInputFormat, typeInfo);