pyflink.dataframe.col

col(name: str) → pyflink.table.expression.Expression

Create a column reference expression.

Parameters

name – Column name.

Returns

Expression referencing the column.

Example::

>>> import pyflink.dataframe as pf
>>> pf.col("a")
>>> pf.col("a") + pf.col("b")