工程java画图板

java画图板  时间:2021-02-24  阅读:()
Flink快速上手之JavaAPI使用本文将介绍如何通过简单地几步来开始编写你的FlinkJava程序.
要求编写你的FlinkJava程序唯一的要求是需要安装Maven3.
0.
4(或者更高)和Java7.
x(或者更高)创建FlinkJava工程使用下面其中一个命令来创建FlinkJava工程1、使用Mavenarchetypes:$mvnarchetype:generate\-DarchetypeGroupId=org.
apache.
flink\-DarchetypeArtifactId=flink-quickstart-java\-DarchetypeVersion=1.
0.
02、运行quickstart脚本$curlhttps://flink.
apache.
org/q/quickstart.
sh|bash上面两个命令(使用Maven创建的时候需要输入artifactId、groupId等相关信息)运行完之后都会产生类似于以下的目录结构:.
quickstartpom.
xmlsrcmainjavaorgmyorgquickstartJob.
javaSocketTextStreamWordCount.
java1/4WordCount.
javaresourceslog4j.
properties8directories,5files检查工程您的工作目录中会出现一个新的目录.
如果你使用了curl命令来创建FlinkJava工程,这个目录的名称是quickstart.
否则,就是你输入的artifactId名字.
这个工程是一个Maven工程,包含三个类.
Job是一个基本的框架程序,SocketTextStreamWordCount和WordCount是一个简单的单词次数计算示例.
需要注意的是,这三个类的main方法都允许你在开发/测试模式下启动Flink.
我们推荐将这个工程导入到你的IDE中,并进行开发和测试.
如果你用的是Eclipse,可以使用m2e插件来导入Maven工程.
有些Eclipse发行版默认嵌入了这个插件,其他的需要你手动去安装.
IntelliJIDE内置就提供了对Maven工程的支持.
给MacOSX用户的建议:默认的JVM堆内存对Flink来说太小了,你必须手动增加内存.
这里以Eclipse为例,依次选择RunConfigurations->Arguments,然后在VMArguments里写入:-Xmx800m.
编译工程如果你想要编译你的工程,进入到工程所在目录,并输入mvncleaninstall-Pbuild-jar命令.
你将会找到target/your-artifact-id-1.
0-SNAPSHOT.
jar文件,它可以在任意的Flink集群上运行.
还有一个fat-jar,名为target/your-artifact-id-1.
0-SNAPSHOT-flink-fat-jar.
jar,包含了所有添加到Maven工程的依赖.
下一步开始编写我们自己的程序Quickstart工程包含了一个WordCount的实现,也就是大数据处理系统的HelloWorld.
WordCount的目标是计算文本中单词出现的频率.
比如:单词"the"或者"house"在所有的Wikipedia文本中出现了多少次.
样本输入2/4bigdataisbig样本输出big2data1is1下面的代码就是Quickstart工程的WordCount实现,它使用两种操作(FlatMap和Reduce)处理了一些文本,并且在标准输出中打印了单词的计数结果.
publicclassWordCount{publicstaticvoidmain(String[]args)throwsException{//setuptheexecutionenvironmentfinalExecutionEnvironmentenv=ExecutionEnvironment.
getExecutionEnvironment();//getinputdataDataSettext=env.
fromElements("Tobe,ornottobe,--thatisthequestion:--","Whether'tisnoblerinthemindtosuffer","Theslingsandarrowsofoutrageousfortune","Ortotakearmsagainstaseaoftroubles,");DataSet>counts=//splitupthelinesinpairs(2-tuples)containing:(word,1)text.
flatMap(newLineSplitter())//groupbythetuplefield"0"andsumuptuplefield"1".
groupBy(0).
aggregate(Aggregations.
SUM,1);//emitresultcounts.
print();}}3/4这些操作是在专门的类中定义的,下面是LineSplitter类.
publicclassLineSplitterimplementsFlatMapFunction>{@OverridepublicvoidflatMap(Stringvalue,Collector>out){//normalizeandsplitthelineintowordsString[]tokens=value.
toLowerCase().
split("\\W+");//emitthepairsfor(Stringtoken:tokens){if(token.
length()>0){out.
collect(newTuple2(token,1));}}}}完整代码参见https://github.
com/apache/flink/blob/master//flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.
java本博客文章除特别声明,全部都是原创!
原创文章版权归过往记忆大数据(过往记忆)所有,未经许可不得转载.
本文链接:【】()PoweredbyTCPDF(www.
tcpdf.
org)4/4

totyun:香港cn2 vps,5折优惠,$6/月,10Mbps带宽,不限流量,2G内存/2核/20g+50g

totyun,新公司,主要运作香港vps、日本vps业务,接入cn2网络,不限制流量!VPS基于KVM虚拟,采用系统盘和数据盘分离,从4G内存开始支持Windows系统...大家注意下,网络分“Premium China”、“Global”,由于站长尚未测试,所以也还不清楚情况,有喜欢吃螃蟹的尝试过不妨告诉下站长。官方网站:https://totyun.com一次性5折优惠码:X4QTYVNB3P...

virmach:AMD平台小鸡,赌一把,单车变摩托?$7.2/年-512M内存/1核/10gSSD/1T流量,多机房可选

virmach送来了夏季促销,价格低到爆炸,而且在低价的基础上还搞首年8折,也就是说VPS低至7.2美元/年。不过,这里有一点要说明:你所购买的当前的VPS将会在09/30/2021 ~ 04/30/2022进行服务器转移,而且IP还会改变,当前的Intel平台会换成AMD平台,机房也会变动(目前来看以后会从colocrossing切换到INAP和Psychz),采取的是就近原则,原来的水牛城可能...

hostkey俄罗斯、荷兰GPU显卡服务器/免费Windows Server

Hostkey.com成立于2007年的荷兰公司,主要运营服务器出租与托管,其次是VPS、域名、域名证书,各种软件授权等。hostkey当前运作荷兰阿姆斯特丹、俄罗斯莫斯科、美国纽约等数据中心。支持Paypal,信用卡,Webmoney,以及支付宝等付款方式。禁止VPN,代理,Tor,网络诈骗,儿童色情,Spam,网络扫描,俄罗斯色情,俄罗斯电影,俄罗斯MP3,俄罗斯Trackers,以及俄罗斯法...

java画图板为你推荐
视频截图软件什么视频截图软件最好用解压程序软件怎么解压拂晓雅阁现在最流行的系统是那个???快速美白好方法脸部快速美白有什么好方法啊二叉树遍历写出二叉树的先序遍历、中序遍历、后序遍历。http与https的区别http和https到底有什么区别啊???手机区号有的手机号中间的号码是地区区号,那是什么卡数码资源网安卓有没有可以离线刷题的软件?中小企业信息化信息化为中小企业发展带来了哪些机遇彩信中心移动的短信中心号码是多少
虚拟主机系统 花生壳域名贝锐 七牛优惠码 lamp 冰山互联 pccw 外贸主机 cloudstack 美国便宜货网站 台湾谷歌地址 帽子云 有奖调查 已备案删除域名 hkg 速度云 域名接入 佛山高防服务器 电信虚拟主机 上海联通宽带测速 服务器是干什么用的 更多