Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
    • TableEnvironment
    • Table
    • Data Types
    • Window
    • Expressions
    • User Defined Functions
    • Descriptors
    • StatementSet
    • Catalog
  • PyFlink DataStream
  • PyFlink Common

pyflink.table.statement_set.StatementSet.attach_as_datastream#

StatementSet.attach_as_datastream()[source]#

Optimizes all statements as one entity and adds them as transformations to the underlying StreamExecutionEnvironment.

Use execute() to execute them.

The added statements will be cleared after calling this method.

New in version 1.16.0.

previous

pyflink.table.statement_set.StatementSet.add_insert_sql

next

pyflink.table.statement_set.StatementSet.add_insert

Show Source

Created using Sphinx 4.5.0.