基于Flink引擎的数据处理方法、装置、设备及介质

本申请公开了基于Flink引擎的数据处理方法、装置、设备及介质，涉及大数据处理技术领域，包括：基于预设多语言序列化框架进行线程安全的实例创建，并将待序列化对象注册至得到的目标实例中；基于预设集成策略并将所述目标实例集成至Flink引擎中的数据传输层、状态管理组件，以得到相应的集成后计算引擎；在利用所述集成后计算引擎进行数据处理的过程中，通过预设字符串压缩算法、零拷贝序列化原则以及所述目标实例触发序列化操作和/或反序列化操作，以完成相应的引擎节点间的数据传输操作、Flink引擎的状态后端的状态存储操作。能够有效提高数据处理的效率、可靠性以及适用性。