概述
Flink支持的DataType
lJava Tuple 和 Scala case class
lJava POJOs:java实体类
lPrimitive Types
•默认支持java和scala基本数据类型
lGeneral Class Types
•默认支持大多数java和scala class
lHadoop Writables
•支持hadoop中实现了org.apache.hadoop.Writable的数据类型
lSpecial Types
•例如scala中的Either Option 和Try
Flink 的序列化
lFlink自带了针对诸如int,long,String等标准类型的序列化器
l针对Flink无法实现序列化的数据类型,我们可以交给Avro和Kryo
•使用方法:ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
•使用avro序列化:env.getConfig().enableForceAvro();
•使用kryo序列化:env.getConfig().enableForceKryo();
•使用自定义序列化:env.getConfig().addDefaultKryoSerializer(Class<?> type, Class<? extends Serializer<?>> serializerClass)
•https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/custom_serializers.html
最后
以上就是坚强乐曲为你收集整理的flink---7 flink的DataType和序列化的全部内容,希望文章能够帮你解决flink---7 flink的DataType和序列化所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复