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

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找不到导入？

因为在jarflink-java-0.8.1.jar中没有目录io/jdbc。

我在flink-0.9.0-bin-hadoop27中尝试了同样的操作，在jar中没有org/apache/flink/api/java/io/jdbc目录。我解压缩了jar并搜索字符串"jdbcinputformat"，结果为0。我搜索了字符串"jdbc"，它只在org/apache/log4j、.org/eclipse/jetty以及其他不是org.apache.flink.api.java.io的地方被提及

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

我该怎么做才能在Flink中访问SqlServer2012（除了在Flink之外访问它，创建csv文件，然后在Flink读取它们（这听起来很可怕，因为应该有一个特定的类））？

Answer 1

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

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

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

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

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