Data Types and Serialization: Flink Advanced Tutorials

Customizing a Serialization Framework for Flink

Flink Data Types

TypeInformation

Flink Serialization Process

Best Practices of Flink Serialization

Common Scenarios

Practice — Type Declaration

PojoTypeInfo<Person> typeInfo = (PojoTypeInfo<Person>) TypeInformation.of(Person.class);
final TypeInfomation<Tuple2<Integer,Integer>> resultType = TypeInformation.of(new TypeHint<Tuple2<Integer,Integer>>(){});

Practice — Subtype Registration

final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
Env. registerType(typeClass);

Practice — Kryo Serialization

env.getConfig().enableForceAvro();
env.getConfig().addDefaultKryoSerializer(clazz, serializer);

Flink Communication Serialization

Original Source:

--

--

--

Follow me to keep abreast with the latest technology news, industry insights, and developer trends. Alibaba Cloud website:https://www.alibabacloud.com

Love podcasts or audiobooks? Learn on the go with our new app.

Recommended from Medium

Null is your friend, not a mistake

Find All Anagrams in a String

🌟MINI GAME FOR GLOBAL ZOMBIE WORLD Z COMMUNITY — “WEEKLY QUIZ”🌟

How Does MongoDB Consume and Use Memory?

I18n Tutorial: How to Go Multilingual with Hugo

CS371p Spring 2021: Luca Chaves Rodrigues Noronha dos Santos

Why Infrastructure as Code is lit?

Get the Medium app

A button that says 'Download on the App Store', and if clicked it will lead you to the iOS App store
A button that says 'Get it on, Google Play', and if clicked it will lead you to the Google Play store
Alibaba Cloud

Alibaba Cloud

Follow me to keep abreast with the latest technology news, industry insights, and developer trends. Alibaba Cloud website:https://www.alibabacloud.com

More from Medium

They will use you as long as you let them — Random freewrite

The NRIC Check Digit Algorithm: Unbelievable facts to know about

Neural Workflow -Workflow Software

INTRODUCTION :