pyflink.dataframe.dataframe.col# col(name: str) → Expression[source]# 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")
