osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[no subject]


Hi,
Is there a way to get table's metadata in flink?
if I emit a table to kafka, then how can I know the table columns when I subscribe the kafka topic and restore the table using tableEnv.registerDataStream("t1", source, "field1, field2 ...")  in another flink program?

Flink should provide something like Hive's metastore to keep metadata of tables.

--
best wishes
hengyu