Apache Flink - tworzenie aplikacji Flink
W tym rozdziale nauczymy się, jak stworzyć aplikację Flink.
Otwórz Eclipse IDE, kliknij New Project i Select Java Project.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/create_flink_application.jpg)
Podaj nazwę projektu i kliknij Zakończ.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/create_flink_application2.jpg)
Teraz kliknij Zakończ, jak pokazano na poniższym zrzucie ekranu.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/create_flink_application3.jpg)
Teraz kliknij prawym przyciskiem myszy src i przejdź do New >> Class.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/create_flink_application4.jpg)
Podaj nazwę klasy i kliknij Zakończ.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/create_flink_application5.jpg)
Skopiuj i wklej poniższy kod w Edytorze.
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.util.Collector;
public class WordCount {
// *************************************************************************
// PROGRAM
// *************************************************************************
public static void main(String[] args) throws Exception {
final ParameterTool params = ParameterTool.fromArgs(args);
// set up the execution environment
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
// make parameters available in the web interface
env.getConfig().setGlobalJobParameters(params);
// get input data
DataSet<String> text = env.readTextFile(params.get("input"));
DataSet<Tuple2<String, Integer>> counts =
// split up the lines in pairs (2-tuples) containing: (word,1)
text.flatMap(new Tokenizer())
// group by the tuple field "0" and sum up tuple field "1"
.groupBy(0)
.sum(1);
// emit result
if (params.has("output")) {
counts.writeAsCsv(params.get("output"), "\n", " ");
// execute program
env.execute("WordCount Example");
} else {
System.out.println("Printing result to stdout. Use --output to specify output path.");
counts.print();
}
}
// *************************************************************************
// USER FUNCTIONS
// *************************************************************************
public static final class Tokenizer implements FlatMapFunction<String, Tuple2<String, Integer>> {
public void flatMap(String value, Collector<Tuple2<String, Integer>> out) {
// normalize and split the line
String[] tokens = value.toLowerCase().split("\\W+");
// emit the pairs
for (String token : tokens) {
if (token.length() > 0) {
out.collect(new Tuple2<>(token, 1));
}
}
}
}
}
Otrzymasz wiele błędów w edytorze, ponieważ biblioteki Flink muszą zostać dodane do tego projektu.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/flink_libraries_added.jpg)
Kliknij prawym przyciskiem myszy projekt >> Ścieżka budowania >> Konfiguruj ścieżkę budowania.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/right_click_project.jpg)
Wybierz kartę Biblioteki i kliknij Dodaj zewnętrzne pliki JAR.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/select_libraries.jpg)
Przejdź do katalogu bibliotek Flink, wybierz wszystkie 4 biblioteki i kliknij OK.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/flinks_lib_directory.jpg)
Przejdź do zakładki Zamów i eksportuj, wybierz wszystkie biblioteki i kliknij OK.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/order_and_export_tab.jpg)
Zobaczysz, że błędów już nie ma.
Teraz wyeksportujmy tę aplikację. Kliknij projekt prawym przyciskiem myszy i kliknij Eksportuj.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/export_this_application.jpg)
Wybierz plik JAR i kliknij Dalej
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/select_jar_file.jpg)
Podaj ścieżkę docelową i kliknij Dalej
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/destination_path.jpg)
Kliknij Dalej>
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/click_next.jpg)
Kliknij Przeglądaj, wybierz główną klasę (WordCount) i kliknij Zakończ.
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/click_finish.jpg)
Note - Kliknij OK, jeśli pojawi się jakieś ostrzeżenie.
Uruchom poniższe polecenie. Spowoduje to dalsze uruchomienie właśnie utworzonej aplikacji Flink.
./bin/flink run /home/ubuntu/wordcount.jar --input README.txt --output /home/ubuntu/output
![](https://post.nghiatu.com/assets/tutorial/apache_flink/images/get_warning.jpg)