Welcome to Flink Python API Docs!

Contents

• pyflink package
  • Subpackages
• pyflink.common package
  • Module contents
• pyflink.table package
  • Module contents
  • 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.