接上篇:[翻译]Flink 异步I / O访问外部数据 最近看了大佬的博客,突然想起Async I/O方式是Blink 推给社区的一大重要功能,可以使用异步的方式获取外部数据,想着自己实现以下,项目上用的时候,可以不用现去找了. 最开始想用scala 实现一个读取 hbase数据的demo,参照官网demo: /** * An implementation of the 'AsyncFunction' that sends requests and sets the callback. */ c
1,Connect an External Data Source, 添加新的数据源,填写如下 2, 点击Validate and Sync 按钮 3,添加Orders和Orders Details 4,观察外部数据,创建Tab后,点击Order可以看到数据 5,转换 Order Detail 的 Order ID 的类型为 External Object ID 链接 Order 6, 标准和自定义Object 引用 外部数据 引用流程都和外部引用都是一致的,不过再转换External ID