Skip to content

SortedWindow

Sorted running window data structure.

Parameters

  • size

    Typeint

    Size of the window to compute the rolling quantile.

Attributes

  • size

Examples

from river import utils

window = utils.SortedWindow(size=3)

for i in reversed(range(9)):
    print(window.append(i))
[8]
[7, 8]
[6, 7, 8]
[5, 6, 7]
[4, 5, 6]
[3, 4, 5]
[2, 3, 4]
[1, 2, 3]
[0, 1, 2]

Methods

append

S.append(value) -- append value to the end of the sequence

Parameters

  • x

clear

S.clear() -> None -- remove all items from S

copy
count

S.count(value) -> integer -- return number of occurrences of value

Parameters

  • item

extend

S.extend(iterable) -- extend sequence by appending elements from the iterable

Parameters

  • other

index

S.index(value, [start, [stop]]) -> integer -- return first index of value. Raises ValueError if the value is not present.

Supporting start and stop arguments is optional, but recommended.

Parameters

  • item
  • args

insert

S.insert(index, value) -- insert value before index

Parameters

  • i
  • item

pop

S.pop([index]) -> item -- remove and return item at index (default last). Raise IndexError if list is empty or index is out of range.

Parameters

  • i — defaults to -1

remove

S.remove(value) -- remove first occurrence of value. Raise ValueError if the value is not present.

Parameters

  • item

reverse

S.reverse() -- reverse IN PLACE

sort