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
  • Descriptors
  • pyflink.table.schema.Schema.Builder.primary_key

pyflink.table.schema.Schema.Builder.primary_key#

Builder.primary_key(*column_names: str) → Builder#

Declares a primary key constraint for a set of given columns. Primary key uniquely identify a row in a table. Neither of columns in a primary can be nullable. The primary key is informational only. It will not be enforced. It can be used for optimizations. It is the data owner’s responsibility to ensure uniqueness of the data.

The primary key will be assigned a generated name in the format {@code PK_col1_col2}.

Parameters:

column_names – Columns that form a unique primary key

previous

pyflink.table.schema.Schema.Builder.watermark

next

pyflink.table.schema.Schema.Builder.primary_key_named

On this page
  • Builder.primary_key()

This Page

  • Show Source

Created using Sphinx 7.4.7.

Built with the PyData Sphinx Theme 0.16.1.