org.apache.flink.api.java.io.jdbc.JDBCInputFormat不在FLINK罐子里
org.apache.flink.api.java.io.jdbc.JDBCInputFormat不在FLINK罐子里
提问于 2015-07-02 03:17:50
- 我已经在eclipse-jee-kepler-SR2-win32-x86_64中创建了一个新的Java项目。
- 我在flink-0.8.1\lib中包含了这些Jars。
- 我已经创建了标准的WordCount，它可以工作。
- 我已经修改了我的WordCount，以便从文本文件和csv文件中获取输入，并且它可以工作。
- 所有的进口产品都运行得很好。
- 然后我尝试导入org.apache.flink.api.java.io.jdbc.JDBCInputFormat.
- 月食找不到吗？
为什么Eclipse找不到导入？
因为在jar flink-java-0.8.1.jar中没有io/jdbc目录。
我在flink-0.9.0-bin-hadoop27 27中尝试了同样的方法，而在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中读取它们(这听起来很可怕，因为应该有一个特定于此的类))？
回答 1
Stack Overflow用户
回答已采纳
发布于 2015-07-02 04:00:34
不包括相应的模块。为了使用它，您需要从头开始构建Flink。运行以下命令：
git clone https://github.com/apache/flink.git
cd flink
mvn -DskipTests clean install这将生成flink-0.10-快照的最新快照。如果要使用稳定版本0.9，请运行不同的git克隆命令：
git clone -b release-0.9 https://github.com/apache/flink.git在当前项目中，您需要相应地更改pom文件中使用的Flink版本，例如0.10快照或0.9快照。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/31183115
复制相关文章
相似问题
腾讯云开发者
