flink1.12.x sink-发送数据到elasticsearch7
Executable Jar、Uber Jar、Fat jar、Shade jar、Shadow jar
flink 维表关联、翻译字典-热存储维表-使用AsyncDataStream、RichAsyncFunction 查询Hbase,并缓存到guava cache中
JAVA本地缓存-Google Guava Cache
flink1.12.x AsyncDataStream和AsyncFunction、RichAsyncFunction异步处理
flink 维表关联、翻译字典-热存储维表-使用AsyncDataStream、RichAsyncFunction 查询Hbase
hbase2.1.x java 封装一个cell数据:CellData
java Collections.singleton()
flink 维表关联、翻译字典-热存储维表-使用AsyncDataStream、RichAsyncFunction 进行异步处理(查询MySQL)
flink 维表关联、翻译字典-热存储维表-使用asynchbase异步客户端库