加油哦!
加油哦!
KStream和KTable是Kafka Streams里内建的两个最重要的抽象,分别对应数据流和数据库。Kafka Streams作为流处理技术的一大卖点,即是很好地将存储...
同为流处理技术,Kafka Streams的API和更为人所熟知的Spark Streaming在很多方面有不少相似之处,比如大量类似的算子。因此,对于一个有Spark经验的...
仅仅是一段代码 Kafka Streams作为集成在Kafka系统中的一个API,在配合Kafka来进行流处理时有着得天独厚的优势。不同于Spark Streaming和Fl...
Docker在很多时候都可以帮助我们快速搭建想要的开发环境,免去了很多安装配置上的麻烦。在涉及到Apache Kafka的快速demo时,使用Docker Hub上提供的镜像...
WordCount WordCount 堪称大数据界的HelloWorld,相信不管是Hadoop还是Spark等大数据工具的上手实例,第一个十有八九是WordCount。 ...
现在开源流处理框架越来越多,大家都熟知的有 Spark Streaming, NiFi, Flink等等。Kafka Streams 也是其中一员。 那么在众多的流处理框架中...
谢谢分享,相互学习!
在搭建数据通道(data pipeline)时,由于涉及到:数据读取,数据分析,数据存储等等,如果将各个部分分别容器化,独立设计各个模块,将有助于缩短开发时间。 这里以一个基...
快速语法对照 List HashMap Set For loop Range
Scala中,使用 to*方法 在很多情况下可以方便地进行类型转换。 toString toInt toDouble toFloat toLong Int 到 String ...
Kafka Connect 作为service提供了 REST API 服务,用来: 获取 Kafka Connect 状态 管理 Kafka Connect 配置 Kafk...
文本分析在Spark开发中非常常见,而正则表达式又是文本分析中的重要工具,因此对一些常用正则表达式进行总结: \\s Whitespace 空格\\s+ Whit...
Flask是一个轻便的Web开发库,但随着API开发但进行,越来越多的部分被加入到项目中,为了结构的简明和日后的可维护性,更好地组织项目结构势在必行。 RESTful API...
Model的由来 在 Model与Resource(上) 中,models文件夹下那些对应Resource的类,它们的主要任务是:提供并管理 Resource类下CRUD操作...
REST API设计的核心是资源(Resource),围绕着资源才有了URI和各种各样的HTTP操作。因此,如何对资源建模就显得十分重要,这关系到API能否为使用者提供他们想...
什么是类方法(class method)? Python开发中,我们更多使用的是实例方法(instance methods): 如这里的__init__(self),需要se...
资源 Resource 的摆放 在使用Flask-RESTful的Resource类简化API开发步骤时,所有的资源都可以通过继承Resource类来构建一个单独的class...