没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
试读
2页
1. 训练要点 (1) 使用socket连接方式获取数据源。 (2) DStream的转换操作。 2. 需求说明 从一台服务器的8888端口上收到一个以换行符为分隔符的多行文本,要从中筛选出包含单词error的记录,并把它打印出来。 3. 实现步骤 (1) 启动Spark独立集群模式并启动spark-shell。 spark-shell –master local[2]
资源推荐
资源详情
资源评论
实训 过滤打印包含单次 的记录
训练要点
使用 连接方式获取数据源。
的转换操作。
需求说明
从一台服务器的 端口上收到一个以换行符为分隔符的多行文本要从中筛选出包含
单词 的记录并把它打印出来。
实现步骤
启动 独立集群模式并启动 。
在 交互式终端中编写代码。
!
!"#$%&
''(((% 替换成另外一台服务器 ! 的 )*
!"+%,(((%, !-.-/0123)4.0
! #&$5 " 6-, ,785,,% "9 %
&5:;4;<
在另外一台服务器中!查看是否安装 软件。
,如果正常执行,则有;报错则没有
= 若没有安装 软件则先安装 软件。
;5%>>=
? 在 ! 上启动监听。
> 启动 程序
里继续写:
#+@
然后在 的窗口里输入文本,只有输入“A才会被计数:
资源评论
- zlt_662023-01-07总算找到了想要的资源,搞定遇到的大问题,赞赞赞!
weixin_42152901
- 粉丝: 2
- 资源: 15
下载权益
C知道特权
VIP文章
课程特权
开通VIP
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功