org.apache.flink.api.java.io.jdbc.JDBCInputFormat 不在 FLINK JARS 中

Question

我创建了一个新的 Java 项目 eclipse-jee-kepler-SR2-win32-x86_64.
我已经将罐子包含在 flink-0.8.1\lib.
我已经创建了标准的 WordCount 并且它有效。
我修改了我的 WordCount 以从文本文件和 csv 文件中获取输入并且它有效。
所有导入都完美无缺。
然后我尝试了导入org.apache.flink.api.java.io.jdbc.JDBCInputFormat。
Eclipse 找不到它？

为什么 Eclipse 找不到导入？

因为jar里面flink-java-0.8.1.jar没有目录io/jdbc.

我用 flink-0.9.0-bin-hadoop27 和 jar flink-dist-0.9.0.jar 尝试了同样的事情 没有 org/apache/flink/api/java/io/jdbc 目录。我解压缩了 jar 并搜索了字符串 "jdbcinputformat"，结果为 0。我搜索了字符串 "jdbc"，它只在 org/apache/log4j、org/eclipse/jetty 和其他不是 org.apache.flink.api.java.io

的地方

所以我的问题是：我在哪里可以找到 class JDBCInputFormat?

我能做些什么来在 Flink 中访问 SqlServer2012（除了在 Flink 之外访问它，创建 csv 文件，然后在 Flink 中读取它们（这对我来说听起来很可怕，因为应该有一个 class 特定于那))?

Answer 1

没有包含相应的模块。为了使用它，您需要从头开始构建 Flink。运行以下命令：

git clone https://github.com/apache/flink.git
cd flink
mvn -DskipTests clean install

这为 flink-0.10-SNAPSHOT 构建了最新的快照。如果你想使用稳定版本 0.9 运行不同 git 克隆命令：

git clone -b release-0.9 https://github.com/apache/flink.git

在您当前的项目中，您需要相应地更改您的pom文件中使用的Flink版本，例如0.10-SNAPSHOT或0.9-SNAPSHOT。

org.apache.flink.api.java.io.jdbc.JDBCInputFormat 不在 FLINK JARS 中

org.apache.flink.api.java.io.jdbc.JDBCInputFormat NOT INSIDE FLINK JARS

jdbc

apache-flink