level 1
双木哥9527
楼主
各位帮忙看下,已经按照网上说的加上
import org.apache.flink.api.scala._
import org.apache.flink.table.api.scala._
但是依旧会报错,版本信息如下
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-scala_2.12</artifactId>
<version>1.9.1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table_2.12</artifactId>
<version>1.7.2</version>
</dependency>
代码:
val env = ExecutionEnvironment.getExecutionEnvironment
val tableENV = TableEnvironment.getTableEnvironment(env)
//读取文本数据
//val unit = env.readTextFile("flink_table_api/data")
//隐式转换
import org.apache.flink.api.scala._
import org.apache.flink.table.api.scala._
val tuples = List(
("u001", "alex", "jk"),
("u002", "lucy", "lolita"),
("u003", "rose", "jk")
)
val value = env.fromCollection(tuples)
tableENV.registerDataSet("stu",value,'ids,'name,'jk)
Error:(26, 35) could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[(String, String, String)]
val value = env.fromCollection(tuples)
2020年03月11日 06点03分
1
import org.apache.flink.api.scala._
import org.apache.flink.table.api.scala._
但是依旧会报错,版本信息如下
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-scala_2.12</artifactId>
<version>1.9.1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table_2.12</artifactId>
<version>1.7.2</version>
</dependency>
代码:
val env = ExecutionEnvironment.getExecutionEnvironment
val tableENV = TableEnvironment.getTableEnvironment(env)
//读取文本数据
//val unit = env.readTextFile("flink_table_api/data")
//隐式转换
import org.apache.flink.api.scala._
import org.apache.flink.table.api.scala._
val tuples = List(
("u001", "alex", "jk"),
("u002", "lucy", "lolita"),
("u003", "rose", "jk")
)
val value = env.fromCollection(tuples)
tableENV.registerDataSet("stu",value,'ids,'name,'jk)
Error:(26, 35) could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[(String, String, String)]
val value = env.fromCollection(tuples)