pyflink.table.table_environment.TableEnvironment.create_temporary_table#
- TableEnvironment.create_temporary_table(path: str, descriptor: pyflink.table.table_descriptor.TableDescriptor)[source]#
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.