我是靠谱客的博主 坚强乐曲,最近开发中收集的这篇文章主要介绍flink---7 flink的DataType和序列化,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

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无法实现序列化的数据类型,我们可以交给AvroKryo

使用方法: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和序列化所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(45)

评论列表共有 0 条评论

立即
投稿
返回
顶部