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

[no subject]

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