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)[source]

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)[source]