Scala类型不匹配MapFunction中的Flink scala NotInferedR [Tuple2[Boolean，行]，InferedR]
Scala类型不匹配MapFunction中的Flink scala NotInferedR [Tuple2[Boolean，行]，InferedR]
在Flink中，MapFunction是一个接口，用于将输入流中的每个元素转换为另一个元素。在Scala中，当使用MapFunction时，有时会遇到类型不匹配的问题。
在这个问题中，错误提示为"Scala类型不匹配MapFunction中的Flink scala NotInferedR [Tuple2[Boolean，行]，InferedR]"，这意味着在MapFunction中的输入类型和输出类型不匹配。
解决这个问题的方法是确保MapFunction的输入类型和输出类型正确匹配。根据错误提示，输入类型应该是Tuple2[Boolean，行]，输出类型应该是InferedR。
首先，我们需要了解Tuple2[Boolean，行]和InferedR的含义和类型。
- Tuple2[Boolean，行]：Tuple2是Scala中的元组类型，表示一个包含两个元素的元组。在这里，Tuple2[Boolean，行]表示一个包含一个Boolean类型和一个行类型的元组。
- InferedR：这个词可能是一个拼写错误，应该是InferredR。InferredR可能是一个自定义的类型，根据上下文来推断。
根据上述信息，我们可以得出以下答案：
在Flink中，MapFunction用于将输入流中的每个元素转换为另一个元素。当在Scala中使用MapFunction时，有时会遇到类型不匹配的问题。在这个问题中，错误提示为"Scala类型不匹配MapFunction中的Flink scala NotInferedR [Tuple2[Boolean，行]，InferedR]"，这意味着在MapFunction中的输入类型和输出类型不匹配。
为了解决这个问题，我们需要确保MapFunction的输入类型和输出类型正确匹配。根据错误提示，输入类型应该是Tuple2[Boolean，行]，输出类型应该是InferredR。
- Tuple2[Boolean，行]表示一个包含一个Boolean类型和一个行类型的元组。这意味着MapFunction的输入应该是一个包含Boolean和行的元组。
- InferredR可能是一个自定义的类型，根据上下文来推断。根据具体的上下文，我们需要确定InferredR的具体含义和类型。
为了解决这个问题，我们可以尝试以下步骤：
- 检查MapFunction的定义，确保输入类型和输出类型与错误提示中的类型匹配。
- 检查输入流的数据类型，确保与MapFunction的输入类型匹配。
- 检查MapFunction的实现，确保正确处理输入元素并生成正确的输出元素。
如果以上步骤都正确无误，但仍然遇到类型不匹配的问题，可能需要进一步检查代码逻辑或寻求更多的上下文信息来解决问题。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云Flink产品介绍：https://cloud.tencent.com/product/flink
- 腾讯云云原生产品介绍：https://cloud.tencent.com/product/cloud-native
- 腾讯云数据库产品介绍：https://cloud.tencent.com/product/cdb
- 腾讯云服务器运维产品介绍：https://cloud.tencent.com/product/cvm
- 腾讯云音视频产品介绍：https://cloud.tencent.com/product/vod
- 腾讯云人工智能产品介绍：https://cloud.tencent.com/product/ai
- 腾讯云物联网产品介绍：https://cloud.tencent.com/product/iot
- 腾讯云移动开发产品介绍：https://cloud.tencent.com/product/mobile
- 腾讯云存储产品介绍：https://cloud.tencent.com/product/cos
- 腾讯云区块链产品介绍：https://cloud.tencent.com/product/baas
- 腾讯云元宇宙产品介绍：https://cloud.tencent.com/product/vr
相关·内容
我正在尝试在MapFunction中将Tuple2Boolean，行转换为flink中的行，但由于错误而失败。当我尝试运行时，我得到了另一个错误。 val data = kinesis.map(mapFunction)
tEnv.registerDataStream("transactions", data, "transactions where
浏览 33提问于2019-07-17得票数 0
回答已采纳
1回答
我正在使用Scala2.11.7和Flink 1.3.2处理数据。现在，我想将生成的org.apache.flink.api.scala.DataSet存储在neo4j图形数据库中。有一些Github项目是为了兼容性：
最有希望的
浏览 1提问于2017-08-31得票数 0
回答已采纳
JSONKeyValueDeserializationSchema(false), parameterTool.getProperties()));
2)以上问题可能与DataStream没有类型有关。>
<groupId>org.apache.flink</gro
浏览 2提问于2016-09-03得票数 3
回答已采纳
如果A是TypeTag，下面的条件也将尝试匹配Tuple2的内部类型，即字符串和Int。if (typeOf[A] == typeOf[Int])else if (typeOf[A] == typeOf[Tuple2[String, Int]]) ...
浏览 4提问于2015-09-03得票数 2
回答已采纳
我试图让一个基本的有效的证明工作，但我得到了一个类型不匹配的错误从这一行：我不知道为什么编译器认为它应该是NotInferedR；我找不到任何与此相关的文档这是我的</e
浏览 1提问于2019-03-21得票数 0
Flink 0.10.0最近刚刚发布。我需要从0.9.1迁移一些代码。但是得到了以下错误：
org.apache.flink.api.common.functions.InvalidTypesException:类型的TypeVariable 'K‘在’类fi.aalto.dmg.frame.FlinkPairWorkloadOperator这很可能是一个类型擦除问题。类型提取当前仅在返回类型中的所有变量都可以从输入
浏览 2提问于2015-11-19得票数 2
回答已采纳
1回答
我尝试根据添加具有事件时间属性的表源。element: Row): Long = element.getField(0).asInstanceOf[Timestamp].getTime }我在getDataStream方法中得到的这是我从每个卡夫卡记录中提取的TsCol。我想使用TsCol作为事件时间。但是，TsCol是一个10位的timestamp with string数据类型，所以我需要将它转换为13位Long数据类型。<t时间戳
浏览 33提问于2020-02-13得票数 0
readHadoopFile(new TeraInputFormat(), classOf[Text], classOf[Text], inputPath)但是在我的编辑器中出现了一个类型不匹配的错误：我该如何解决这个问题呢？这是完整<
浏览 10提问于2016-07-07得票数 2
回答已采纳
我试过这两个变量：在第二个例子中，我看到了Tuple2[Int,Int]，但是第一个例子显示了内存中的Tuple4[Integer,Integer,Double,Boolean]，即在Intellij/Eclipse中看到变量类型。因此Scala正在转储原语类型Int并将其存储为Integer。
如果我将Int添加到Array[AnyVal]中</
浏览 3提问于2014-09-11得票数 2
回答已采纳
然后，我想使用这个值来过滤主流，以便获得比我在窗口流中计算的stat值更大的值。 然而，我不知道如何合并或计算这两个流来实现我的目标。我的场景是，如果我将第一个stat值转换为广播变量，然后将其传递给主流，以便能够根据广播变量中的stat值过滤传入的值。 下面是我的代码。;import org.apa
浏览 10提问于2019-02-12得票数 0
回答已采纳
我是斯卡拉的新人。因此，我想在Java中处理Apache的DataSet。但是我在Scala代码中有一个DataSet，我想在Java的方法中传递它。例如:在Scala中：在SampleJavaClass.java中有一个类似于sendDs(DataSet<Vector> javaDs)的方法
我正在尝试这样做
浏览 5提问于2016-02-27得票数 4
回答已采纳
1回答
我只是尝试在Flink中使用Scala类型的类。我定义了以下类型的类接口： def timestamp(payload: T): Int现在，我想考虑一下这样的DataSet of LikeEvent在这里，我只是为了学习而尝试类型类模式，但在我看来，一种更面向对象的方法(基于子类型)看起来更简单。List 注意到 提出了类似的问题，但它考虑的</em
浏览 5提问于2020-04-13得票数 2
回答已采纳
1回答
我的问题非常类似于，只是这个问题对于Java来说，我需要在Scala中得到答案。我在IntelliJ中复制粘贴了所提供的解决方案，它将复制粘贴的片段自动转换为Scala，然后我对它进行了编辑，以适应我的代码。基本上，提供给keyBy (keySelector的getKey函数的返回值)的参数不匹配任何重载版本的keyBy函数所期望的</e
浏览 0提问于2018-12-29得票数 0
回答已采纳
1回答
我试着联合一些flink DataSets。它们都包含在一个赛格里。下面是产生问题的代码val线程“主”org.apache.flink.api.common.InvalidProgramException:中的异常不能合并不同类型的输入。Input1=scala</
浏览 3提问于2015-09-04得票数 2
回答已采纳
3回答
我要使用apache运行简单的worcount示例。使用$SPARK_HOME/jars中的本地jar文件，它正确运行，但使用maven依赖于它的错误： .mapToPair(word -> new Tuple2</e
浏览 19提问于2017-11-28得票数 0
回答已采纳
我正在使用库瑟拉上scala程序中的Scala代码：
类型不匹配；找到: scala.Boolean(false)必需:src.function al.Week 4。
浏览 1提问于2013-04-17得票数 6
回答已采纳
2回答
我想模式匹配一个函数，问题是类型擦除。请注意在下面的片段中，尽管发出了警告，但是匹配发生了，并且在这一点上出现了“错误”。scala> def f1 = ()=>truefl: () => Boolean = <function0>
我能想出的是一个case类来结束这个函数。我
浏览 5提问于2015-08-27得票数 4
回答已采纳
检查这个REPL会话，在Scala2.12.10下面：a: AnyVal= 1
<console>:11: error: type(a, b) = 4 match { case 3 =&g
浏览 6提问于2020-01-15得票数 3
回答已采纳
我有包含userId和point的元组列表。我想按键组合或减少这个列表。._2))
found : Double我做错了什么，有什么惯用的方法来实现这一点但是，Scala中有内置的方法吗？
浏览 0提问于2018-04-30得票数 1
回答已采纳
) => Unit l.foreach[Unit](foo)
U是foreach本身的模板参数。我的问题是为什么需要((String, String)) => Unit？额外的括号是从哪里来的？
浏览 4提问于2015-09-16得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
