It should be ok. This is the list of my all imports. First part of it has been
highlighted weaker. I don’t know why.
import org.apache.flink.streaming.api.windowing.time.Time
import org.apache.flink.api.java.utils.ParameterTool
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.streaming.api.windowing.time.Time
import org.apache.flink.cep.scala.{CEP, PatternStream}
import org.apache.flink.cep.scala.pattern.Pattern
import org.apache.flink.cep.{PatternFlatSelectFunction,
PatternFlatTimeoutFunction}
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction
import
org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
import org.apache.flink.util.Collector
import org.apache.flink.streaming.api.scala._
import org.apache.flink.api.scala._
import org.apache.flink.table.api.scala._
import org.apache.flink.table.api.scala.StreamTableEnvironment
import org.apache.flink.table.api.java.StreamTableEnvironment
import org.apache.flink.types.Row
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.sources.CsvTableSource
import org.apache.flink.api.common.typeinfo.Types
BR Esa
From: Xingcan Cui [mailto:xingc...@gmail.com]
Sent: Thursday, February 22, 2018 10:09 AM
To: Esa Heikkinen <esa.heikki...@student.tut.fi>
Cc: user@flink.apache.org
Subject: Re: Problems to use toAppendStream
Hi Esa,
just to remind that don’t miss the dot and underscore.
Best,
Xingcan
On 22 Feb 2018, at 3:59 PM, Esa Heikkinen
<esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>> wrote:
Hi
Actually I have also line “import org.apache.flink.streaming.api.scala” on my
code, but this line seems to be highlighted weaker in window of IDEA IntelliJ
editor. What does this mean ?
But the same errors will still be generated.
Esa
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Wednesday, February 21, 2018 9:41 PM
To: Esa Heikkinen
<esa.heikki...@student.tut.fi<mailto:esa.heikki...@student.tut.fi>>
Cc: user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: Problems to use toAppendStream
Hi Esa,
whenever you observe the error "could not find implicit value for evidence
parameter of type X" in a streaming program, you need to add the following
import:
import org.apache.flink.streaming.api.scala._
Best, Fabian
2018-02-21 19:49 GMT+01:00 Esa Heikkinen
<heikk...@student.tut.fi<mailto:heikk...@student.tut.fi>>:
Hi
I have tried to solve below Errors for long time, but no succeed yet. Could you
give some hint how to solve it ?
Errors in compiling:
------------------
Error:(56, 46) could not find implicit value for evidence parameter of type
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]
val stream = tableEnv.toAppendStream[Row](tableTest)
Error:(56, 46) not enough arguments for method toAppendStream: (implicit
evidence$3:
org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row])org.apache.flink.streaming.api.scala.DataStream[org.apache.flink.types.Row].
Unspecified value parameter evidence$3.
val stream = tableEnv.toAppendStream[Row](tableTest)
Code:
-----------------
import org.apache.flink.types.Row
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.sources.CsvTableSource
import org.apache.flink.api.common.typeinfo.Types
object CepTest2 {
def main(args: Array[String]) {
println("Start ...")
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
//val tableEnv = StreamTableEnvironment.getTableEnvironment(env)
val tableEnv = TableEnvironment.getTableEnvironment(env)
val csvtable = CsvTableSource
.builder
.path("/home/esa/Log_EX1_gen_track_5.csv")
.ignoreFirstLine
.fieldDelimiter(",")
.field("time", Types.INT)
.field("id", Types.STRING)
.field("sources", Types.STRING)
.field("targets", Types.STRING)
.field("attr", Types.STRING)
.field("data", Types.STRING)
.build
tableEnv.registerTableSource("test", csvtable)
val tableTest =
tableEnv.scan("test").where("id='5'").select("id,sources,targets")
val stream = tableEnv.toAppendStream[Row](tableTest)
stream.print
env.execute()
}
}
--------------------
