Scala Language › Scala - User

inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]

‹ Previous Topic Next Topic ›
 
classic Classic list List threaded Threaded
♦
♦
 6 messages Options
sjhanderson
Reply | Threaded
Open this post in threaded view
♦
♦
|

inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]

sjhanderson
I am translating kafka's streams word count example to scala version. 

https://github.com/apache/kafka/blob/trunk/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java

But compiler complains inferred type arguments do not conform to map function's type parameter bounds, and type mismatch.

inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]
[error]         ).map(
[error]           ^
type mismatch;
[error]  found   : org.apache.kafka.streams.kstream.KeyValueMapper[String,String,org.apache.kafka.streams.KeyValue[String,String]]
[error]  required: org.apache.kafka.streams.kstream.KeyValueMapper[_ >: String, _ >: String, _ <: org.apache.kafka.streams.KeyValue[_ <: KR, _ <: VR]]
[error]           new KeyValueMapper[String, String, KeyValue[String, String]] {
[error]           ^


The code snippet looks like

        val counts = source.flatMapValues(
          new ValueMapper[String, java.lang.Iterable[String]] {
            override def apply(value: String): java.lang.Iterable[String] = {
              val ary = value.toLowerCase(Locale.getDefault()).split(" ")
              Arrays.asList(ary).asInstanceOf[java.lang.Iterable[String]]
            }
          }
        ).map(
          new KeyValueMapper[String, String, KeyValue[String, String]] {
            override def apply(key: String, value: String): KeyValue[String, String] = new KeyValue(value, value)            
          }
        ).groupByKey().count("Counts");

How can I fix this compilation error?

Thanks. 

--
You received this message because you are subscribed to the Google Groups "scala-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
For more options, visit https://groups.google.com/d/optout.
oss.mlists
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]

oss.mlists
Arrays.asList(ary).asInstanceOf[java.lang.Iterable[String]]

This is wrong. asList takes varags I think. You have to spread ary. See, asInstanceOf can kill you. But it doesn't have to be the only problem. It might need more explicit type parameters because of call site variance.

This should help a bit:

override def apply(value: String): java.lang.Iterable[String] = {
  val ary = value.toLowerCase(Locale.getDefault()).split(" ")
  Arrays.asList(ary: _*)
}

Petr




On Monday, March 6, 2017 at 4:53:00 PM UTC+1, [hidden email] wrote:
I am translating kafka's streams word count example to scala version. 

<a href="https://github.com/apache/kafka/blob/trunk/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java" target="_blank" rel="nofollow" onmousedown="this.href=&#39;https://www.google.com/url?q\x3dhttps%3A%2F%2Fgithub.com%2Fapache%2Fkafka%2Fblob%2Ftrunk%2Fstreams%2Fexamples%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fkafka%2Fstreams%2Fexamples%2Fwordcount%2FWordCountDemo.java\x26sa\x3dD\x26sntz\x3d1\x26usg\x3dAFQjCNEjgcxamAXSxpbUBzokh5JT4mo5Yg&#39;;return true;" onclick="this.href=&#39;https://www.google.com/url?q\x3dhttps%3A%2F%2Fgithub.com%2Fapache%2Fkafka%2Fblob%2Ftrunk%2Fstreams%2Fexamples%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fkafka%2Fstreams%2Fexamples%2Fwordcount%2FWordCountDemo.java\x26sa\x3dD\x26sntz\x3d1\x26usg\x3dAFQjCNEjgcxamAXSxpbUBzokh5JT4mo5Yg&#39;;return true;">https://github.com/apache/kafka/blob/trunk/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java

But compiler complains inferred type arguments do not conform to map function's type parameter bounds, and type mismatch.

inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]
[error]         ).map(
[error]           ^
type mismatch;
[error]  found   : org.apache.kafka.streams.kstream.KeyValueMapper[String,String,org.apache.kafka.streams.KeyValue[String,String]]
[error]  required: org.apache.kafka.streams.kstream.KeyValueMapper[_ >: String, _ >: String, _ <: org.apache.kafka.streams.KeyValue[_ <: KR, _ <: VR]]
[error]           new KeyValueMapper[String, String, KeyValue[String, String]] {
[error]           ^


The code snippet looks like

        val counts = source.flatMapValues(
          new ValueMapper[String, java.lang.Iterable[String]] {
            override def apply(value: String): java.lang.Iterable[String] = {
              val ary = value.toLowerCase(Locale.getDefault()).split(" ")
              Arrays.asList(ary).asInstanceOf[java.lang.Iterable[String]]
            }
          }
        ).map(
          new KeyValueMapper[String, String, KeyValue[String, String]] {
            override def apply(key: String, value: String): KeyValue[String, String] = new KeyValue(value, value)            
          }
        ).groupByKey().count("Counts");

How can I fix this compilation error?

Thanks. 

--
You received this message because you are subscribed to the Google Groups "scala-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
For more options, visit https://groups.google.com/d/optout.
oss.mlists
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]

oss.mlists
Without spread it pass your Array[String] as the first arg returning Iterable[Array[String]]. Not a good idea to do asInstanceOf.

Petr

On Monday, March 6, 2017 at 6:29:05 PM UTC+1, [hidden email] wrote:
Arrays.asList(ary).asInstanceOf[java.lang.Iterable[String]]

This is wrong. asList takes varags I think. You have to spread ary. See, asInstanceOf can kill you. But it doesn't have to be the only problem. It might need more explicit type parameters because of call site variance.

This should help a bit:

override def apply(value: String): java.lang.Iterable[String] = {
  val ary = value.toLowerCase(Locale.getDefault()).split(" ")
  Arrays.asList(ary: _*)
}

Petr




On Monday, March 6, 2017 at 4:53:00 PM UTC+1, [hidden email] wrote:
I am translating kafka's streams word count example to scala version. 

<a href="https://github.com/apache/kafka/blob/trunk/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java" rel="nofollow" target="_blank" onmousedown="this.href=&#39;https://www.google.com/url?q\x3dhttps%3A%2F%2Fgithub.com%2Fapache%2Fkafka%2Fblob%2Ftrunk%2Fstreams%2Fexamples%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fkafka%2Fstreams%2Fexamples%2Fwordcount%2FWordCountDemo.java\x26sa\x3dD\x26sntz\x3d1\x26usg\x3dAFQjCNEjgcxamAXSxpbUBzokh5JT4mo5Yg&#39;;return true;" onclick="this.href=&#39;https://www.google.com/url?q\x3dhttps%3A%2F%2Fgithub.com%2Fapache%2Fkafka%2Fblob%2Ftrunk%2Fstreams%2Fexamples%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fkafka%2Fstreams%2Fexamples%2Fwordcount%2FWordCountDemo.java\x26sa\x3dD\x26sntz\x3d1\x26usg\x3dAFQjCNEjgcxamAXSxpbUBzokh5JT4mo5Yg&#39;;return true;">https://github.com/apache/kafka/blob/trunk/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java

But compiler complains inferred type arguments do not conform to map function's type parameter bounds, and type mismatch.

inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]
[error]         ).map(
[error]           ^
type mismatch;
[error]  found   : org.apache.kafka.streams.kstream.KeyValueMapper[String,String,org.apache.kafka.streams.KeyValue[String,String]]
[error]  required: org.apache.kafka.streams.kstream.KeyValueMapper[_ >: String, _ >: String, _ <: org.apache.kafka.streams.KeyValue[_ <: KR, _ <: VR]]
[error]           new KeyValueMapper[String, String, KeyValue[String, String]] {
[error]           ^


The code snippet looks like

        val counts = source.flatMapValues(
          new ValueMapper[String, java.lang.Iterable[String]] {
            override def apply(value: String): java.lang.Iterable[String] = {
              val ary = value.toLowerCase(Locale.getDefault()).split(" ")
              Arrays.asList(ary).asInstanceOf[java.lang.Iterable[String]]
            }
          }
        ).map(
          new KeyValueMapper[String, String, KeyValue[String, String]] {
            override def apply(key: String, value: String): KeyValue[String, String] = new KeyValue(value, value)            
          }
        ).groupByKey().count("Counts");

How can I fix this compilation error?

Thanks. 

--
You received this message because you are subscribed to the Google Groups "scala-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
For more options, visit https://groups.google.com/d/optout.
oss.mlists
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]

oss.mlists
KR, VR are unknown. What is the type of "source"? I would guess it is KStream[Nothing, Nothing] and that you use default serdes and have plain buider.stream("my_topic"). Scala can't infer it because this way the information is on runtime. Either annotate "source" when doing builder.source[String, String]("my_topic") or use the variant which provides serdes explicitly - builder.source(Serdes.String(), Serdes.String(), "my_topic").

It could be fine then. If not find where types are inferred to Nothing. Java patterns do mess to Scala type inference.

Petr

--
You received this message because you are subscribed to the Google Groups "scala-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
For more options, visit https://groups.google.com/d/optout.
robert towne
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]

robert towne
Did you ever find out how to solve this - I'm running into the same problem as well..

Thanks!
Robert


--
You received this message because you are subscribed to the Google Groups "scala-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
For more options, visit https://groups.google.com/d/optout.
Adriaan Moors-7
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: inferred type arguments [?1,?0] do not conform to method map's type parameter bounds [KR,VR]

Adriaan Moors-7
Hi,

The following snippet compiles for me on Scala 2.12.1 (against kafka-streams 0.10.2.0).
Thanks IntelliJ for translating most of the Java code :-)


cheers
adriaan

import scala.collection.JavaConverters._

val builder = new KStreamBuilder
val source: KStream[String, String] = builder.stream("streams-file-input")
val counts: KTable[String, java.lang.Long] = source.
  flatMapValues[String] { _.toLowerCase(Locale.getDefault).split(" ").toList.asJava }.
  map[String, String] { (key, value) => new KeyValue(value, value) }.
  groupByKey.count("Counts")

// need to override value serde to Long type
counts.to(Serdes.String, Serdes.Long, "streams-wordcount-output")

On Thu, Apr 13, 2017 at 5:01 AM robert towne <[hidden email]> wrote:
Did you ever find out how to solve this - I'm running into the same problem as well..

Thanks!
Robert


--
You received this message because you are subscribed to the Google Groups "scala-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
For more options, visit https://groups.google.com/d/optout.

--
You received this message because you are subscribed to the Google Groups "scala-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to [hidden email].
For more options, visit https://groups.google.com/d/optout.
Free forum by Nabble Edit this page