pyflink.dataframe.DataType.row

classmethod DataType.row(fields: Union[Dict[str, pyflink.dataframe.datatype.DataType], List[tuple]]) → pyflink.dataframe.datatype.DataType

Struct/Row type with named fields.

Parameters

fields – Either a dict of {name: type} or list of (name, type) tuples.

Example::

>>> DataType.struct({"name": DataType.string(), "age": DataType.int32()})
>>> DataType.struct([("name", DataType.string()), ("age", DataType.int32())])