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

Docker — Beginner Notes

How to Deploy a SQL Server Container in Alibaba Container Service Kubernetes

Lessons learned on migrating to AWS

How Yuque, Alibaba’s Work Collaboration Software, Has Evolved Over Time

The Development of a Real-time Precise Outreach System

Advanced REST API Design

Generate password protected excel file in Java

The Easiest Way You Can Learn JavaScript

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

CS373 Spring: Dillon Samra

CS373 Spring 2022: Scarlett Shires, Week 14

CS373 Spring 2022: Kristina Zhou