pyflink.table.schema.Schema.Builder.column

Builder.column(column_name: str, data_type: Union[str, DataType]) → Builder

Declares a physical column that is appended to this schema.

Physical columns are regular columns known from databases. They define the names, the types, and the order of fields in the physical data. Thus, physical columns represent the payload that is read from and written to an external system. Connectors and formats use these columns (in the defined order) to configure themselves. Other kinds of columns can be declared between physical columns but will not influence the final physical schema.

Parameters

• column_name – Column name

• data_type – Data type of the column