草庐IT

JavaHadoop

全部标签

MacOS下安装Apache Flink及测试WordCount

1.安装java1.8版本steven@wangyuxiangdeMacBook-Pro~java-versionjavaversion"1.8.0_211"Java(TM)SERuntimeEnvironment(build1.8.0_211-b12)JavaHotSpot(TM)64-BitServerVM(build25.211-b12,mixedmode)2.安装flink使用brew安装flink,命令如下:brewinstallapache-flink3.查看是否安装成功steven@wangyuxiangdeMacBook-Pro~flink-vVersion:1.13.2,

kafka分区扩容和修改三个副本数

Kafka是Apache旗下的一款分布式流媒体平台,Kafka是一种高吞吐量、持久性、分布式的发布订阅的消息队列系统。它最初由LinkedIn(领英)公司发布,使用Scala语言编写,与2010年12月份开源,成为Apache的顶级子项目。它主要用于处理消费者规模网站中的所有动作流数据。动作指(网页浏览、搜索和其它用户行动所产生的数据)。​消息系统分类我们知道常见的消息系统有Kafka、RabbitMQ、ActiveMQ等等,但是这些消息系统中所使用的消息模式如下:Peer-to-Peer(Queue)简称PTP队列模式,也可以理解为点到点。例如单发邮件,我发送一封邮件给XuWeiLiang,

Hadoop基础-12-Hive

源码见:https://github.com/hiszm/hadoop-trainHive概述http://hive.apache.org/Hive是什么TheApacheHive™datawarehousesoftwarefacilitatesreading,writing,andmanaginglargedatasetsresidingindistributedstorageusingSQL.Structurecanbeprojectedontodataalreadyinstorage.AcommandlinetoolandJDBCdriverareprovidedtoconnectuse

超级经典的SQL练习题(MySQL版本),你还怕SQL不过关吗?

微信搜索公众号【Cyouagain】,回复“SQL”下载无水印PDF版本,方便收藏1数据表1.1学生表Student(SId,Sname,Sage,Ssex)SId学生编号,Sname学生姓名,Sage出生年月,Ssex学生性别1.2课程表Course(CId,Cname,TId)CId课程编号,Cname课程名称,TId教师编号1.3教师表Teacher(TId,Tname)TId教师编号,Tname教师姓名1.4成绩表SC(SId,CId,score)SId学生编号,CId课程编号,score分数2sql语句2.1学生表SQLcreatetableStudent(SIdvarchar(10

MacOS下安装Apache Flink及测试WordCount

1.安装java1.8版本steven@wangyuxiangdeMacBook-Pro~java-versionjavaversion"1.8.0_211"Java(TM)SERuntimeEnvironment(build1.8.0_211-b12)JavaHotSpot(TM)64-BitServerVM(build25.211-b12,mixedmode)2.安装flink使用brew安装flink,命令如下:brewinstallapache-flink3.查看是否安装成功steven@wangyuxiangdeMacBook-Pro~flink-vVersion:1.13.2,

kafka分区扩容和修改三个副本数

Kafka是Apache旗下的一款分布式流媒体平台,Kafka是一种高吞吐量、持久性、分布式的发布订阅的消息队列系统。它最初由LinkedIn(领英)公司发布,使用Scala语言编写,与2010年12月份开源,成为Apache的顶级子项目。它主要用于处理消费者规模网站中的所有动作流数据。动作指(网页浏览、搜索和其它用户行动所产生的数据)。​消息系统分类我们知道常见的消息系统有Kafka、RabbitMQ、ActiveMQ等等,但是这些消息系统中所使用的消息模式如下:Peer-to-Peer(Queue)简称PTP队列模式,也可以理解为点到点。例如单发邮件,我发送一封邮件给XuWeiLiang,
12