pyflink.table.table_environment.StreamTableEnvironment.create_temporary_table

StreamTableEnvironment.create_temporary_table(path: str, descriptor: pyflink.table.table_descriptor.TableDescriptor)

Registers the given TableDescriptor as a temporary catalog table.

The TableDescriptor is converted into a CatalogTable and stored in the catalog.

Temporary objects can shadow permanent ones. If a permanent object in a given path exists, it will be inaccessible in the current session. To make the permanent object available again one can drop the corresponding temporary object.

Examples:

>>> table_env.create_temporary_table("MyTable", TableDescriptor.for_connector("datagen")
...     .schema(Schema.new_builder()
...         .column("f0", DataTypes.STRING())
...         .build())
...     .option("rows-per-second", 10)
...     .option("fields.f0.kind", "random")
...     .build())

Parameters

• path – The path under which the table will be registered.

• descriptor – Template for creating a CatalogTable instance.

New in version 1.14.0.