[flink-SQL-API]如何将kafka中的json数据注册为表？

[猫猫 <16...@qq.com>]

我在kafka中有如下的数据存储结构，我希望将一些字段放到表中，使用sql方式进行处理。


我需要将其转换为数组流，然后再注册吗？
还是我可以配置字段为："key.database,value.data.user_id,value.data.org_id"这种方式直接注册成表？


也就是问，我需要装换json吗？


{
	"key": {
		"database": "test",
		"table": "jhi_user_org",
		"pk.user_id": 9522636,
		"pk.org_id": 10065286
	},
	"value": {
		"database": "test",
		"table": "jhi_user_org",
		"type": "insert",
		"ts": 1576465904,
		"xid": 539057,
		"commit": true,
		"data": {
			"user_id": 9522636,
			"org_id": 10065286
		}
	},
	"metadata": {
		"offset": 760,
		"topic": "TEST_BINLOG_ALL",
		"partition": 0
	}
}