pyflink.table.table_environment.StreamTableEnvironment.register_table_sink

StreamTableEnvironment.register_table_sink(name: str, table_sink: pyflink.table.sinks.TableSink)

Registers an external TableSink with given field names and types in this TableEnvironment’s catalog. Registered sink tables can be referenced in SQL DML statements.

Example:

>>> table_env.register_table_sink("sink",
...                               CsvTableSink(["a", "b"],
...                                            [DataTypes.INT(),
...                                             DataTypes.STRING()],
...                                            "./2.csv"))

Parameters

• name – The name under which the table sink is registered.

• table_sink – The table sink to register.

Note

Deprecated in 1.10. Use execute_sql() instead.