概述

萬里第一步，要進行flink代碼開發(fā)，第一步先整個 flink 代碼工程

flink相關文章鏈接
flink官方文檔

兩種方式

一種命令行 mvn 創(chuàng)建，另一種直接在 idea 中創(chuàng)建一個工程，使用 mvn 的一些配置

mvn命令行創(chuàng)建

mvn 創(chuàng)建flink工程，創(chuàng)建的工程里多了一些兼容性配置，后面自己使用idea創(chuàng)建時，進行精簡及調整

# /Users/hyl/Desktop 構建的項目在此目錄下
appledeMacBook-Pro:Desktop hyl$ pwd
/Users/hyl/Desktop
mvn archetype:generate \
    -DarchetypeGroupId=org.apache.flink \
    -DarchetypeArtifactId=flink-walkthrough-datastream-java \
    -DarchetypeVersion=1.17.1 \
    -DgroupId=frauddetection \
    -DartifactId=frauddetection \
    -Dversion=0.1 \
    -Dpackage=spendreport \
    -DinteractiveMode=false

效果如下圖顯示

使用idea直接創(chuàng)建

創(chuàng)建好的工程會放在gitee上，直接點鏈接下載源碼，可以自己建立工程，將相關文件進行拷貝
gitee項目地址

代碼

在此給出簡要代碼

public class Example {

    public static void main(String[] args) throws Exception {
        final StreamExecutionEnvironment env =
                StreamExecutionEnvironment.getExecutionEnvironment();

        DataStream<Person> flintstones = env.fromElements(
                new Person("Fred", 35),
                new Person("Wilma", 35),
                new Person("Pebbles", 2));

        DataStream<Person> adults = flintstones.filter(new FilterFunction<Person>() {
            @Override
            public boolean filter(Person person) throws Exception {
                return person.age >= 18;
            }
        });

        adults.print();

        env.execute();
    }

    public static class Person {
        public String name;
        public Integer age;
        public Person() {}

        public Person(String name, Integer age) {
            this.name = name;
            this.age = age;
        }

        public String toString() {
            return this.name.toString() + ": age " + this.age.toString();
        }
    }
}

bug

執(zhí)行過程中遇到以下 bug ，解決方案如下

上圖這種報錯可以檢查一下，是否jar包設置了 provider
按下面圖示操作，運行環(huán)境包括 provider 即可

成功

上面兩步修改之后，即可運行成功，如下圖

結束

至此，工程代碼創(chuàng)建成功文章來源地址http://www.zghlxwxcb.cn/news/detail-732386.html

到了這里，關于2.flink編碼第一步(maven工程創(chuàng)建)的文章就介紹完了。如果您還想了解更多內容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章，希望大家以后多多支持TOY模板網(wǎng)！