| 968 | @check_arg_types |
| 969 | @contextualized_operator |
| 970 | def _buffer( |
| 971 | self, |
| 972 | threshold_column: expr.ColumnExpression, |
| 973 | time_column: expr.ColumnExpression, |
| 974 | instance_column: expr.ColumnExpression | None = None, |
| 975 | ) -> Table: |
| 976 | if instance_column is None: |
| 977 | instance_column = expr.ColumnConstExpression(None) |
| 978 | context = clmn.BufferContext( |
| 979 | self._id_column, |
| 980 | self._eval(threshold_column), |
| 981 | self._eval(time_column), |
| 982 | self._eval(instance_column), |
| 983 | ) |
| 984 | return self._table_with_context(context) |
| 985 | |
| 986 | @contextualized_operator |
| 987 | @check_arg_types |