Scala文件读取添加空格
在编程中，我们经常需要从文件中读取数据并处理。在Scala中，我们可以使用Java的IO库来读取文件。以下是一个简单的示例，说明如何读取文件并在Scala中添加空格。
首先，我们需要创建一个名为input.txt的文件，并在其中添加一些文本。例如：
Hello,World!
This,is,a,test.接下来，我们可以使用以下Scala代码来读取文件并在每个单词之间添加空格：
import java.io.{BufferedReader, FileReader}
object ScalaFileReading {
def main(args: Array[String]): Unit = {
val file = "input.txt"
val bufferedReader = new BufferedReader(new FileReader(file))
var line: String = null
while ({line = bufferedReader.readLine(); line != null}) {
val words = line.split(",")
val wordsWithSpaces = words.mkString(" ")
println(wordsWithSpaces)
}
bufferedReader.close()
}
}在这个示例中，我们首先导入了java.io.BufferedReader和java.io.FileReader类。然后，我们创建了一个名为file的变量，该变量包含要读取的文件的名称。接下来，我们创建了一个BufferedReader对象，并使用FileReader对象来读取文件。
在while循环中，我们使用readLine()方法读取文件中的每一行。然后，我们使用split()方法将每行文本分割成单词数组，并使用mkString()方法将这些单词连接成一个字符串，其中每个单词之间都有一个空格。最后，我们使用println()方法将结果打印到控制台。
运行此代码后，您将看到以下输出：
Hello, World!
This, is, a, test.这个示例演示了如何在Scala中读取文件并在单词之间添加空格。您可以根据需要修改此代码以适应您的特定需求。
相关·内容
我已经在我的Windows 7系统上安装了Scala。当我从Windows命令提示符运行"scala -version“时，我得到: Scala代码运行器版本2.11.4 --版权2002-2013年，LAMP/EPFL当我从Git Bash运行"scala -version”时，这是Swagger和其他框架所要求的，我得到: Error:无法找到或加载主类文件
有人知道如何从Git Bash运行scala可执行文件吗？
浏览 3提问于2014-12-01得票数 0
回答已采纳
1回答
我正在尝试使用spark读取vcf文件。 Spark 3.0 spark.read.format("com.databricks.vcf").load("vcfFilePath") 错误： java.lang.ClassNotFoundException: Failed to find data source: com.databricks.vcf. Please find packages at http://spark.apache.org/third-party-projects.html
at org.apache.spark.sql.execut
浏览 44提问于2021-01-03得票数 0
回答已采纳
2回答
我需要在火花读取文本文件到datasetT。该文件的格式不正确，因为它有一些空白字段，并且很难定义拆分字符串的参数。我一直在尝试将数据读取到RDD中，然后将其转换为case类类型，然而，并不是所有的字段都被正确解析，我得到了一个错误：
java.lang.NumberFormatException: empty String
at sun.misc.FloatingDecimal.readJavaFormatString(FloatingDecimal.java:1842)
at sun.misc.FloatingDecimal.parseDouble(Floa
浏览 11提问于2019-06-08得票数 3
1回答
我试图在Flink (Scala)中开发一个K均值模型，使用齐柏林飞艇( Zeppelin )。这是我的简单代码的一部分：
//Reading data
val mapped : DataSet[Vector] = data.map {x => DenseVector (x._1,x._2) }
//Create algorithm
val knn = KNN()
.setK(3)
.setBlocks(10)
.setDistanceMetric(SquaredEuclideanDistanceMetric())
.setUseQuadTree(false)
.s
浏览 2提问于2017-06-03得票数 0
回答已采纳
我试图在Scala中使用NetBeans 8.01，但它找不到"Scala平台“。我正在使用Windows8.1 x64。我跟踪，我也读过这个，但是不起作用。
我遵循路径tools-->Scala ，并且我有错误：指定的文件夹不包含Scala 。
我试图添加一个新的平台，但是netbeans没有找到Scala平台。最后，我尝试了scala的，这就是工作。
所以想知道netbeans中是否存在bug，还是我必须做一些其他的事情？有人能把我弄直吗？
谢谢
浏览 4提问于2014-11-04得票数 0
回答已采纳
下面是我的代码，将csv数据加载到dataframe中，在两列上应用差异，并使用withColumn.The将差异追加到新的列上。我试图找出两列的差异是一种双精度。请帮我找出以下例外情况：
import org.apache.log4j.{Level, Logger}
import org.apache.spark.sql.SparkSession
/**
* Created by Guest1 on 5/10/2017.
*/
object arith extends App {
Logger.getLogger("org").setLevel(Level.ER
浏览 3提问于2017-05-11得票数 3
回答已采纳
是Scala和Java的web框架。它的Scala接口使用.scala.html模板文件自动生成HTML。是否有自动格式化这些文件的工具？
更多的上下文:在Eclipse中，使用Scala和Play插件，格式化程序可以自动格式化Scala源文件和路由文件，但是它对.scala.html文件没有任何作用。
浏览 1提问于2013-09-24得票数 3
回答已采纳
在中，我们有很好的方法，比如readInt、readChar等。
为什么我们不把它们放在io.Source上呢？如果您认为我们应该使用Java的IO功能，那么为什么要使用Console.read*方法呢？
对于最小的文件解析器，还有其他scala式的方法吗？
浏览 0提问于2011-05-20得票数 3
回答已采纳
我正在尝试使用Spark (在EMR上是2.1 )处理~500M的gz文件，我没有办法改变格式或将它们分割成更小的尺寸。
其中一个执行程序失败，出现以下问题：
java.lang.IllegalArgumentException: Size exceeds Integer.MAX_VALUE
at sun.nio.ch.FileChannelImpl.map(FileChannelImpl.java:869)
at org.apache.spark.storage.DiskStore$$anonfun$getBytes$2.apply(DiskStore.scala:103)
浏览 10提问于2017-05-21得票数 2
我可以将变量作为多值参数进行传递：
scala> <b/>
res26: scala.xml.Elem = <b></b>
scala> Elem(null,"a",Null,TopScope,res26)
res27: scala.xml.Elem = <a><b></b></a>
但我不能将XML文本作为多值参数传递：
scala> Elem(null,"a",Null,TopScope,<b/>)
<console>:12: er
浏览 0提问于2011-09-26得票数 6
回答已采纳
在windows 7上的命令行工具中输入activator会给出以下错误消息。
C:\Program Files\activator-dist-1.3.6>activator ui
Found previous process id: 4164
Local repository: activator-launcher-local @ file:////C:/Program%20Files/activat
or-dist-1.3.6/repository
Play server process ID is 4068
java.io.FileNotFoundException: C:\Pro
浏览 3提问于2015-09-26得票数 1
回答已采纳
嗨，现在从spark Scala数据帧中，我得到了一个以逗号分隔值输出的文本文件，它以零件文件的形式出现在文件夹中。我希望它的宽度是固定的，如第一列应该是10字节，接下来应该是5字节，第三列应该是8字节的..so on，并作为一个单一的输出文件(output.txt)而不是部分文件 myfile.rdd
.map(r => { val x = r.toString; x.substring(1, x.length-1)})
.saveAsTextFile("C:/Users/rukku/Desktop/op") 示例输出(作为文件夹中的part0001、p
浏览 23提问于2020-10-08得票数 0
1回答
我有一个格式错误的UTF-8字符串，它应该写为"Michèle Huà“，但输出为”Michç¨le Huç“
根据该表，Windows-1252和UTF-8 之间存在问题
如何进行转换？
scala> scala.io.Source.fromBytes("Michèle HuÃ".getBytes(), "ISO-8859-1").mkString
res25: String = Michèle HuÃ
scala> scala.io.Source.fromBytes("Michèle HuÃ".getBytes(
浏览 2提问于2016-09-22得票数 1
回答已采纳
1回答
我正在尝试从本地读取一个文本文件到pyspark。使用
df = spark.read.text("file:///<path>")
这将成功地运行并发出一个数据文件。
df. printSchema()
产出：
root
|-- value: string (nullable = true)
但是，当尝试访问df时，它会给出以下错误。
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
File "/usr/hdp/
浏览 1提问于2019-10-21得票数 0
我刚刚开始学习Scala，它来自Python。我试图在Scala中执行一个基本的文件处理任务。任务是使用regex从数据文件中删除像"[ ... ]"这样的子字符串。脚本成功地处理前几个文件，然后抛出一个java.lang.OutOfMemoryError: Java heap space错误。发生错误的数据文件大约为70 my，我有16 at的RAM可供使用。(前6个文件的文件大小为<100 as，第一个文件为例外: 5.5MB)。
我的问题是：是什么导致了 OutOfMemoryError，，以及我如何改变我的方法来防止它发生？--我不明白为什么会发生这种情况。我几乎
浏览 5提问于2016-11-03得票数 2
回答已采纳
我有一个包含文件列表的文本文件。目前，我正在按顺序遍历我的文件列表
我的文件列表如下所示：
D:\Users\bramasam\Documents\sampleFile1.txt
D:\Users\Documents\sampleFile2.txt
并为每个文件执行以下代码，
val df = spark.read
.format("org.apache.spark.csv")
.option("header", false)
.option("inferSchema", false)
.option("delim
浏览 0提问于2018-05-24得票数 0
1回答
你好，当我试图在支持向量机中运行和终端中的./run-example org.apache.spark.mllib.classification.SVM local <path-to-dir>/sample_svm_data.txt 2 2.0 2时，我会收到以下错误消息。
Exception in thread "main" java.lang.NumberFormatException: For input string: "1 0 2.52078447201548 0 0 0 2.004684436494304 2.000347299268466
浏览 0提问于2013-12-13得票数 0
回答已采纳
2回答
我对emacs很陌生，我想在Windows中使用。我试过了，但不起作用。它似乎无法工作，因为有一个名为"\ensime\bin\server.sh“的*nix格式文件。非常感谢有人给我一些提示。
编辑:我遵从冯克的建议，但效果并不完美。我肯定我漏掉了什么。
我在dir D:\Dev\emacs-23.1，scala-模式在D：\Dev\emacs-23.1\scala-模式中安装了emacs23.1，在D:\Dev\emacs-23.1\ensime中安装了ensime。
以下是我的.emacs文件内容：
;;禁用工具栏
(tool-bar-mode nil)
;;显示行号
(gl
浏览 1提问于2010-04-21得票数 3
回答已采纳
我要去拿
在classpath: com上没有这样的文件或类。
当使用以下命令执行scala时。
scala -classpath kafka-scala-1.0-SNAPSHOT.jar com.< com.< >.< abc >.KafkaAggregateConsumerApp
我正在使用Scala2.11.12
浏览 1提问于2019-05-19得票数 0
我在jdk1.8上使用了spark和Scala。我是scala的新手。
我正在读取一个类似于:的文本文件(pat1.txt)
现在我从scala代码中读取该文件为:
val sqlContext = SparkSession.builder().getOrCreate()
sqlContext.read
.format(externalEntity.getExtractfileType)
.option("compression", externalEntity.getCompressionCodec)
.option("heade
浏览 0提问于2019-01-29得票数 0
回答已采纳
我正在尝试运行一个负载测试，它使用Gatling工具中的feed方法。当前，当我们使用一个大小在3.5GB (有600000条记录)左右的文件时，Gatling会失败，例外情况如下:模拟LoadTestSimulation启动了.
线程"main“中的异常:在java.lang.AbstractStringBuilder.expandCapacity(AbstractStringBuilder.java:130) at java.lang.AbstractStringBuilder.ensureCapacityInternal(AbstractStringBuilder.java:11
浏览 9提问于2016-05-05得票数 0
我在电子病历笔记本上执行了以下PySpark代码：
s3_path = "s3://bucket/key/file.csv"
df = spark.read.csv(s3_path, header=True)
df.repartition(1).write.mode("overwrite").csv(s3_path)
我得到了以下错误：
An error occurred while calling o166.csv.
: org.apache.spark.SparkException: Job aborted.
at org.apache.spark
浏览 12提问于2022-05-09得票数 0
回答已采纳
我知道我可以像这样读取Scala中的本地文件：
import scala.io.Source
val filename = "laba01/ml-100k/u.data"
for(line <- Source.fromFile(filename).getLines){
println(line)
}
这个代码字很好，并打印出文本文件中的行。我用Apache Toree在JupyterHub中运行它。
我知道我可以在这个服务器上读取HDFS，因为当我在另一个单元格中运行下一段代码时：
import sys.process._
"hdfs dfs -ls
浏览 22提问于2020-05-30得票数 1
1回答
我现在正在使用spark为shapefile编写一个解析器。我首先使用NewAPIHadoopFile从原始.shp文件中逐个提取二进制记录。问题是，当程序从本地磁盘获取文件时，它可以正常工作。但是当从hdfs读取文件时，我从DataInputStream获得的字节流不再与原始文件集成。例外情况如下。
java.lang.NegativeArraySizeException
at ShapeFileParse.ShapeParseUtil.parseRecordPrimitiveContent(ShapeParseUtil.java:53)
at spatial.ShapeFi
浏览 3提问于2017-05-26得票数 0
2回答
数据库上的
、、
我正在尝试将dataset从我的Databricks文件系统(DBFS)导入到运行在Databricks集群上的R；下面我将面临这个问题。
> sparkDF <- read.df(source = "parquet", path = "/tmp/lrs.parquet", header="true", inferSchema = "true")`
错误:加载错误:在com.databricks.sql.acl.ReflectionBackedAclClient$$anonfun$com$databricks$sql$
浏览 2提问于2020-10-13得票数 0
我试图转换“合成控制图时间序列数据集”在Uci机器学习。
下一个是数据集的外观。
28.7812 34.4632 31.3381 31.2834 28.9207 33.7596 25.3969 27.7849 35.2479 27.1159 32.8717 29.2171 36.0253 32.337 34.5249 32.8717 34.1173 26.5235 27.6623 26.3693 25.7744 29.27 30.7326 29.5054 33.0292 25.04 28.9167 24.3437 26.1203 34.9424 25.0293 26.6311 35.
浏览 1提问于2016-06-07得票数 2
回答已采纳
1回答
当我从s3桶将数据加载到pyspark中时，进行一些操作(连接、联合)，然后尝试覆盖前面读取的相同路径(' data /csv/')。我得到了一个错误：
py4j.protocol.Py4JJavaError: An error occurred while calling o4635.save.
: org.apache.spark.SparkException: Job aborted.
at org.apache.spark.sql.execution.datasources.FileFormatWriter$.write(FileFormatWriter.sca
浏览 0提问于2019-06-12得票数 0
我在这里看到了几个帖子和谷歌搜索的org.apache.hadoop.mapred.InvalidInputException，但大多数涉及HDFS文件或陷阱错误。我的问题是，虽然我可以从spark读取CSV文件，但是从编译的JAR中运行它会不断地返回一个org.apache.hadoop.mapred.InvalidInputException错误。
罐子的粗糙过程：
阅读S3中的JSON文档(此工作)
从S3中的拼花文件中读取(这也成功)
将对#1和#2的查询的结果写入S3中的拼花文件(也成功)
从相同的存储桶#3中读取配置csv文件。(这失败了)
下面是我在代码中
浏览 4提问于2017-02-03得票数 0
当我从一个文件夹中读取多个多行JSON文件时，我收到一条Py4JJavaError消息。在从这些文件中推断模式时，Spark似乎在苦苦挣扎。
我试图减少要读取的文件数量，因为它必须从数千个JSON文件中推断，但似乎不起作用。
def get_user_details_schema(url):
df = sqlContext.read.json(url, multiLine=True)
return df.schema
这是我得到的信息：
Py4JJavaError Traceback (most recent call last
浏览 0提问于2019-10-17得票数 0
我在努力学习火花放电。我已经在我的windows 10机器上安装了python 3.6.5。
我正在使用火花版本2.3。
我已经从git下载了压缩文件。我随身带着一个WordCount.py文件。
当我试图在cmd中运行命令时：
spark-submit WordCount.py
我得到了下面的错误。
我正在复制WordCount.py的目录中执行此命令。
18/10/14 15:24:41 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java cl
浏览 0提问于2018-10-14得票数 0
回答已采纳
我有拼图文件，假设文件名为abc/A。parquet和一些记录根据某些条件被过滤出来，并创建DF，我正在尝试用saveMode overwrite选项用结果过滤的DF覆盖文件，但抛出了以下异常：
用于覆盖filterDF.coalesce(1).write.mode("overwrite").parquet("file:/home/psub2/cls_parquet2/file:/home/psub7/abc/A.parquet")的命令
写入行时失败。在org.apache.spark.sql.execution.datasources.FileFormatW
浏览 16提问于2019-11-26得票数 0
回答已采纳
因此，我只是花了一些时间来思考为什么我在scala中的String.split调用失败了--我试图在一个选项卡上拆分。
问题不在于我在做什么，而是因为intelliJ将制表符更改为空格。很公平，但我能告诉intelliJ不要对某些文件这样做-比如我可能用于测试/学习的随机文本文件？
浏览 4提问于2013-07-17得票数 1
回答已采纳
我正在尝试运行Typesafe激活器的UI。当我运行它时，它的表现就好像它成功地下载了所有东西，但是抛出了一个java.lang.IlleagalArgumentException。我已经多次尝试运行它，但是我一直收到这样的错误：
Checking for a newer version of Activator (current version 1.2.10)...
... our current version 1.2.10 looks like the latest.
Found previous process id: 2816
FOUND REPO = activator-lo
浏览 3提问于2014-10-09得票数 4
回答已采纳
1回答
我有一段可以在本地运行的scala代码
val test = "resources/test.csv"
val trainInput = spark.read
.option("header", "true")
.option("inferSchema", "true")
.format("com.databricks.spark.csv")
.load(train)
.cache
然而，当我尝试在azure上运行它时，通过提交作业并调整以下行来触发：
val test = &
浏览 12提问于2018-02-26得票数 1
回答已采纳
使用Scala 2.10.2？
我是一名Java工程师，从昨天开始学习Scala，但现在我陷入了困境，这段简单的代码对我不起作用，但是当我使用java编写它时，它工作得很好：
package lesson4
import scala.io.Source
import scala.reflect.io.File
object Test {
def main(args: Array[String]): Unit = {
var filePath = Source.getClass().getResource("/less
浏览 0提问于2013-10-29得票数 2
回答已采纳
我有多项目Build.scala。有没有办法将sbt-assembly生成的所有jars文件都放在根目标目录中？
例如，考虑以下内容：
lazy val root = Project("root", file(".")).aggregate(hello)
lazy val hello = Project(id = "hello", base = file("hello"))
.settings(assemblySettings: _*)
现在，如果我运行sbt assembly，hello.jar将被放在hello/tar
浏览 0提问于2015-02-15得票数 11
1回答
我在我的项目中使用了火花-SQL2.3.1v，带有java8的kafka。使用
--driver-memory 4g \
--driver-cores 2 \
--num-executors 120 \
--executor-cores 1 \
--executor-memory 768m \
在消费者端，我试图使用下面的代码用hdfs编写文件
dataSet.writeStream()
.format("parquet")
浏览 3提问于2020-02-12得票数 0
回答已采纳
我能够运行简单的Hello程序通过火花在独立的机器上。但是，当我使用Spark上下文运行一个单词计数程序，并使用吡火花运行它时，我会得到以下错误。错误SparkContext:初始化SparkContext时出错。file:/Users/tanyagupta/Documents/Internship/Zyudly%20Labs/Tanya-Programs/word_count.py :添加的文件java.io.FileNotFoundException不存在。我是在Mac上安装的，我通过brew安装apache-spark安装了Spark。现在有什么想法吗？
使用Spark的默认log4j配
浏览 4提问于2016-07-20得票数 0
回答已采纳
我正在尝试从hdfs中读取现有的拼板文件，但我的POC使用spark，但遇到OOM错误。
对于给定的分区日期，我需要读取所有分段文件。分区如下: date/file_dir_id
日期文件夹下有1200个子文件夹。
所有这些文件夹下共有234769个.parquet文件(数量不多)。
所有.parquet文件的总大小为10g。
拼花文件夹结构
日期
File_dir_1
File_1.parquet
File_2.parquet
- File\_dir\_2
- File\_3.parquet
- File\_3
浏览 0提问于2018-05-15得票数 6
在编写build.sbt脚本之后，我正在努力导入所需的jar文件，并将它们部署到scala项目中。解析器拒绝从声纳和maveen 2解析器下载任何scala库。我的scala版本是2.13.0，在编译sbt构建之后，sbt是1.6.1，程序会产生以下错误。
download error: Caught java.io.IOException (Server returned HTTP
response code: 400 for URL:
https://repo1.maven.org/maven2/org/scala-lang/scala-library/2.13.0
/sc
浏览 7提问于2022-02-01得票数 1
斯卡拉的超级粉丝，但SBT总是让我在没有牙齿的地方感到牙痛。通常我能应付，但这件事让我有点困惑。有人能帮我做以下几件事吗？
TL/DR
当重新导入我的sbt-项目时，我遇到了以下错误。
[error] (update) java.nio.file.InvalidPathException: Illegal char < > at index 90: C:\Users\\-username-\AppData\Local\Coursier\cache\v1\https\repo1.maven.org\maven2\io\cucumbe r\cucumber-jun
浏览 13提问于2020-06-04得票数 1
回答已采纳
1回答
在spark 1.6.2中，我可以通过执行一个非常简单的操作来读取本地拼图文件：
SQLContext sqlContext = new SQLContext(new SparkContext("local[*]", "Java Spark SQL Example"));
DataFrame parquet = sqlContext.read().parquet("file:///C:/files/myfile.csv.parquet");
parquet.show(20);
我正在尝试升级到Spark 2.0.0，并通过运行以下命令来实现同样的
浏览 4提问于2016-08-09得票数 3
回答已采纳
我有一个火花工作，不断上传Parquet文件到S3 (与分区)。
这些文件都有相同的拼花模式。
其中一种字段类型最近已被更改(从String改为long)，因此某些分区的拼花模式是混合的。
来自这两种类型的混合数据的地方现在失败了，无法读取某些内容。
虽然我似乎可以执行：sqlContext.read.load(path)
尝试在DataFrame上应用任何提取操作(例如，collect)时，该操作在ParquetDecodingException中失败
我打算迁移数据并将其重新格式化为，但无法将混合内容读取到DataFrame中。
如何使用Apache将混合分区加载到DataFrames或任
浏览 0提问于2018-06-21得票数 0
回答已采纳
我有一些regex值，需要用作新正则表达式的变量。
我想写这样的东西：
val lowers: Regex = "[a-z]”.r
val uppers: Regex = "[A-Z]”.r
val letters: Regex = “(lowers | uppers)*”.r
但我不知道正确的语法。
如果可能的话，如何在Scala中完成呢？
编辑
正如注释中所建议的那样，当regex变量被添加到regex之外时，这个也与这个变量相关，而正则表达式似乎并不能解决这里的问题。
浏览 2提问于2021-05-07得票数 2
回答已采纳
我有一个用scala编写的简单的mvn项目。我想访问一个文本文件并读取它的内容。代码运行正常，但唯一的问题是我在读取文本文件时给出了绝对路径。以下是我的项目的目录结构。
如何使用相对路径读取该文件？(我是否必须将movies.txt文件移到资源目录中，如果是这样，我如何读取该文件？)
任何有见地的人都会非常感激。谢谢
myproject
|-src
| |-resources
| |-scala
| |-movies.simulator
| |-Boot
| |-Simulate
| |-myobject.sc
浏览 1提问于2015-07-16得票数 5
回答已采纳
我正在尝试将移植到scala 2.10，并使用maven使用antlr3-maven-plugin而不是sbt来构建它。到目前为止，我得到了，代码编译成功。但是在运行时，当我尝试执行像new Mustach("hello {{world}}!")这样简单的东西时，我得到了一个java.lang.NoClassDefFoundError。
奇怪的是，一开始，我得到了Node类的NoClassDefFoundError。我不明白为什么java类不在编译后的jar中，但我渴望测试它是否能工作。所以我只用javac编译了两个java类，并调用了scala REPL，如下所示：
$sca
浏览 0提问于2013-06-14得票数 1
我意识到与这个相关的问题，但我就是不能让我的代码工作。
我正在独立模式下运行一个Spark流应用程序，主节点在我的Windows主机上，一个工作人员在Ubuntu虚拟机中。问题是:当我运行submit时，显示的是：
>spark-submit --master spark://192.168.56.1:7077 --class spark.example.Main C:/Users/Manuel Mourato/xxx/target/ParkMonitor-1.0-SNAPSHOT.jar
Warning: Skip remote jar C:/Users/Manuel.
java.
浏览 3提问于2016-10-05得票数 0
我正在尝试编译和运行一个简单的kafka代码，它是Aapche.When compiling中的一个示例。我得到了以下异常，即使在为scala添加了所有lib文件之后(我猜)。
Exception in thread "main" java.lang.NullPointerException
at scala.Predef$.Integer2int(Predef.scala:303)
at kafka.client.ClientUtils$$anonfun$parseBrokerList$1.apply(ClientUtils.scala:103)
at kafka.clien
浏览 3提问于2015-04-30得票数 1
我使用Scala解析器组合子已经有一段时间了，我学习了一些方法来让它表现良好，并使用内置函数做我想做的大多数事情。
但是如何制作嵌入式语言(如php或ruby的erb)呢？它要求在实际代码的嵌入之外不要忽略空格。
我设法创建了一个简单的解析器，它将所有文本匹配到给定的正则表达式匹配，但我正在寻找一种更好、更漂亮的方式来实现这一点。可能有一些已经定义好的函数可以完成所需的工作。
测试语言解析文本的方式如下：
now: [[ millis; ]]
and now: [[; millis; ]]
并由以下代码生成：
package test
import scala.util.parsing.co
浏览 2提问于2010-07-28得票数 2
回答已采纳
我在读csv。人是一个案例类
Case class Person(name, address)
def getData(path:String,existingName) : List[Person] = {
Source.fromFile(“my_file_path”).getLines.drop(1).map(l => {
val data = l.split("|", -1).map(_.trim).toList
val personName = data(0)
if(personName.
浏览 1提问于2020-03-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
