flink动态写入tag标签

请问各位大佬 flink在写入nebula的时候可以 动态写入tag标签吗?就是根据消费的数据设置tag标签,我现在消费了kafka的数据,然后想根据消费的数据,使用每条数据的某个字段来设置写入时的tag标签,有这样的方法吗?

可以的,NebulaGraph 里使用 tag 来代替 label,因此你insert vertex 时把 tag 以及这个 tag 的属性(如果有)插入就行


我按照提供的demo来写的,应该怎么修改呢 :disappointed_relieved:

此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。