工程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

RAKsmart美国洛杉矶独立服务器 E3-1230 16GB内存 限时促销月$76

RAKsmart 商家我们应该较多的熟悉的,主营独立服务器和站群服务器业务。从去年开始有陆续的新增多个机房,包含韩国、日本、中国香港等。虽然他们家也有VPS主机,但是好像不是特别的重视,价格上特价的时候也是比较便宜的1.99美元月付(年中活动有促销)。不过他们的重点还是独立服务器,毕竟在这个产业中利润率较大。正如上面的Megalayer商家的美国服务器活动,这个同学有需要独立服务器,这里我一并整理...

Hostodo(年付12美元),美西斯波坎机房Linux VPS主机66折

Hostodo 商家是比较小众的国外VPS主机商,这不看到商家有推送促销优惠在美国西岸的斯波坎机房还有少部分库存准备通过低价格促销,年付低至12美元Linux VPS主机,且如果是1GB内存方案的可以享受六六折优惠,均是采用KVM架构,且可以支付宝付款。第一、商家优惠码优惠码:spokanessd 1GB+内存方案才可以用到优惠码,其他都是固定的优惠低至年12美元。第二、商家促销这里,我们可以看到...

hypervmart:英国/荷兰vps,2核/3GB内存/25GB NVMe空间/不限流量/1Gbps端口/Hyper-V,$10.97/季

hypervmart怎么样?hypervmart是一家国外主机商,成立于2011年,提供虚拟主机、VPS等,vps基于Hyper-V 2012 R2,宣称不超售,支持linux和windows,有荷兰和英国2个数据中心,特色是1Gbps带宽、不限流量。现在配置提高,价格不变,性价比提高了很多。(数据中心不太清楚,按以前的记录,应该是欧洲),支持Paypal付款。点击进入:hypervmart官方网...

java画图板为你推荐
最新qq空间代码qq空间都是有哪些免费代码!(要全部)申请证书求高手教下怎么申请证书中小企业信息化什么是企业信息化,应该这样实施qq怎么发邮件手机QQ怎么发邮件云挂机云软件挂机赚钱是骗子网络广告投放怎样在网络上进行广告的投放?宽带接入服务器什么是宽带接入系统?怎样绕过宽带接入系统上网qq等级表谁能告诉我QQ等级列表?去鼠标加速度怎样才能彻底去掉鼠标加速度office2007简体中文版office2007绿色下载 office2007下载安装
租用主机 如何注册网站域名 申请免费域名 ddos bluehost 海外服务器 彩虹ip ibox官网 电子邮件服务器 howfile 老左正传 四川电信商城 西安服务器托管 重庆联通服务器托管 脚本大全 腾讯服务器 美国asp空间 sonya 免费的加速器 百度新闻源申请 更多