序列化

来源：8-9 Flink对接Kafka作为Sink使用

慕瓜9172627

2019-08-07

老师你好
输出流类型是Int的如何进行序列化，用哪个类

写回答

1回答

Michael_PK

2019-08-07

基本数据类型默认就能序列化的

慕瓜9172627

不是就是在addSink使用kafkaProducer时，输出值是int类型，第二个参数应该怎么写 data.addSink(new FlinkKafkaProducer［Int］(topic,new KeyedSerializationSchemaWrapper［Int］(？？？)，properties))

2019-08-08

共1条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势，多语言系统化讲解，极速入门Flink

969 学习 · 296 问题

查看课程

相似问题

写入es报没有序列化

回答 1

private transient ValueState

回答 1

如果Connection可序列化是不是用map也可以

回答 1

如果想把对象序列化后的byte数组写入kafka该怎么做呢

回答 1

Socket断开时基于DataStream应用的failover如何处理?

回答 1

打开慕课网App查看更多内容