time_stream.infill.InfillMethodPipeline¶

class time_stream.infill.InfillMethodPipeline(infill_method, ctx, column, observation_interval=None, max_gap_size=None)[source]¶

Encapsulates the logic for the infill pipeline steps.

Parameters:

infill_method (InfillMethod)
ctx (InfillCtx)
column (str)
observation_interval (datetime | tuple[datetime, datetime | None] | None)
max_gap_size (int | None)

__init__(infill_method, ctx, column, observation_interval=None, max_gap_size=None)[source]¶

Parameters:

infill_method (InfillMethod)
ctx (InfillCtx)
column (str)
observation_interval (datetime | tuple[datetime, datetime | None] | None)
max_gap_size (int | None)

Methods

`__init__`(infill_method, ctx, column[, ...])
`execute`()	Execute the infill pipeline