Compatible alternative for ParquetInputFormat in Flink > 1.14.0

[Meghajit Mazumdar <me...@gojek.com>]

In flink-parquet_2.12 version 1.13.0, there used to be a class called
as *org.apache.flink.formats.parquet.ParquetInputFormat<E>
. *This class's constructor used to accept
<https://javadoc.io/static/org.apache.flink/flink-parquet_2.12/1.13.0/org/apache/flink/formats/parquet/ParquetInputFormat.html#ParquetInputFormat-org.apache.flink.core.fs.Path-org.apache.parquet.schema.MessageType->
a org.apache.parquet.schema.MessageType and a org.apache.flink.core.fs.Path.

However, in flink-parquet_2.12 version > 1.14.0
<https://javadoc.io/doc/org.apache.flink/flink-parquet_2.12/1.14.0/index.html>,
this class doesn't seem to be present any more. There is this class but
it's constructor args are quite different and it requires us to specify the
RowType.

I understand this was a major version upgrade. But just wanted to confirm
if there is any other class/method to achieve the same behavior as
*ParquetInputFormat *in 1.14.0+ ?


-- 
*Regards,*
*Meghajit*