FlinkProject怎么用

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

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

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

示例環(huán)境

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

示例數(shù)據(jù)源 （項目碼云下載）

Flink 系例 之 搭建開發(fā)環(huán)境與數(shù)據(jù)

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算子：從數(shù)據(jù)流的元數(shù)組中，重新排例參數(shù)并指定不同的下標位，返回新的數(shù)據(jù)流
 */
public class Project {

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

    /**
     * 在原有的數(shù)據(jù)源上重新排序組裝一個新的數(shù)據(jù)源，并打印
     * @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參數(shù)對應(yīng)數(shù)據(jù)流中Tuple3的下標位，可以指定多個下標位，返回一個新包含Tuple的數(shù)據(jù)流
        DataStream<Tuple2<Integer, String>> dataStream = env.fromCollection(tuple3List).project(2,0);
        dataStream.print();
        env.execute("flink Project job");
    }
}

打印結(jié)果

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

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

文章題目：FlinkProject怎么用
當前路徑：http://bm7419.com/article38/jdsisp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供定制開發(fā)、做網(wǎng)站、靜態(tài)網(wǎng)站、企業(yè)建站、動態(tài)網(wǎng)站、手機網(wǎng)站建設(shè)

廣告

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