网创优客建站品牌官网
为成都网站建设公司企业提供高品质网站建设
热线:028-86922220
成都专业网站建设公司

定制建站费用3500元

符合中小企业对网站设计、功能常规化式的企业展示型网站建设

成都品牌网站建设

品牌网站建设费用6000元

本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...

成都商城网站建设

商城网站建设费用8000元

商城网站建设因基本功能的需求不同费用上面也有很大的差别...

成都微信网站建设

手机微信网站建站3000元

手机微信网站开发、微信官网、微信商城网站...

建站知识

当前位置:首页 > 建站知识

Scala的文件读取、写入、控制台操作的方法示例

本篇内容介绍了“Scala的文件读取、写入、控制台操作的方法示例”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

创新互联建站专业为企业提供宾川网站建设、宾川做网站、宾川网站设计、宾川网站制作等企业网站建设、网页设计与制作、宾川企业网站模板建站服务,十载宾川做网站经验,不只是建网站,更提供有价值的思路和整体网络服务。

Scala文件读取

E盘根目录下scalaIO.txt文件内容如下:

文件读取示例代码:

//文件读取 val file=Source.fromFile("E:\\scalaIO.txt") for(line <- file.getLines) {  println(line) } file.close

说明1:file=Source.fromFile(“E:\scalaIO.txt”),其中Source中的fromFile()方法源自 import scala.io.Source源码包,源码如下图:

file.getLines(),返回的是一个迭代器-Iterator;源码如下:(scala.io)

Scala 网络资源读取

//网络资源读取 val webFile=Source.fromURL("http://spark.apache.org") webFile.foreach(print) webFile.close()

fromURL()方法源码如下:

/** same as fromURL(new URL(s)) */ def fromURL(s: String)(implicit codec: Codec): BufferedSource = fromURL(new URL(s))(codec)

读取的网络资源资源内容如下:

 Apache Spark™ - Lightning-Fast Cluster Computing

      Lightning-fast cluster computing  

 

Latest News
   

Archive

 Built-in Libraries:  

   Third-Party Packages

Apache Spark™ is a fast and general engine for large-scale data processing.

Speed

 Run programs up to 100x faster than  Hadoop MapReduce in memory, or 10x faster on disk.

 Spark has an advanced DAG execution engine that supports cyclic data flow and  in-memory computing.

   

Logistic regression in Hadoop and Spark

Ease of Use

 Write applications quickly in Java, Scala, Python, R.

 Spark offers over 80 high-level operators that make it easy to build parallel apps.  And you can use it interactively  from the Scala, Python and R shells.

 

 text_file = spark.textFile("hdfs://...")
 
 text_file.flatMap(lambdaline:line.split())
 .map(lambda word: (word, 1))
 .reduceByKey(lambda a, b: a+b)  

 

Word count in Spark's Python API

Generality

 Combine SQL, streaming, and complex analytics.

 Spark powers a stack of libraries including  SQL and DataFrames, MLlib for machine learning,  GraphX, and Spark Streaming.  You can combine these libraries seamlessly in the same application.

 Spark SQL  Spark Streaming  MLlib (machine learning)  GraphX

Runs Everywhere

 Spark runs on Hadoop, Mesos, standalone, or in the cloud. It can access perse data sources including HDFS, Cassandra, HBase, and S3.

 You can run Spark using its standalone cluster mode, on EC2, on Hadoop YARN, or on Apache Mesos.  Access data in HDFS, Cassandra, HBase,  Hive, Tachyon, and any Hadoop data source.

Community

 Spark is used at a wide range of organizations to process large datasets.  You can find example use cases at the Spark Summit  conference, or on the  Powered By  page.

 There are many ways to reach the community:

Contributors

 Apache Spark is built by a wide set of developers from over 200 companies.  Since 2009, more than 800 developers have contributed to Spark!

 The project's  committers  come from 16 organizations.

 If you'd like to participate in Spark, or contribute to the libraries on top of it, learn  how to  contribute.

Getting Started

Learning Spark is easy whether you come from a Java or Python background:

Download Spark

Process finished with exit code 0

//网络资源读取 val webFile=Source.fromURL("http://www.baidu.com/") webFile.foreach(print) webFile.close()

读取中文资源站点,出现编码混乱问题如下:(解决办法自行解决,本文不是重点)

Exception in thread "main" java.nio.charset.MalformedInputException: Input length = 1

“Scala的文件读取、写入、控制台操作的方法示例”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!


本文名称:Scala的文件读取、写入、控制台操作的方法示例
分享网址:http://bjjierui.cn/article/ggccih.html