用SCALA版本怎么实现

来源:1-1 课前须知,这里有你需要了解得一切

begin_0002

2022-03-25

public static DataStream createKafkaStreamV3(String[] args, Class<? extends KafkaDeserializationSchema> deser) throws Exception {

请问上述代码如何用scala语言实现

写回答

1回答

Michael_PK

2022-03-29

这个需要你自己去了解Scala语言的开发,关于泛型的使用了

0
0

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据,Flink助力轻松提薪;尚未入行,让你弯道超车

1000 学习 · 225 问题

查看课程