【文件属性】:
文件名称:SparkStreaming
文件大小:19KB
文件格式:ZIP
更新时间:2021-04-05 05:58:30
Scala
火花流
来自文件的基本流
环境
运行HDFS(.src / main / resources / application.conf中的配置地址)默认为hdfs://localhost:9000/
HDFS temperatures文件夹中有数据文件( hdfs dfs -ls /temperatures )
有一个空的文件夹test ( hdfs dfs -ls /test )
运行应用
复制文件以查看结果hdfs dfs -cp /temperatures/*2020080* /test
在下次运行之前删除文件hdfs dfs -rm -r /test/*
【文件预览】:
SparkStreaming-master
----pom.xml(7KB)
----SparkStreaming.iml(80B)
----src()
--------test()
--------main()
----dependency-reduced-pom.xml(6KB)
----.gitignore(42B)
----README.md(505B)