這篇文章主要講解了“Flink Project怎么用”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“Flink Project怎么用”吧！

成都創新互聯公司是專業的麥蓋提網站建設公司，麥蓋提接單;提供網站設計制作、成都網站制作,網頁設計,網站設計,建網站,PHP網站建設等專業做網站服務;采用PHP框架,可快速的進行麥蓋提網站開發網頁制作和功能擴展;專業做搜索引擎喜愛的網站,專業的做網站團隊,希望更多企業前來合作!

Project算子：從數據流的元數組中，重新排例參數并指定不同的下標位，返回新的數據流

示例環境

java.version: 1.8.x
flink.version: 1.11.1

示例數據源 （項目碼云下載）

Flink 系例 之 搭建開發環境與數據

Project.java

import com.flink.examples.DataSource;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.api.java.tuple.Tuple3;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

import java.util.List;

/**
 * @Description Project算子：從數據流的元數組中，重新排例參數并指定不同的下標位，返回新的數據流
 */
public class Project {

    /**
     * 官方文檔：https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/stream/operators/
     */

    /**
     * 在原有的數據源上重新排序組裝一個新的數據源，并打印
     * @param args
     * @throws Exception
     */
    public static void main(String[] args) throws Exception {
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        List<Tuple3<String,String,Integer>> tuple3List = DataSource.getTuple3ToList();
        //project(索引下標，索引下標)，project參數對應數據流中Tuple3的下標位，可以指定多個下標位，返回一個新包含Tuple的數據流
        DataStream<Tuple2<Integer, String>> dataStream = env.fromCollection(tuple3List).project(2,0);
        dataStream.print();
        env.execute("flink Project job");
    }
}

打印結果

1> (29,王五)3> (20,張三)2> (32,劉六)3> (18,伍七)4> (24,李四)4> (30,吳八)

感謝各位的閱讀，以上就是“Flink Project怎么用”的內容了，經過本文的學習后，相信大家對Flink Project怎么用這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是創新互聯，小編將為大家推送更多相關知識點的文章，歡迎關注！

文章題目：FlinkProject怎么用
當前路徑：http://m.2m8n56k.cn/article38/jdsisp.html

成都網站建設公司_創新互聯，為您提供定制開發、做網站、靜態網站、企業建站、動態網站、手機網站建設

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯