towhee.engine.operator_io.reader.DataFrameReader¶

class towhee.engine.operator_io.reader.DataFrameReader(it: DataFrameIterator, op_inputs_index: Dict[str, int])[source]¶

Read data from input dataframes, unpack and combine data. One op_ctx has one dataframe reader.

Methods

`close`
`read`

Attributes

size

__init__(it: DataFrameIterator, op_inputs_index: Dict[str, int])[source]¶