1
  • 我在 eclipse-jee-kepler-SR2-win32-x86_64 中创建了一个新的 Java 项目。
  • 我已将 Jars 包含在 flink-0.8.1\lib 中。
  • 我已经创建了标准 WordCount 并且它可以工作。
  • 我已经修改了我的 WordCount 以从文本文件和 csv 文件中获取输入，并且它可以工作。
  • 所有的进口都完美无缺。
  • 然后我尝试了 import 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的地方提到

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

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

4

1 回答 1

1

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

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

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

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

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

于 2015-07-02T12:00:34.217 回答