حالة Streams والنوافذ والبيانات المتأخرة

def window_start(timestamp_s, width_s=10):
    return (timestamp_s // width_s) * width_s
assert window_start(0) == 0
assert window_start(9) == 0
assert window_start(10) == 10
print(window_start(9), window_start(10))

0 10

حاويات العشر ثوان اتفاق حسابي معلن وليست اختبار تشغيل Streams.

from collections import Counter
events = [('D1', 2), ('D1', 9), ('D2', 10)]
counts = Counter((depot, timestamp // 10 * 10) for depot, timestamp in events)
assert counts[('D1', 0)] == 2
assert counts[('D2', 10)] == 1
print(counts[('D1', 0)], counts[('D2', 10)])

2 1

يعد كل حدث معطى مرة؛ ولا ينفذ سماحاً أو سياسة تكرار.