我希望通过Flink、Scala-language和addSource- and readCsvFile-函数来读取csv文件。我还没有找到任何关于这方面的简单例子。我只发现：和这个对于我的目的来说太复杂了。定义: StreamExecutionEnvironment.addSource(sourceFunction)我应该只使用readCsvFile作为sourceFunction吗？
浏览 0提问于2018-02-16得票数 1
我正在Scala (2.11.8)和使用Flink框架(1.8.3)中工作。我正在尝试读取一个csv文件，该文件包含具有长、双和布尔数据类型的列中的培训数据，这些数据类型如下：
val env = ExecutionEnvironment.getExecutionEnvironmentval trainingDS = env.readCsvFile(.我的导入包括:导入org.apache.flink.api.<em
浏览 10提问于2020-08-12得票数 1
我在Flink 1.4.0上使用表API。我有一些Table对象要转换为DataSet类型的Row。该项目使用Maven构建，并在IntelliJ上导入。
浏览 1提问于2018-03-04得票数 0
回答已采纳
1回答
我正在使用apache开发一个基于scala的项目，到目前为止，我只在IntelliJ中运行我的项目，它没有出现任何问题。这在IntelliJ中有效，但在flink运行时不起作用。请注意，以下将在IntelliJ和flink运行时中同时工作：val parsed这是因为XML文件将包含指向其他文件的链接，相对地存储到setup.x
浏览 2提问于2018-12-12得票数 4
我试图在Flink中执行的代码的一部分： fieldDelimiter = "\t", includedFields= Array(1))不能将org.apache.flink
浏览 4提问于2015-07-08得票数 2
我决定使用scala控制台(或者更准确地说是)从csv文件中读取一些内容，并在本地打印它.只是为了调试结束实验。import $ivy.`org.apache.flink::flink-scala:1.10.0`
import org.apache.flink.api.scala._
浏览 3提问于2020-02-25得票数 2
回答已采纳
我需要读取一个CSV文件，其中有6列，类型分别为Integer、String、Integer、Integer。我想使用Apache的ExecutionEnvironment.readCsvFile方法，但是我总是收到输入错误和参数错误。String, Integer, Integer]("C:/Users/zoldham/IdeaProjects/flinkpoc/Data/gun-violence-data_01-2013_03-20
浏览 0提问于2018-06-20得票数 2
回答已采纳
我想通过以下代码在本地使用Flink-API读取CSV文件：List<Tuple2<String, Double>> csv= env.readCsvFile(csvPath)我尝试了一些不同大小的<em
浏览 22提问于2017-01-11得票数 0
我正试图用DataSet的将Iris ParserError NUMERIC_VALUE_ILLEGAL_CHARACTER读入flink，并不断地获取ParserError NUMERIC_VALUE_ILLEGAL_CHARACTERcsv (隐藏字符可见)如下我试图删除文件中项之间的空白，但没有成功。有多个无法读取的项，这是错误输出：
org.apache.flink.api.common.io.ParseException: Line could not be par
浏览 1提问于2018-02-05得票数 1
回答已采纳
2回答
我正在使用Apache Flink api中的readCsvFile(path)函数来读取CSV文件并将其存储在列表变量中。它是如何使用多线程工作的？例如，它是否基于某些统计数据拆分文件？或者它会逐行读取文件，然后将这些行发送到线程进行处理？4csvPath="data/weathe
浏览 1提问于2017-01-11得票数 3
=org.apache.flink \ -DarchetypeVersion[(Long, Long, Double)]("tmp-contactos.csv")
val als = ALS()at org
浏览 4提问于2017-01-26得票数 0
回答已采纳
我试图用Flink的KafkaSource运行一个简单的测试程序。我使用的方法如下：
import org.apache.flink.streaming.api.scala._
import org.apache.flink.
浏览 3提问于2015-07-15得票数 5
FlinkKafkaConsumer[String]("topic", new SimpleStringSchema(), properties)).print()scala)).print() [T](function:$10: org.apache.flink.api.common.typeinfo.TypeInf
浏览 0提问于2019-03-11得票数 1
回答已采纳
3回答
我正在尝试阅读卡夫卡主题的数据，在Flink流中。;import org.apache.flink.streaming.api.datastream.DataStream;import org.apache.flink
浏览 4提问于2017-01-09得票数 2
回答已采纳
我开始在Flink中训练一个多元线性回归算法。我正在跟踪可怕的和。我正在使用齐柏林飞艇来开发这个代码。如果我从CSV文件加载数据：val data = benv.readCsvFile[(Int, Double, Double, Double)]("/.../quake.csv")
val mapped = data.map {x => new org.apache.flink<
浏览 10提问于2017-05-31得票数 0
回答已采纳
我正在使用Datastream编写Scala脚本，以便在Apache中处理csv文件。我需要将格式修改为某些列，然后将它们转换为适当的类型。我目前的代码是：import org.apache.flink.api.common.functions/RIA_exportacion_datos_diarios_Huelva_20140206.csv</
浏览 2提问于2021-02-22得票数 1
回答已采纳
1回答
我试图在flink中做pagerank基本示例，只修改一点(仅在读取输入文件时，其他所有内容都相同)，因为任务不可序列化的及以下是输出错误的一部分
atorg.apache.flink.api.scala.ClosureCleaner$.ensureSerializable(ClosureCleaner.scala:179) at org.apache.flink.api.scala.ClosureCleaner$.clean(ClosureClea
浏览 2提问于2015-07-09得票数 4
1回答
我从CSV文件中读取了一个DataSet： getClass.getResource("/elecNormNew.arff但是当我尝试使用它时，例如，从一个测试中：a.discretizeorg.apache.flink.api.common.InvalidProgramE
浏览 3提问于2018-06-06得票数 1
回答已采纳
1回答
我正在尝试将Flink与Kafka集成，并读取Kafka producer的数据。FlinkKafkaConsumer<>("my-topic", new SimpleStringSchema(), properties); } 我得到以下错误， The method addSource(SourceFunction<OUT&g
浏览 23提问于2021-02-11得票数 0
我试图用flink readCsvFile读取一个简单的csv文件，但是ı得到一个错误。我用Apache Spark将同样的文件读了几百遍，没有任何问题。我的环境: Ubuntu、Intellij、Java8、Flink 1.9.2和Scala2.11.8。我的文件的一部分是这样的：
34,3,"Nike Women's Pro Core 3"&quo
浏览 52提问于2021-02-25得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
