diff --git a/examples/notebooks/tutorials/asynctransformer.ipynb b/examples/notebooks/tutorials/asynctransformer.ipynb index ddc6bdfd..2611efb1 100644 --- a/examples/notebooks/tutorials/asynctransformer.ipynb +++ b/examples/notebooks/tutorials/asynctransformer.ipynb @@ -162,11 +162,11 @@ "output_type": "stream", "text": [ " | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 3 | 1725337968054 | 1\n", - "^3CZ78B4... | 2 | 3 | 1725337968254 | 1\n", - "^YYY4HAB... | 6 | 7 | 1725337968254 | 1\n", - "^3HN31E1... | 6 | 7 | 1725337968656 | 1\n", - "^X1MXHYY... | 12 | 13 | 1725337968656 | 1\n" + "^Z3QWT29... | 2 | 3 | 1725424375496 | 1\n", + "^3CZ78B4... | 2 | 3 | 1725424375698 | 1\n", + "^YYY4HAB... | 6 | 7 | 1725424375698 | 1\n", + "^3HN31E1... | 6 | 7 | 1725424376098 | 1\n", + "^X1MXHYY... | 12 | 13 | 1725424376098 | 1\n" ] } ], @@ -410,12 +410,12 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337972330 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337972430 | -1\n", - "^Z3QWT29... | 2 | 3 | 4 | 1725337972430 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337972632 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337972830 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725337972830 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1725424379536 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1725424379636 | -1\n", + "^Z3QWT29... | 2 | 3 | 4 | 1725424379636 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1725424379836 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1725424380036 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1725424380036 | 1\n" ] } ], @@ -537,18 +537,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337973240 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725337973240 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337973542 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725337973542 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1725337973542 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1725337973542 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337973640 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725337973640 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337973742 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725337973742 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725337973742 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1725337973742 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1725424380280 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1725424380280 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1725424380580 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1725424380580 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1725424380580 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1725424380580 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1725424380680 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1725424380680 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1725424380780 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1725424380780 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1725424380780 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1725424380780 | 1\n" ] } ], @@ -581,16 +581,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337973870 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1725337973970 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725337974072 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337974172 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725337974172 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1725337974172 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1725337974172 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337974270 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337974372 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725337974372 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1725424380932 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1725424381032 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1725424381134 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1725424381234 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1725424381234 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1725424381234 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1725424381234 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1725424381334 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1725424381434 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1725424381434 | 1\n" ] } ], @@ -633,18 +633,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337974498 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337974498 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725337974498 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725337974498 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337975000 | -1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337975000 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725337975000 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725337975000 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725337975000 | 1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1725337975000 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1725337975000 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1725337975000 | 1\n" + "^YYY4HAB... | 1 | 5 | 6 | 1725424381570 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1725424381570 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1725424381570 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1725424381570 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1725424382070 | -1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1725424382070 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1725424382070 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1725424382070 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1725424382070 | 1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1725424382070 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1725424382070 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1725424382070 | 1\n" ] } ], @@ -688,16 +688,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337975130 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725337975130 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725337975430 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725337975430 | -1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337975530 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725337975530 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725337975630 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725337975630 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725337975630 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1725337975630 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1725424382214 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1725424382214 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1725424382514 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1725424382514 | -1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1725424382616 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1725424382616 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1725424382714 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1725424382714 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1725424382714 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1725424382714 | 1\n" ] } ], diff --git a/examples/notebooks/tutorials/fs_connector.ipynb b/examples/notebooks/tutorials/fs_connector.ipynb index c6ccb4c8..36ac1843 100644 --- a/examples/notebooks/tutorials/fs_connector.ipynb +++ b/examples/notebooks/tutorials/fs_connector.ipynb @@ -144,10 +144,10 @@ "name": "stdout", "output_type": "stream", "text": [ - "{\"data\":\"test1\",\"diff\":1,\"time\":1725337951126}\r\n", - "{\"data\":\"data2\",\"diff\":1,\"time\":1725337951126}\r\n", - "{\"data\":\"data1\",\"diff\":1,\"time\":1725337951126}\r\n", - "{\"data\":\"test2\",\"diff\":1,\"time\":1725337951126}\r\n" + "{\"data\":\"test1\",\"diff\":1,\"time\":1725424358618}\r\n", + "{\"data\":\"data2\",\"diff\":1,\"time\":1725424358618}\r\n", + "{\"data\":\"data1\",\"diff\":1,\"time\":1725424358618}\r\n", + "{\"data\":\"test2\",\"diff\":1,\"time\":1725424358618}\r\n" ] }, { @@ -161,8 +161,8 @@ "name": "stdout", "output_type": "stream", "text": [ - "{\"data\":\"test1\",\"diff\":1,\"time\":1725337951126}\r\n", - "{\"data\":\"data1\",\"diff\":1,\"time\":1725337951126}\r\n" + "{\"data\":\"test1\",\"diff\":1,\"time\":1725424358618}\r\n", + "{\"data\":\"data1\",\"diff\":1,\"time\":1725424358618}\r\n" ] } ], @@ -218,8 +218,8 @@ "output_type": "stream", "text": [ "out3:\r\n", - "{\"data\":\"data2\",\"diff\":1,\"time\":1725337951836}\r\n", - "{\"data\":\"test2\",\"diff\":1,\"time\":1725337951836}\r\n" + "{\"data\":\"data2\",\"diff\":1,\"time\":1725424359306}\r\n", + "{\"data\":\"test2\",\"diff\":1,\"time\":1725424359306}\r\n" ] } ], @@ -333,10 +333,10 @@ "output_type": "stream", "text": [ "header1,header2,time,diff\r\n", - "\"data7\",\"data8\",1725337953440,1\r\n", - "\"data1\",\"data2\",1725337953440,1\r\n", - "\"data3\",\"data4\",1725337953440,1\r\n", - "\"data5\",\"data6\",1725337953440,1\r\n" + "\"data7\",\"data8\",1725424360896,1\r\n", + "\"data1\",\"data2\",1725424360896,1\r\n", + "\"data3\",\"data4\",1725424360896,1\r\n", + "\"data5\",\"data6\",1725424360896,1\r\n" ] } ], @@ -450,9 +450,9 @@ "name": "stdout", "output_type": "stream", "text": [ - "{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1725337954896}\r\n", - "{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1725337954896}\r\n", - "{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1725337954896}\r\n" + "{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1725424362338}\r\n", + "{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1725424362338}\r\n", + "{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1725424362338}\r\n" ] } ], @@ -521,10 +521,10 @@ "output_type": "stream", "text": [ "data,time,diff\r\n", - "\"test1\",1725337955304,1\r\n", - "\"data2\",1725337955304,1\r\n", - "\"data1\",1725337955304,1\r\n", - "\"test2\",1725337955304,1\r\n" + "\"test1\",1725424362778,1\r\n", + "\"data2\",1725424362778,1\r\n", + "\"data1\",1725424362778,1\r\n", + "\"test2\",1725424362778,1\r\n" ] }, { @@ -539,8 +539,8 @@ "output_type": "stream", "text": [ "data,time,diff\r\n", - "\"test2\\ndata2\",1725337955304,1\r\n", - "\"test1\\ndata1\",1725337955304,1\r\n" + "\"test2\\ndata2\",1725424362778,1\r\n", + "\"test1\\ndata1\",1725424362778,1\r\n" ] }, { @@ -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],1725337955304,1\r\n", - "[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1725337955304,1\r\n" + "[116, 101, 115, 116, 50, 10, 100, 97, 116, 97, 50, 10],1725424362778,1\r\n", + "[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1725424362778,1\r\n" ] } ],