Flink 和 Pulsar 的批流融合
简介： 如何通过 Apache Pulsar 原生的存储计算分离的架构提供批流融合的基础，以及 Apache Pulsar 如何与 Flink 结合，实现批流一体的计算。 简介：StreamNative 联合创始人翟佳在本次演讲中介绍了下一代云原生消息流平台 Apache ...
原文：最佳实践：Pulsar 为批流处理提供融合存储
非常荣幸有机会和大家分享一下 Apache Pulsar 怎样为批流处理提供融合的存储。希望今天的分享对做大数据处理的同学能有帮助和启发。 这次分享，主要分为四个部分： 介绍与其他消息系统相比， Apache Pulsar 的独特优势 分析批流处理中的存储需求 讲述 Apache Pulsar 如何完美匹配批流处理中的存储需求 介绍怎样使用 Apache Pulsar 提供批流融合的存储 Apac ...
2020-09-02 23:51 0 788 推荐指数：
相关推荐
统一批处理流处理——Flink批流一体实现原理
实现批处理的技术许许多多，从各种关系型数据库的sql处理，到大数据领域的MapReduce，Hive，Spark等等。这些都是处理有限数据流的经典方式。而Flink专注的是无限流处理，那么他是怎么做到批处理的呢？ 无限流处理：输入数据没有尽头；数据处理从当前或者过去的某一个时间 点开 ...
Java 处理 Exception 的 9 个最佳实践！
使用的异常处理最佳实践。 1. 在Finally块中清理资源或者使用try-with-resource ...
ajax 请求二进制流 图片 文件 XMLHttpRequest 请求并处理二进制流数据 之最佳实践
写在前面 ：从提出需求到完美的解决问题，实现过程是曲折的。 需求：在前（web client）后（Restful Service）端完全解耦的模式框架下，webclient需要请求 Service 返回的图片文件（二进制流），并在client端显示。 第一步思考：拿到此需求， 基于程序员 ...
Pulsar部署和实践(一)
前言 本地Docker部署Pulsar消息代理实现消息发布和消息订阅 介绍 相关概念，后面有时间再花时间整理下。 实践步骤 1.使用dokcer本地部署pulsar docker run -it \ -p 6650:6650 \ -p 8080 ...
MySQL 中存储时间的最佳实践
平时开发中经常需要记录时间，比如用于记录某条记录的创建时间以及修改时间。在数据库中存储时间的方式有很多种，比如 MySQL 本身就提供了日期类型，比如 DATETIME，TIMESTAMEP 等，我们也可以直接存储时间戳为 INT 类型，也有人直接将时间存储为字符串类型。 那么到底哪种存储时间 ...
Java异常处理之最佳实践
引言： publicvoidconsumeAndForgetAllExceptions(){ try{ ...s ...
Linux故障处理最佳实践
引言 业务中断了！ 老板咆哮，主管抓狂，而你就是那个要去处理故障、恢复业务的不幸的人。 你将会怎么做？泡一杯咖啡准备通宵苦战？此时，或许你的心底也充满无奈： Linux服务器上部署的业务出现中断时，为快速处理问题、消除故障，避免以上苦逼的剧情发生，我们可以做哪些准备 ...