towhee.engine.operator_io.reader.BlockMapReaderWithOriginData¶

class towhee.engine.operator_io.reader.BlockMapReaderWithOriginData(input_df: DataFrame, op_inputs_index: Dict[str, int])[source]¶

Return both op’s input data and origin data.

Methods

`close`
`read`	Read data from dataframe, get cols by operator_repr info

Attributes

size

read() → Tuple[Dict[str, any], Tuple][source]¶: Read data from dataframe, get cols by operator_repr info