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: df59bd8ae6d5d54c25c8888a5ef85a18070f81aa
  • Loading branch information
@Pathway-Dev
Pathway-Dev and Manul from Pathway committed Aug 18, 2024
1 parent 197f219 commit dfb0158
Show file tree
Hide file tree
Showing 3 changed files with 93 additions and 87 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 | 1723869167566 | 1\n",
"^3CZ78B4... | 2 | 3 | 1723869167766 | 1\n",
"^YYY4HAB... | 6 | 7 | 1723869167766 | 1\n",
"^3HN31E1... | 6 | 7 | 1723869168168 | 1\n",
"^X1MXHYY... | 12 | 13 | 1723869168168 | 1\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"
]
}
],
Expand Down Expand Up @@ -410,12 +410,12 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869171626 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869171726 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1723869171726 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869171928 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869172128 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723869172128 | 1\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"
]
}
],
Expand Down Expand Up @@ -537,18 +537,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869172454 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723869172454 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869172756 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723869172756 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1723869172756 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1723869172756 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869172856 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723869172856 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869172956 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723869172956 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723869172956 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1723869172956 | 1\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"
]
}
],
Expand Down Expand Up @@ -581,16 +581,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869173106 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1723869173208 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723869173308 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869173408 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723869173408 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1723869173408 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1723869173408 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869173508 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869173608 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723869173608 | 1\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"
]
}
],
Expand Down Expand Up @@ -633,18 +633,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869173772 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869173772 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723869173772 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723869173772 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869174272 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869174272 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723869174272 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723869174272 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723869174272 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1723869174272 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1723869174272 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1723869174272 | 1\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"
]
}
],
Expand Down Expand Up @@ -688,16 +688,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869174408 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723869174408 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1723869174708 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1723869174708 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869174808 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723869174808 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1723869174908 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1723869174908 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1723869174908 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1723869174908 | 1\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"
]
}
],
Expand Down
24 changes: 15 additions & 9 deletions examples/notebooks/tutorials/basic_datatypes.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1110,7 +1110,13 @@
"output_type": "stream",
"text": [
"id | timestamp | values | values_str | diff_values\n",
"ANY_POINTER | INT | INT | STR | Optional(INT)\n",
"ANY_POINTER | INT | INT | STR | Optional(INT)\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"timestamp | values | values_str | diff_values\n",
"1 | 1 | fg |\n",
"2 | 2 | ef | 1\n",
Expand All @@ -1125,20 +1131,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"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"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",
"6 | 16 | ab | 1970-01-01 00:00:00.016000 | 0 days 00:00:00.005000\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"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\":1723869150642}\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1723869150642}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1723869150642}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1723869150642}\r\n"
"{\"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"
]
},
{
Expand All @@ -161,8 +161,8 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"data\":\"test1\",\"diff\":1,\"time\":1723869150642}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1723869150642}\r\n"
"{\"data\":\"test1\",\"diff\":1,\"time\":1723955562580}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1723955562580}\r\n"
]
}
],
Expand Down Expand Up @@ -218,8 +218,8 @@
"output_type": "stream",
"text": [
"out3:\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1723869151346}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1723869151346}\r\n"
"{\"data\":\"data2\",\"diff\":1,\"time\":1723955563352}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1723955563352}\r\n"
]
}
],
Expand Down Expand Up @@ -333,10 +333,10 @@
"output_type": "stream",
"text": [
"header1,header2,time,diff\r\n",
"\"data7\",\"data8\",1723869152934,1\r\n",
"\"data1\",\"data2\",1723869152934,1\r\n",
"\"data3\",\"data4\",1723869152934,1\r\n",
"\"data5\",\"data6\",1723869152934,1\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"
]
}
],
Expand Down Expand Up @@ -450,9 +450,9 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1723869154384}\r\n",
"{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1723869154384}\r\n",
"{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1723869154384}\r\n"
"{\"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"
]
}
],
Expand Down Expand Up @@ -521,10 +521,10 @@
"output_type": "stream",
"text": [
"data,time,diff\r\n",
"\"test1\",1723869154814,1\r\n",
"\"data2\",1723869154814,1\r\n",
"\"data1\",1723869154814,1\r\n",
"\"test2\",1723869154814,1\r\n"
"\"test1\",1723955566858,1\r\n",
"\"data2\",1723955566858,1\r\n",
"\"data1\",1723955566858,1\r\n",
"\"test2\",1723955566858,1\r\n"
]
},
{
Expand All @@ -539,8 +539,8 @@
"output_type": "stream",
"text": [
"data,time,diff\r\n",
"\"test2\\ndata2\",1723869154814,1\r\n",
"\"test1\\ndata1\",1723869154814,1\r\n"
"\"test2\\ndata2\",1723955566858,1\r\n",
"\"test1\\ndata1\",1723955566858,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],1723869154814,1\r\n",
"[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1723869154814,1\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"
]
}
],
Expand Down

0 comments on commit dfb0158

Please sign in to comment.