从Azure Blob存储中读取连续的镶木材料文件作为dataStream

Question

1. 我想读取具有格式 yyyy-mm-dd/hh/mm/file_name.parquet

   的目录中每秒在Azure Blob存储中生成的parquet文件。

2. 我想将数据读为datastream。

我们是否已经定义了任何可以做到这一点的Flink源？

我尝试使用：

// Partial version 1: the raw file is processed continuously
val path: String = "hdfs://hostname/path_to_file_dir/"
val textInputFormat: TextInputFormat = new TextInputFormat(new Path(path))
// monitor the file continuously every minute
val stream: DataStream[String] = streamExecutionEnvironment.readFile(textInputFormat, path, FileProcessingMode.PROCESS_CONTINUOUSLY, 60000)

上述方法中的问题：

1. 无法找到ReadParquetFile支持。

2. 它仅从路径中传递的特定目录处理文件。在我的情况下，给定目录格式为 yyyy-mm-dd/hh/mm/file_name.parquet