我想创建一个表(基于dataStream(,并在许多作业之间共享。我想创建类似白名单的东西,并在另一个作业中查询此列表。
有可能吗?据我了解,桌子已分配给餐桌环境。每个工作都有自己的餐桌环境。
如何共享此"状态"?
我不认为可以通过多个单独的作业共享表。我能想到的最好的解决方案是使用适当的TableSource
,例如CsvTableSource
或KafkaJsonTableSource
来注册每个作业的表。但这不会给您真正分享状态,因为如果您在一项工作中修改Table
,则不会自动传播更改。我不确定您的用户酶是什么,如果TableSource
适合您的需求。