pyflink.table.table_environment.TableEnvironment.from_descriptor#

TableEnvironment.from_descriptor(descriptor: pyflink.table.table_descriptor.TableDescriptor) → pyflink.table.table.Table[source]#

Returns a Table backed by the given TableDescriptor.

The TableDescriptor is registered as an inline (i.e. anonymous) temporary table (see create_temporary_table()) using a unique identifier and then read. Note that calling this method multiple times, even with the same descriptor, results in multiple temporary tables. In such cases, it is recommended to register it under a name using create_temporary_table() and reference it via from_path()

Examples:

>>> table_env.from_descriptor(TableDescriptor.for_connector("datagen")
...     .schema(Schema.new_builder()
...         .column("f0", DataTypes.STRING())
...         .build())
...     .build()

Note that the returned Table is an API object and only contains a pipeline description. It actually corresponds to a <i>view</i> in SQL terms. Call execute() in Table to trigger an execution.

Returns: The Table object describing the pipeline for further transformations.

New in version 1.14.0.