Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -25,22 +25,22 @@
],
"outputs": [
{"topic": "S2", "key": 0, "value": "0,0", "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,5", "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,5", "timestamp": 10000, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,5", "timestamp": 10000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 10000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 20000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 20000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,6", "timestamp": 40000, "window": {"start": 40000, "end": 70000}},
{"topic": "S2", "key": 100, "value": "100,300", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,300", "timestamp": 40000, "window": {"start": 40000, "end": 70000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 45000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 45000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,6", "timestamp": 45000, "window": {"start": 40000, "end": 70000}},
{"topic": "S2", "key": 100, "value": "100,300", "timestamp": 50000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,300", "timestamp": 50000, "window": {"start": 40000, "end": 70000}},
{"topic": "S2", "key": 100, "value": "100,300", "timestamp": 50000, "window": {"start": 50000, "end": 80000}},
{"topic": "S2", "key": 0, "value": "0,100", "timestamp": 10000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 0, "value": "0,100", "timestamp": 20000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 0, "value": "0,100", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 0, "value": "0,2000", "timestamp": 20000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 0, "value": "0,2000", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 0, "value": "0,100", "timestamp": 35000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 0, "value": "0,100", "timestamp": 35000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 0, "value": "0,100", "timestamp": 35000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 0, "value": "0,2000", "timestamp": 40000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 0, "value": "0,2000", "timestamp": 40000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 0, "value": "0,2000", "timestamp": 40000, "window": {"start": 40000, "end": 70000}}

]
Expand All @@ -58,10 +58,10 @@
],
"outputs": [
{"topic": "S2", "key": 0, "value": "0,0", "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,0", "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,0", "timestamp": 10000, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,5", "timestamp": 10000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 10000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 20000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 20000, "end": 50000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 30000, "end": 60000}}
]
},
Expand All @@ -77,7 +77,7 @@
],
"outputs": [
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[0.0]}, "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[100.0,0.0]}, "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[100.0,0.0]}, "timestamp": 10000, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[100.0]}, "timestamp": 10000, "window": {"start": 10000, "end": 40000}}
]
},
Expand All @@ -94,9 +94,9 @@
],
"outputs": [
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[0.0]}, "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[100.0,0.0]}, "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[100.0,0.0]}, "timestamp": 10000, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[100.0]}, "timestamp": 10000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[100.0,0.0]}, "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[100.0,0.0]}, "timestamp": 10000, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": {"ID":0,"TOPK":[100.0]}, "timestamp": 10000, "window": {"start": 10000, "end": 40000}}
]
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@
],
"outputs": [
{"topic": "S2", "key": 0, "value": "0,0", "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": null, "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": null, "timestamp": 10000, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,5", "timestamp": 10000, "window": {"start": 0, "end": 40000}},
{"topic": "S2", "key": 1, "value": "1,100", "timestamp": 10000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 1, "value": null, "timestamp": 10000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 1, "value": null, "timestamp": 40000, "window": {"start": 10000, "end": 40000}},
{"topic": "S2", "key": 1, "value": "1,200", "timestamp": 40000, "window": {"start": 10000, "end": 70000}}
]
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,12 @@
],
"outputs": [
{"topic": "S2", "key": 0, "value": "0,0", "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,5", "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,5", "timestamp": 10000, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,300", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 0, "value": "0,100", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 0, "value": "0,2000", "timestamp": 30000, "window": {"start": 30000, "end": 60000}}
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 45000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,300", "timestamp": 50000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 0, "value": "0,100", "timestamp": 35000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 0, "value": "0,2000", "timestamp": 40000, "window": {"start": 30000, "end": 60000}}

]
},
Expand All @@ -49,10 +49,10 @@
],
"outputs": [
{"topic": "S2", "key": 0, "value": "0,0", "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,0", "timestamp": 0, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 0, "value": "0,0", "timestamp": 10000, "window": {"start": 0, "end": 30000}},
{"topic": "S2", "key": 100, "value": "100,100", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,6", "timestamp": 30000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,6", "timestamp": 30000, "window": {"start": 30000, "end": 60000}}
{"topic": "S2", "key": 100, "value": "100,6", "timestamp": 45000, "window": {"start": 30000, "end": 60000}},
{"topic": "S2", "key": 100, "value": "100,6", "timestamp": 50000, "window": {"start": 30000, "end": 60000}}
]
},
{
Expand Down