|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 implicitvalue forevidence parameter of
typeorg.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]valstream
=tableEnv.toAppendStream[Row](tableTest)Error:(56,46)not enough
arguments formethod
toAppendStream:(implicitevidence$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].Unspecifiedvalue
parameter evidence$3.valstream =tableEnv.toAppendStream[Row](tableTest)|
Code: -----------------
importorg.apache.flink.types.Rowimportorg.apache.flink.streaming.api.TimeCharacteristicimportorg.apache.flink.streaming.api.scala.{DataStream,StreamExecutionEnvironment}importorg.apache.flink.table.api.TableEnvironmentimportorg.apache.flink.table.sources.CsvTableSourceimportorg.apache.flink.api.common.typeinfo.TypesobjectCepTest2{defmain(args:Array[String]){println("Start
...")valenv =StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)//val
tableEnv = StreamTableEnvironment.getTableEnvironment(env)valtableEnv
=TableEnvironment.getTableEnvironment(env)valcsvtable
=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)valtableTest
=tableEnv.scan("test").where("id='5'").select("id,sources,targets")valstream
=tableEnv.toAppendStream[Row](tableTest)stream.print
env.execute()}}-------------------- |
- Problems to use toAppendStream Esa Heikkinen
-