pyflink.table.table_environment.TableEnvironment.register_table_sink#
- TableEnvironment.register_table_sink(name: str, table_sink: pyflink.table.sinks.TableSink)[source]#
Registers an external
TableSink
with given field names and types in thisTableEnvironment
’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.