org.apache.flink.api.java.io.jdbc.JDBCInputFormat НЕ ВНУТРИ FLiNK JARS

Question

• Я создал новый проект Java в затмение-Jee-Kepler-SR2-win32-x86_64.
• Я включил банки в flink-0.8.1 \ lib.
• Я создал стандартный WordCount, и он работает.
• Я изменил свой WordCount, чтобы принимать входные данные из текстовых файлов и CSV-файлов, и он работает.
• весь импорт работает отлично.
• затем я попробовал import org.apache.flink.api.java.io.jdbc.JDBCInputFormat.
• Eclipse не нашел?

Почему Eclipse не находит импорт?

Потому что внутри банки flink-java-0.8.1.jar нет каталога io/jdbc.

Я попробовал то же самое с Flink-0.9.0-бен-hadoop27 и в банке Flink-распред-0.9.0.jar нет орг/апач/Flink/API/Java/io/jdbc. Я несжал банку и искал строку «jdbcinputformat» с 0 результатами. Я искал строку «» JDBC и упоминается только в орг/Apache/log4j, орг/затмение/молы, и в других местах, которые не org.apache.flink.api.java.io

Так что мой вопрос: Где я могу найти класс JDBCInputFormat?

Что можно сделать для доступа к SqlServer2012 в Flink (помимо доступа к нему за пределами 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 запустить другую команду мерзавца клон:

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

В текущем проекте, вам необходимо изменить используемый Flink версию в файле п соответственно, например, 0,10-ПАНОРАМА или 0,9-ПАНОРАМА.