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 <github.manul@pathway.com>
GitOrigin-RevId: 1c727549b29c6378939b7e0f415c032e93bd39de
  • Loading branch information
@Pathway-Dev
Pathway-Dev and Manul from Pathway committed Sep 16, 2024
1 parent 5d15376 commit 9a7f21e
Show file tree
Hide file tree
Showing 3 changed files with 79 additions and 86 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 | 1726374771526 | 1\n",
"^3CZ78B4... | 2 | 3 | 1726374771728 | 1\n",
"^YYY4HAB... | 6 | 7 | 1726374771728 | 1\n",
"^3HN31E1... | 6 | 7 | 1726374772128 | 1\n",
"^X1MXHYY... | 12 | 13 | 1726374772128 | 1\n"
"^Z3QWT29... | 2 | 3 | 1726461168850 | 1\n",
"^3CZ78B4... | 2 | 3 | 1726461169052 | 1\n",
"^YYY4HAB... | 6 | 7 | 1726461169052 | 1\n",
"^3HN31E1... | 6 | 7 | 1726461169452 | 1\n",
"^X1MXHYY... | 12 | 13 | 1726461169452 | 1\n"
]
}
],
Expand Down Expand Up @@ -410,12 +410,12 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374775406 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374775506 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1726374775506 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374775706 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374775908 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726374775908 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1726461172794 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726461172896 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1726461172896 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726461173096 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726461173296 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726461173296 | 1\n"
]
}
],
Expand Down Expand Up @@ -537,18 +537,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374776140 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726374776140 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374776442 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726374776442 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1726374776442 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1726374776442 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374776542 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726374776542 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374776642 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726374776642 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726374776642 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1726374776642 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1726461173540 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726461173540 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726461173840 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726461173840 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1726461173840 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1726461173840 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726461173940 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726461173940 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726461174040 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726461174040 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726461174040 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1726461174040 | 1\n"
]
}
],
Expand Down Expand Up @@ -581,16 +581,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374776746 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1726374776846 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726374776946 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374777048 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726374777048 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1726374777048 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1726374777048 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374777146 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374777246 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726374777246 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1726461174154 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1726461174254 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726461174356 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726461174456 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726461174456 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1726461174456 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1726461174456 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726461174556 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726461174656 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726461174656 | 1\n"
]
}
],
Expand Down Expand Up @@ -633,18 +633,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374777372 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374777372 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726374777372 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726374777372 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374777872 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374777872 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726374777872 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726374777872 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726374777872 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1726374777872 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1726374777872 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1726374777872 | 1\n"
"^YYY4HAB... | 1 | 5 | 6 | 1726461174774 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726461174774 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726461174774 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726461174774 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726461175274 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726461175274 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726461175274 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726461175274 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726461175274 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1726461175274 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1726461175274 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1726461175274 | 1\n"
]
}
],
Expand Down Expand Up @@ -688,16 +688,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374778018 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726374778018 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726374778320 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726374778320 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374778420 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726374778420 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726374778518 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726374778518 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726374778518 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1726374778518 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1726461175408 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726461175408 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1726461175708 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1726461175708 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726461175810 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726461175810 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1726461175908 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1726461175908 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1726461175908 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1726461175908 | 1\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\":1726374754722}\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1726374754722}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1726374754722}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1726374754722}\r\n"
"{\"data\":\"test1\",\"diff\":1,\"time\":1726461152148}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1726461152148}\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1726461152150}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1726461152150}\r\n"
]
},
{
Expand All @@ -161,8 +161,8 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"data\":\"test1\",\"diff\":1,\"time\":1726374754722}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1726374754722}\r\n"
"{\"data\":\"test1\",\"diff\":1,\"time\":1726461152150}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1726461152150}\r\n"
]
}
],
Expand Down Expand Up @@ -218,8 +218,8 @@
"output_type": "stream",
"text": [
"out3:\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1726374755416}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1726374755416}\r\n"
"{\"data\":\"data2\",\"diff\":1,\"time\":1726461152842}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1726461152842}\r\n"
]
}
],
Expand Down Expand Up @@ -333,10 +333,10 @@
"output_type": "stream",
"text": [
"header1,header2,time,diff\r\n",
"\"data7\",\"data8\",1726374756992,1\r\n",
"\"data1\",\"data2\",1726374756992,1\r\n",
"\"data3\",\"data4\",1726374756992,1\r\n",
"\"data5\",\"data6\",1726374756992,1\r\n"
"\"data7\",\"data8\",1726461154424,1\r\n",
"\"data1\",\"data2\",1726461154424,1\r\n",
"\"data3\",\"data4\",1726461154424,1\r\n",
"\"data5\",\"data6\",1726461154424,1\r\n"
]
}
],
Expand Down Expand Up @@ -450,9 +450,9 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1726374758436}\r\n",
"{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1726374758436}\r\n",
"{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1726374758436}\r\n"
"{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1726461155844}\r\n",
"{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1726461155844}\r\n",
"{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1726461155844}\r\n"
]
}
],
Expand Down Expand Up @@ -521,10 +521,10 @@
"output_type": "stream",
"text": [
"data,time,diff\r\n",
"\"test1\",1726374758848,1\r\n",
"\"data2\",1726374758848,1\r\n",
"\"data1\",1726374758848,1\r\n",
"\"test2\",1726374758848,1\r\n"
"\"test1\",1726461156250,1\r\n",
"\"data2\",1726461156250,1\r\n",
"\"data1\",1726461156250,1\r\n",
"\"test2\",1726461156250,1\r\n"
]
},
{
Expand All @@ -539,8 +539,8 @@
"output_type": "stream",
"text": [
"data,time,diff\r\n",
"\"test2\\ndata2\",1726374758848,1\r\n",
"\"test1\\ndata1\",1726374758848,1\r\n"
"\"test2\\ndata2\",1726461156250,1\r\n",
"\"test1\\ndata1\",1726461156250,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],1726374758848,1\r\n",
"[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1726374758848,1\r\n"
"[116, 101, 115, 116, 50, 10, 100, 97, 116, 97, 50, 10],1726461156250,1\r\n",
"[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1726461156250,1\r\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

0 comments on commit 9a7f21e

Please sign in to comment.