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.dataset package
  • Module contents
• pyflink.datastream package
  • Module contents
• pyflink.ml package
  • Module contents
  • pyflink.ml.api module
  • pyflink.ml.api.param module
  • pyflink.ml.lib module
  • pyflink.ml.lib.param 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.