我尝试在scala上使用ApacheFlink实现简单的推理操作符。现在我可以从.csv文件中以流的形式读取数据。但我无法处理rdf和owl数据处理。以下是从.csv加载数据的代码：

val csvTableSource = CsvTableSource
      .builder
      .path("src/main/resources/data.stream")
      .field("subject", Types.STRING)
      .field("predicate", Types.STRING)
      .field("object", Types.STRING)
      .fieldDelimiter(";")
      .build()

有人能给我举个例子，用rdf和owl用flink加载这些数据吗？据我所知，rdf流包含动态数据，owl用于静态数据。我必须创建一个简单的推理操作符，我可以询问信息，例如谁是朋友的朋友。
任何帮助都将不胜感激。