I can convert DataStreams to Tables but is there a way to co Apache Flink #troubleshooting

I can convert DataStreams to Tables, but is there ...

Vitor Leal

08/14/2023, 4:13 PM

I can convert DataStreams to Tables, but is there a way to convert DataStream sinks to TableSinks? Given two tables created from data streams:

Copy code

Table t1 = tEnv.fromChangelogStream(...)
Table t2 = tEnv.fromChangelogStream(...)

and a sink:

Copy code

KafkaSink kafkaSink = ???

is there a way to create a TablePipeline from the tables to this sink?

Copy code

StatementSet stmtSet = tEnv.createStatementSet();

stmtSet.add(t1.insertInto(???));
stmtSet.add(t2.insertInto(???));