Welcome to Flink Python API Docs!

Contents

• pyflink package
  • Subpackages
• pyflink.common package
  • Module contents
• pyflink.table package
  • Module contents
  • pyflink.table.expressions module
  • pyflink.table.window module
  • pyflink.table.descriptors module
  • pyflink.table.catalog module
  • pyflink.table.module module
• pyflink.datastream package
  • Module contents
  • pyflink.datastream.state module
  • pyflink.datastream.connectors module
  • pyflink.datastream.window module
• pyflink.metrics package
  • Module contents

Core Classes:

pyflink.table.TableEnvironment

Main entry point for Flink Table functionality.

pyflink.table.Table

Core component of the Flink Table API. The Flink Table API is built around Table.

pyflink.datastream.StreamExecutionEnvironment

Main entry point for Flink DataStream functionality.

pyflink.datastream.DataStream

Core component of the Flink DataStream API. The Flink DataStream API is built around DataStream.