towhee.engine.operator_io.reader.BatchFrameReader

class towhee.engine.operator_io.reader.BatchFrameReader(input_df: DataFrame, op_inputs_index: Dict[str, int], batch_size: int, step: int)[source]

Bases: DataFrameReader

Batch reader.

Methods

close

read

Attributes

size

__init__(input_df: DataFrame, op_inputs_index: Dict[str, int], batch_size: int, step: int)[source]