Skip to content

Commit

Permalink
Daily Pathway examples refresh
Browse files Browse the repository at this point in the history 
Co-authored-by: Manul from Pathway <[email protected]>
GitOrigin-RevId: 48e69c32520654355b6b14d8fec9921817390a66
  • Loading branch information
@Pathway-Dev
Pathway-Dev and Manul from Pathway committed Jan 22, 2025
1 parent f72fbd4 commit 01e1047
Show file tree
Hide file tree
Showing 5 changed files with 76 additions and 79 deletions.
110 changes: 55 additions & 55 deletions examples/notebooks/tutorials/asynctransformer.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -162,11 +162,11 @@
"output_type": "stream",
"text": [
" | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 3 | 1737437860376 | 1\n",
"^3CZ78B4... | 2 | 3 | 1737437860576 | 1\n",
"^YYY4HAB... | 6 | 7 | 1737437860576 | 1\n",
"^3HN31E1... | 6 | 7 | 1737437860978 | 1\n",
"^X1MXHYY... | 12 | 13 | 1737437860978 | 1\n"
"^Z3QWT29... | 2 | 3 | 1737524099870 | 1\n",
"^3CZ78B4... | 2 | 3 | 1737524100070 | 1\n",
"^YYY4HAB... | 6 | 7 | 1737524100070 | 1\n",
"^3HN31E1... | 6 | 7 | 1737524100472 | 1\n",
"^X1MXHYY... | 12 | 13 | 1737524100472 | 1\n"
]
}
],
Expand Down Expand Up @@ -410,12 +410,12 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437864350 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437864450 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1737437864450 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437864652 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437864852 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737437864852 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1737524103966 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737524104066 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1737524104066 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737524104268 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737524104466 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737524104466 | 1\n"
]
}
],
Expand Down Expand Up @@ -537,18 +537,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437865086 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737437865086 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437865388 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737437865388 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1737437865388 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1737437865388 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437865488 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737437865488 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437865588 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737437865588 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737437865588 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1737437865588 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1737524104710 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737524104710 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737524105010 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737524105010 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1737524105010 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1737524105010 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737524105110 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737524105110 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737524105210 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737524105210 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737524105210 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1737524105210 | 1\n"
]
}
],
Expand Down Expand Up @@ -581,16 +581,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437865712 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1737437865812 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737437865912 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437866012 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737437866012 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1737437866012 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1737437866012 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437866112 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437866212 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737437866212 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1737524105330 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1737524105432 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737524105532 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737524105632 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737524105632 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1737524105632 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1737524105632 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737524105732 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737524105832 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737524105832 | 1\n"
]
}
],
Expand Down Expand Up @@ -633,18 +633,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437866360 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437866360 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737437866360 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737437866360 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437866860 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437866860 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737437866860 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737437866860 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737437866860 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1737437866860 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1737437866860 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1737437866860 | 1\n"
"^YYY4HAB... | 1 | 5 | 6 | 1737524105982 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737524105982 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737524105982 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737524105982 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737524106482 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737524106482 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737524106482 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737524106482 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737524106482 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1737524106482 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1737524106482 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1737524106482 | 1\n"
]
}
],
Expand Down Expand Up @@ -688,16 +688,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437866962 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737437866962 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737437867262 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737437867262 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437867362 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737437867362 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737437867462 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737437867462 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737437867462 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1737437867462 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1737524106612 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737524106612 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1737524106912 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1737524106912 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737524107014 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737524107014 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1737524107112 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1737524107112 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1737524107112 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1737524107112 | 1\n"
]
}
],
Expand Down
2 changes: 1 addition & 1 deletion examples/notebooks/tutorials/fs_connector.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -145,8 +145,8 @@
"output_type": "stream",
"text": [
"{\"data\":\"test1\",\"diff\":1,\"time\":1727690268124}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1727690268124}\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1727690268124}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1727690268124}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1727690268124}\r\n"
]
},
Expand Down
14 changes: 7 additions & 7 deletions examples/notebooks/tutorials/interval_join_temporal_behavior.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -428,13 +428,13 @@
"output_type": "stream",
"text": [
" | customer | product | price | order_time | start_time | __time__ | __diff__\n",
"^0NWM7FZ... | Austin | mouse | 43 | 120 | 120 | 138 | 1\n",
"^4AZTSKY... | Brenda | keyboard | 128 | 120 | 118 | 138 | 1\n",
"^0NWR22X... | Carl | mouse | 43 | 124 | 120 | 138 | 1\n",
"^0NWV1C1... | Frank | mouse | 43 | 120 | 120 | 138 | 1\n",
"^0NWRDBC... | Min | mouse | 43 | 124 | 120 | 138 | 1\n",
"^XTE0T7R... | Evelyn | cable | 10 | 128 | 128 | 150 | 1\n",
"^XTE84A9... | Nicole | cable | 10 | 130 | 128 | 150 | 1\n",
"^0NWM7FZ... | Austin | mouse | 43 | 120 | 120 | 134 | 1\n",
"^4AZTSKY... | Brenda | keyboard | 128 | 120 | 118 | 134 | 1\n",
"^0NWR22X... | Carl | mouse | 43 | 124 | 120 | 134 | 1\n",
"^0NWV1C1... | Frank | mouse | 43 | 120 | 120 | 134 | 1\n",
"^0NWRDBC... | Min | mouse | 43 | 124 | 120 | 134 | 1\n",
"^XTE0T7R... | Evelyn | cable | 10 | 128 | 128 | 140 | 1\n",
"^XTE84A9... | Nicole | cable | 10 | 130 | 128 | 140 | 1\n",
"^9W95T84... | Theresa | keyboard | 135 | 134 | 132 | 18446744073709551614 | 1\n"
]
}
Expand Down
9 changes: 1 addition & 8 deletions examples/notebooks/tutorials/udf.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -900,14 +900,7 @@
"name": "stdout",
"output_type": "stream",
"text": [
"inc_async(0.2) finishing"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"\n"
"inc_async(0.2) finishing\n"
]
},
{
Expand Down
20 changes: 12 additions & 8 deletions examples/notebooks/tutorials/windows_temporal_behavior.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -387,14 +387,18 @@
"output_type": "stream",
"text": [
" | window_start | window_end | n_logs | __time__ | __diff__\n",
"^Y8PEAZV... | 352 | 362 | 1 | 368 | 1\n",
"^YFKEFV6... | 356 | 366 | 2 | 368 | 1\n",
"^DX546QX... | 360 | 370 | 3 | 370 | 1\n",
"^Y8PEAZV... | 352 | 362 | 1 | 362 | 1\n",
"^YFKEFV6... | 356 | 366 | 2 | 362 | 1\n",
"^DX546QX... | 360 | 370 | 3 | 368 | 1\n",
"^B5NPNV8... | 364 | 374 | 2 | 370 | 1\n",
"^B5NPNV8... | 364 | 374 | 2 | 372 | -1\n",
"^B5NPNV8... | 364 | 374 | 3 | 372 | 1\n",
"^B5NPNV8... | 364 | 374 | 3 | 374 | -1\n",
"^B5NPNV8... | 364 | 374 | 4 | 374 | 1\n",
"^VRT1YTS... | 368 | 378 | 3 | 382 | 1\n",
"^QE3WQ0X... | 372 | 382 | 1 | 392 | 1\n",
"^VRT1YTS... | 368 | 378 | 3 | 374 | 1\n",
"^QE3WQ0X... | 372 | 382 | 1 | 382 | 1\n",
"^XJDDRJ0... | 376 | 386 | 1 | 382 | 1\n",
"^XJDDRJ0... | 376 | 386 | 1 | 392 | -1\n",
"^XJDDRJ0... | 376 | 386 | 2 | 392 | 1\n",
"^VRT1YTS... | 368 | 378 | 3 | 396 | -1\n",
"^QE3WQ0X... | 372 | 382 | 1 | 396 | -1\n",
Expand Down Expand Up @@ -696,9 +700,9 @@
"output_type": "stream",
"text": [
" | window_start | window_end | n_logs | __time__ | __diff__\n",
"^DX546QX... | 360 | 370 | 3 | 382 | 1\n",
"^B5NPNV8... | 364 | 374 | 4 | 392 | 1\n",
"^VRT1YTS... | 368 | 378 | 3 | 392 | 1\n",
"^DX546QX... | 360 | 370 | 3 | 374 | 1\n",
"^B5NPNV8... | 364 | 374 | 4 | 382 | 1\n",
"^VRT1YTS... | 368 | 378 | 3 | 382 | 1\n",
"^QE3WQ0X... | 372 | 382 | 2 | 18446744073709551614 | 1\n",
"^XJDDRJ0... | 376 | 386 | 3 | 18446744073709551614 | 1\n",
"^R0SM1CF... | 380 | 390 | 2 | 18446744073709551614 | 1\n"
Expand Down

0 comments on commit 01e1047

Please sign in to comment.