Hi all. Is there any way I can

DESCRIBE

a table that's already part of a job (not in the execution environment)?

I'm not sure I understand. What is it that you're trying to do?

I'm using the Table API and SQL. Say if I have a few tables being created:

CREATE TABLE a ...
CREATE TABLE b ...
CREATE TABLE c ...

and then I publish a job:

EXECUTE STATEMENT SET
BEGIN

INSERT INTO c ...

END

is there any way I can use the

DESCRIBE

statement (https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/describe/) in any of these tables through the job itself?

So you basically try to get the output of a DESCRIBE TABLE to influence your logic further downstream?

That's right. We're migrating from Flink to Snowflake essentially, and I want to build a script that prepares Snowflake by automatically generating the CREATE TABLE statements, converts datatypes, etc.

While never tried it, I would expect that you should be able to do something like

Table resultTable =
                tableEnv.sqlQuery(
                        String.join(
                                "\n",
                                "SELECT t_id, c_name, CAST(t_amount AS DECIMAL(5, 2))",
                                "FROM Customers",
                                "JOIN (SELECT DISTINCT * FROM Transactions) ON c_id = t_customer_id"));

But then with a DESCRIBE statement. Not 100% sure though