towhee.engine.operator_io.reader.TimeWindowReader

class towhee.engine.operator_io.reader.TimeWindowReader(input_df: DataFrame, op_inputs_index: Dict[str, int], time_range_sec: int, time_step_sec: int)

Bases: DataFrameReader

Time window reader

Methods

close
read

Attributes

size

__init__(input_df: DataFrame, op_inputs_index: Dict[str, int], time_range_sec: int, time_step_sec: int)