設定執行模式
執行模式可以通過execution.runtime-mode
配置進行設定,該配置可配置的值包括:
這個配置可以通過命令列引數進行配置(bin/flink run ...),或者以程式設計的方式指定。
命令列方式指定樣例:
bin/flink run -dexecution.runtime-mode=batch examples/streaming/wordcount.jar
**方式指定樣例:
stremexecutionenvironment env = streamexecutionenvironment.getexecutionenvironment();
env.setruntimemode(runtimeexecutionmode.batch);
備註:建議使用者不要通過**的方式指定,而是在提交應用時通過命令列引數指定。從而使我們的應用更彈性,相容於任意的執行模式而不用進行任何修改。
Flink 快速入門案例二(參考官方文件)
具有一定實際意義的流處理程式。結合信用卡欺詐驗證場景,實現的具體demo。package com.sanxiau import org.apache.flink.streaming.api.datastream.datastream import org.apache.flink.streaming...
夏新大V官方ROM更新帖 持續更新中
首發 夏新大v 5.4版本詳細 刷機教程 360與國內優秀手機廠家合作,由360提供軟體網際網路服務,手機廠商提供硬體製造,360為使用者直接通過配置高 體驗好 低 的優質手機!夏新大v的推出更是受到了大家的追捧!我們也ji在不斷的進行此手機rom的更新,以便讓使用者用上更順暢,更穩定的rom以及擁...
iOS開發系列文章(持續更新 )
ios開發系列的文章,內容循序漸進,包含c語言 objc ios開發以及日後要寫的遊戲開發和swift程式設計幾部分內容。文章會持續更新,希望大家多多關注,如果文章對你有幫助請點贊支援,多謝!以上群已滿,歡迎加入新群 498257635 ios開發系列 c語言之基礎知識 ios開發系列 c語言之陣列...