233酱工作中使用了一点ELK，偶尔使用Kibana拼接ES DSL简直要命。如果你和我一样「熟悉SQL，但不咋会写DSL」 or 「想要用SQL简化查询」，本文会介绍一下官方对ES SQL的支持，希望对你有所帮助～...

对于大数据稍有了解的人应该知道，大数据主要的编程语言，是使用Java来完成的，而Java之外，掌握一定的Scala，在大数据开发学习当中，能够更好地掌握相关技术框架。那么Scala对于大数据开发重要吗？今天我们来给大家一些Scala基础...

cannot be cast to com.google.protobuf.Message

flink本身给我们提供了大量的内置函数，已经能满足我们绝大部分的需求，但是如果确实是碰到了一些特殊的场景，无法满足我们的需求的时候，我们可以自定义函数来解决，今天我们主要讲一下最简单的自定义函数-ScalarFunction。...

1.0.0 is the latest release. The current stable version is 1.0.0.

export JAVA_HOME=/usr/lib/jvm/jdk1.8.0_261

实际上很早就写了一系列关于akka-streams的博客。但那个时候纯粹是为了了解akka而去学习的，主要是从了解akka-streams的原理为出发点。因为akka-streams是akka系列工具的基础，如：akka-http, persistence-query等都是基于...

本文介绍的内容是侧输出流(SideOutput)，在平时大部分的 DataStream API 的算子的输出是单一输出，也就是某一种或者说某一类数据流，流向相同的地方。

自定义Flink Source，案例分别实现了继承于SourceFunction的四个案例，三个完全自定义的Source， 另外一个Source为常见的MySQL，通过这几个案例，启发我们进行实际案例的Source研发...

目录一.页面单跳转化率统计需求简介思路分析二.具体实现具体业务实现完整项目代码一.页面单跳转化率统计需求简介计算页面单跳转化率，什么是页面单跳转换率，比如一个用户在一次 Session 过程中访问的页面路径 3,5,7,9,1...