deal all:
            目前在看table api 中,自定义的异步 join 方法 AsyncTableFunction#eval 方法时,发现接口提供的是:
            public void eval(CompletableFuture<Collection<RowData>> 
future,Object... keys) {...}


目前遇到两个问题:


1. 直接用 futrue.complate(rowdata) 传递数据,只是实现了发送是异步,异步join 得自己实现,这个理解对吗?
2. 像join hbase 里面通过线程池实现了join异步,是无法保证顺序,并没有看到任何保证顺序的操作,还是有其他逻辑保证顺序吗?


有各位大佬方便介绍一下吗?或者更详细的文档说明之类的?
非常感谢。
          

Reply via email to