Skip to main content
Ctrl+K
PyFlink 1.20+vvr.11.7.dev0 documentation - Home PyFlink 1.20+vvr.11.7.dev0 documentation - Home
  • API Reference
  • Examples
  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
    • TableEnvironment
    • Table
    • Data Types
    • Window
    • Expressions
    • User Defined Functions
    • Descriptors
    • StatementSet
    • Catalog
  • PyFlink DataStream
  • PyFlink DataFrame
  • PyFlink Common
  • API Reference
  • PyFlink Table
  • StatementSet
  • pyflink.table.statement_set.StatementSet.attach_as_datastream

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.

Added in version 1.16.0.

previous

pyflink.table.statement_set.StatementSet.add_insert_sql

next

pyflink.table.statement_set.StatementSet.add_insert

On this page
  • StatementSet.attach_as_datastream()

This Page

  • Show Source

Created using Sphinx 7.4.7.

Built with the PyData Sphinx Theme 0.16.1.