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: 1e4b88e29dd284afd4e442fd46ccae1615137b20
  • Loading branch information
@Pathway-Dev
Pathway-Dev and Manul from Pathway committed Aug 19, 2024
1 parent dfb0158 commit bc7c0db
Show file tree
Hide file tree
Showing 4 changed files with 89 additions and 94 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 | 1723955579686 | 1\n",
"^3CZ78B4... | 2 | 3 | 1723955579886 | 1\n",
"^YYY4HAB... | 6 | 7 | 1723955579886 | 1\n",
"^3HN31E1... | 6 | 7 | 1723955580286 | 1\n",
"^X1MXHYY... | 12 | 13 | 1723955580286 | 1\n"
"^Z3QWT29... | 2 | 3 | 1724041978844 | 1\n",
"^3CZ78B4... | 2 | 3 | 1724041979044 | 1\n",
"^YYY4HAB... | 6 | 7 | 1724041979044 | 1\n",
"^3HN31E1... | 6 | 7 | 1724041979446 | 1\n",
"^X1MXHYY... | 12 | 13 | 1724041979446 | 1\n"
]
}
],
Expand Down Expand Up @@ -410,12 +410,12 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955583764 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955583864 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1723955583864 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955584064 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955584264 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723955584264 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1724041982996 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1724041983096 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1724041983096 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1724041983296 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1724041983498 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1724041983498 | 1\n"
]
}
],
Expand Down Expand Up @@ -537,18 +537,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955584514 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723955584514 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955584814 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723955584814 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1723955584814 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1723955584814 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955584914 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723955584914 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955585014 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723955585014 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723955585014 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1723955585014 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1724041983754 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1724041983754 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1724041984054 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1724041984054 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1724041984054 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1724041984054 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1724041984154 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1724041984154 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1724041984254 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1724041984254 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1724041984254 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1724041984254 | 1\n"
]
}
],
Expand Down Expand Up @@ -581,16 +581,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955585148 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1723955585248 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723955585348 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955585448 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723955585448 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1723955585448 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1723955585448 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955585548 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955585648 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723955585648 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1724041984390 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1724041984490 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1724041984590 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1724041984690 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1724041984690 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1724041984690 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1724041984690 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1724041984790 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1724041984890 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1724041984890 | 1\n"
]
}
],
Expand Down Expand Up @@ -633,18 +633,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955585814 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955585814 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723955585814 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723955585814 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955586314 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955586314 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723955586314 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723955586314 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723955586314 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1723955586314 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1723955586314 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1723955586314 | 1\n"
"^YYY4HAB... | 1 | 5 | 6 | 1724041985042 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1724041985042 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1724041985042 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1724041985042 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1724041985542 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1724041985542 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1724041985542 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1724041985542 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1724041985542 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1724041985542 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1724041985542 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1724041985542 | 1\n"
]
}
],
Expand Down Expand Up @@ -688,16 +688,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955586468 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723955586468 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723955586770 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723955586770 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955586870 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723955586870 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723955586970 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723955586970 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723955586970 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1723955586970 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1724041985704 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1724041985704 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1724041986004 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1724041986004 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1724041986104 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1724041986104 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1724041986204 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1724041986204 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1724041986204 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1724041986204 | 1\n"
]
}
],
Expand Down
24 changes: 9 additions & 15 deletions examples/notebooks/tutorials/basic_datatypes.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1110,13 +1110,7 @@
"output_type": "stream",
"text": [
"id | timestamp | values | values_str | diff_values\n",
"ANY_POINTER | INT | INT | STR | Optional(INT)\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"ANY_POINTER | INT | INT | STR | Optional(INT)\n",
"timestamp | values | values_str | diff_values\n",
"1 | 1 | fg |\n",
"2 | 2 | ef | 1\n",
Expand All @@ -1131,20 +1125,20 @@
"output_type": "stream",
"text": [
"id | timestamp | values | values_str | date | diff_date\n",
"ANY_POINTER | INT | INT | STR | DATE_TIME_NAIVE | Optional(DURATION)\n",
"timestamp | values | values_str | date | diff_date\n",
"1 | 1 | fg | 1970-01-01 00:00:00.001000 |\n",
"2 | 2 | ef | 1970-01-01 00:00:00.002000 | 0 days 00:00:00.001000\n",
"3 | 4 | de | 1970-01-01 00:00:00.004000 | 0 days 00:00:00.002000\n",
"4 | 7 | cd | 1970-01-01 00:00:00.007000 | 0 days 00:00:00.003000\n",
"5 | 11 | bc | 1970-01-01 00:00:00.011000 | 0 days 00:00:00.004000\n",
"6 | 16 | ab | 1970-01-01 00:00:00.016000 | 0 days 00:00:00.005000\n"
"ANY_POINTER | INT | INT | STR | DATE_TIME_NAIVE | Optional(DURATION)\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"timestamp | values | values_str | date | diff_date\n",
"1 | 1 | fg | 1970-01-01 00:00:00.001000 |\n",
"2 | 2 | ef | 1970-01-01 00:00:00.002000 | 0 days 00:00:00.001000\n",
"3 | 4 | de | 1970-01-01 00:00:00.004000 | 0 days 00:00:00.002000\n",
"4 | 7 | cd | 1970-01-01 00:00:00.007000 | 0 days 00:00:00.003000\n",
"5 | 11 | bc | 1970-01-01 00:00:00.011000 | 0 days 00:00:00.004000\n",
"6 | 16 | ab | 1970-01-01 00:00:00.016000 | 0 days 00:00:00.005000\n",
"id | timestamp | values | values_str | date | diff_values\n",
"ANY_POINTER | INT | INT | STR | DATE_TIME_NAIVE | Optional(INT)\n"
]
Expand Down
46 changes: 23 additions & 23 deletions examples/notebooks/tutorials/fs_connector.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -144,10 +144,10 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"data\":\"test1\",\"diff\":1,\"time\":1723955562580}\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1723955562580}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1723955562580}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1723955562580}\r\n"
"{\"data\":\"test1\",\"diff\":1,\"time\":1724041961870}\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1724041961870}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1724041961870}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1724041961870}\r\n"
]
},
{
Expand All @@ -161,8 +161,8 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"data\":\"test1\",\"diff\":1,\"time\":1723955562580}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1723955562580}\r\n"
"{\"data\":\"test1\",\"diff\":1,\"time\":1724041961872}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1724041961872}\r\n"
]
}
],
Expand Down Expand Up @@ -218,8 +218,8 @@
"output_type": "stream",
"text": [
"out3:\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1723955563352}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1723955563352}\r\n"
"{\"data\":\"data2\",\"diff\":1,\"time\":1724041962598}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1724041962598}\r\n"
]
}
],
Expand Down Expand Up @@ -333,10 +333,10 @@
"output_type": "stream",
"text": [
"header1,header2,time,diff\r\n",
"\"data7\",\"data8\",1723955564960,1\r\n",
"\"data1\",\"data2\",1723955564960,1\r\n",
"\"data3\",\"data4\",1723955564960,1\r\n",
"\"data5\",\"data6\",1723955564960,1\r\n"
"\"data7\",\"data8\",1724041964166,1\r\n",
"\"data1\",\"data2\",1724041964166,1\r\n",
"\"data3\",\"data4\",1724041964166,1\r\n",
"\"data5\",\"data6\",1724041964166,1\r\n"
]
}
],
Expand Down Expand Up @@ -450,9 +450,9 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1723955566412}\r\n",
"{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1723955566412}\r\n",
"{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1723955566412}\r\n"
"{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1724041965614}\r\n",
"{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1724041965614}\r\n",
"{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1724041965614}\r\n"
]
}
],
Expand Down Expand Up @@ -521,10 +521,10 @@
"output_type": "stream",
"text": [
"data,time,diff\r\n",
"\"test1\",1723955566858,1\r\n",
"\"data2\",1723955566858,1\r\n",
"\"data1\",1723955566858,1\r\n",
"\"test2\",1723955566858,1\r\n"
"\"test1\",1724041966042,1\r\n",
"\"data2\",1724041966042,1\r\n",
"\"data1\",1724041966042,1\r\n",
"\"test2\",1724041966042,1\r\n"
]
},
{
Expand All @@ -539,8 +539,8 @@
"output_type": "stream",
"text": [
"data,time,diff\r\n",
"\"test2\\ndata2\",1723955566858,1\r\n",
"\"test1\\ndata1\",1723955566858,1\r\n"
"\"test2\\ndata2\",1724041966042,1\r\n",
"\"test1\\ndata1\",1724041966042,1\r\n"
]
},
{
Expand All @@ -555,8 +555,8 @@
"output_type": "stream",
"text": [
"data,time,diff\r\n",
"[116, 101, 115, 116, 50, 10, 100, 97, 116, 97, 50, 10],1723955566858,1\r\n",
"[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1723955566858,1\r\n"
"[116, 101, 115, 116, 50, 10, 100, 97, 116, 97, 50, 10],1724041966042,1\r\n",
"[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1724041966042,1\r\n"
]
}
],
Expand Down
3 changes: 2 additions & 1 deletion examples/notebooks/tutorials/iterate.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -241,7 +241,8 @@
"name": "stdout",
"output_type": "stream",
"text": [
" | a | b | c | x0 | x\n",
" | a | b | c | x0 | x",
"\n",
"^X1MXHYY... | -2 | 1 | 1 | 0 | -0.4655712318767681\n",
"^YYY4HAB... | -2 | 1 | 1 | 2 | -0.4655712318767681\n",
"^Z3QWT29... | -1 | -2 | 1 | 0 | 0.4450418679126288\n",
Expand Down

0 comments on commit bc7c0db

Please sign in to comment.