From 836df73f346332a9d62c87380063e4d79de724d0 Mon Sep 17 00:00:00 2001 From: Anton Mishchuk Date: Mon, 22 Apr 2024 18:31:56 +0200 Subject: [PATCH] Set @buffer to 1 by default --- .gitignore | 5 +- README.md | 2 +- lib/gen_mix.ex | 2 +- lib/transformer.ex | 2 +- test/examples/parcels/all_parcels_shipped.csv | 194 +++--- test/examples/parcels/orders.csv | 200 +++--- test/examples/parcels/parcels.csv | 601 +++++++++--------- test/examples/parcels/threshold_exceeded.csv | 6 +- test/examples/parcels_test.exs | 4 +- 9 files changed, 524 insertions(+), 492 deletions(-) diff --git a/.gitignore b/.gitignore index d25f8aa..483f397 100644 --- a/.gitignore +++ b/.gitignore @@ -25,5 +25,6 @@ strom-*.tar # Temporary files, for example, from tests. /tmp/ -.DS_Store -test_data \ No newline at end of file +/test/examples/parcels/*.csv + +.DS_Store \ No newline at end of file diff --git a/README.md b/README.md index a75abd8..f7f569e 100644 --- a/README.md +++ b/README.md @@ -37,7 +37,7 @@ io_gets = Strom.Source.IOGets.new() source = :stream |> Strom.Source.new(io_gets) function = fn string -> "Hello, #{string}!" end -transformer = :stream |> Strom.Transformer.new(function, nil, buffer: 1) +transformer = :stream |> Strom.Transformer.new(function) io_puts = Strom.Sink.IOPuts.new() sink = :stream |> Strom.Sink.new(io_puts, true) diff --git a/lib/gen_mix.ex b/lib/gen_mix.ex index 21f0116..0dbceda 100644 --- a/lib/gen_mix.ex +++ b/lib/gen_mix.ex @@ -5,7 +5,7 @@ defmodule Strom.GenMix do use GenServer - @buffer 1000 + @buffer 1 defstruct pid: nil, inputs: [], diff --git a/lib/transformer.ex b/lib/transformer.ex index a3a3293..51fc3fb 100644 --- a/lib/transformer.ex +++ b/lib/transformer.ex @@ -31,7 +31,7 @@ defmodule Strom.Transformer do use GenServer - @buffer 1000 + @buffer 1 defstruct pid: nil, running: false, diff --git a/test/examples/parcels/all_parcels_shipped.csv b/test/examples/parcels/all_parcels_shipped.csv index 88ba142..8a91477 100644 --- a/test/examples/parcels/all_parcels_shipped.csv +++ b/test/examples/parcels/all_parcels_shipped.csv @@ -1,98 +1,96 @@ -ALL_PARCELS_SHIPPED,1,2023-12-18 19:34:16.674638Z -ALL_PARCELS_SHIPPED,2,2023-12-18 02:25:53.674638Z -ALL_PARCELS_SHIPPED,3,2023-12-18 10:53:23.674638Z -ALL_PARCELS_SHIPPED,4,2023-12-17 16:46:43.674638Z -ALL_PARCELS_SHIPPED,5,2023-12-19 05:11:17.674638Z -ALL_PARCELS_SHIPPED,6,2023-12-19 00:31:08.674638Z -ALL_PARCELS_SHIPPED,7,2023-12-17 22:23:31.674638Z -ALL_PARCELS_SHIPPED,8,2023-12-18 17:01:25.674638Z -ALL_PARCELS_SHIPPED,9,2023-12-17 17:42:56.674638Z -ALL_PARCELS_SHIPPED,10,2023-12-19 01:26:58.674638Z -ALL_PARCELS_SHIPPED,11,2023-12-18 03:21:44.674638Z -ALL_PARCELS_SHIPPED,12,2023-12-17 23:28:10.674638Z -ALL_PARCELS_SHIPPED,13,2023-12-18 16:38:27.674638Z -ALL_PARCELS_SHIPPED,14,2023-12-17 14:53:21.674638Z -ALL_PARCELS_SHIPPED,15,2023-12-17 13:59:55.674638Z -ALL_PARCELS_SHIPPED,16,2023-12-18 10:32:38.674638Z -ALL_PARCELS_SHIPPED,17,2023-12-18 08:10:32.674638Z -ALL_PARCELS_SHIPPED,18,2023-12-17 15:22:07.674638Z -ALL_PARCELS_SHIPPED,19,2023-12-18 01:38:06.674638Z -ALL_PARCELS_SHIPPED,20,2023-12-17 19:59:47.674638Z -ALL_PARCELS_SHIPPED,21,2023-12-18 05:20:09.674638Z -ALL_PARCELS_SHIPPED,22,2023-12-17 11:38:40.674638Z -ALL_PARCELS_SHIPPED,23,2023-12-17 20:38:51.674638Z -ALL_PARCELS_SHIPPED,24,2023-12-17 15:16:58.674638Z -ALL_PARCELS_SHIPPED,25,2023-12-18 10:10:02.674638Z -ALL_PARCELS_SHIPPED,26,2023-12-18 06:49:07.674638Z -ALL_PARCELS_SHIPPED,27,2023-12-18 01:59:58.674638Z -ALL_PARCELS_SHIPPED,28,2023-12-17 09:00:32.674638Z -ALL_PARCELS_SHIPPED,29,2023-12-19 01:42:07.674638Z -ALL_PARCELS_SHIPPED,30,2023-12-18 17:02:21.674638Z -ALL_PARCELS_SHIPPED,31,2023-12-18 15:28:26.674638Z -ALL_PARCELS_SHIPPED,32,2023-12-18 21:17:00.674638Z -ALL_PARCELS_SHIPPED,33,2023-12-18 17:49:57.674638Z -ALL_PARCELS_SHIPPED,34,2023-12-17 15:02:56.674638Z -ALL_PARCELS_SHIPPED,35,2023-12-19 08:07:52.674638Z -ALL_PARCELS_SHIPPED,36,2023-12-17 10:06:25.674638Z -ALL_PARCELS_SHIPPED,37,2023-12-17 14:51:16.674638Z -ALL_PARCELS_SHIPPED,38,2023-12-19 01:13:37.674638Z -ALL_PARCELS_SHIPPED,39,2023-12-18 08:10:00.674638Z -ALL_PARCELS_SHIPPED,40,2023-12-17 10:07:38.674638Z -ALL_PARCELS_SHIPPED,41,2023-12-19 07:01:44.674638Z -ALL_PARCELS_SHIPPED,42,2023-12-18 18:37:51.674638Z -ALL_PARCELS_SHIPPED,43,2023-12-17 21:45:44.674638Z -ALL_PARCELS_SHIPPED,44,2023-12-18 16:53:27.674638Z -ALL_PARCELS_SHIPPED,45,2023-12-17 09:24:06.674638Z -ALL_PARCELS_SHIPPED,46,2023-12-17 17:02:04.674638Z -ALL_PARCELS_SHIPPED,47,2023-12-17 20:44:04.674638Z -ALL_PARCELS_SHIPPED,48,2023-12-19 07:43:15.674638Z -ALL_PARCELS_SHIPPED,49,2023-12-18 12:17:16.674638Z -ALL_PARCELS_SHIPPED,50,2023-12-17 13:34:45.674638Z -ALL_PARCELS_SHIPPED,51,2023-12-18 07:26:25.674638Z -ALL_PARCELS_SHIPPED,52,2023-12-18 01:34:05.674638Z -ALL_PARCELS_SHIPPED,53,2023-12-18 16:58:53.674638Z -ALL_PARCELS_SHIPPED,54,2023-12-19 03:20:33.674638Z -ALL_PARCELS_SHIPPED,55,2023-12-18 08:30:36.674638Z -ALL_PARCELS_SHIPPED,56,2023-12-18 04:07:13.674638Z -ALL_PARCELS_SHIPPED,57,2023-12-18 16:58:20.674638Z -ALL_PARCELS_SHIPPED,58,2023-12-18 10:19:21.674638Z -ALL_PARCELS_SHIPPED,59,2023-12-19 06:55:37.674638Z -ALL_PARCELS_SHIPPED,60,2023-12-18 02:21:00.674638Z -ALL_PARCELS_SHIPPED,61,2023-12-19 01:48:17.674638Z -ALL_PARCELS_SHIPPED,62,2023-12-18 21:30:26.674638Z -ALL_PARCELS_SHIPPED,63,2023-12-18 20:39:08.674638Z -ALL_PARCELS_SHIPPED,64,2023-12-18 02:49:28.674638Z -ALL_PARCELS_SHIPPED,65,2023-12-19 01:23:41.674638Z -ALL_PARCELS_SHIPPED,66,2023-12-18 23:47:49.674638Z -ALL_PARCELS_SHIPPED,67,2023-12-17 19:13:57.674638Z -ALL_PARCELS_SHIPPED,68,2023-12-19 03:12:43.674638Z -ALL_PARCELS_SHIPPED,69,2023-12-18 22:03:11.674638Z -ALL_PARCELS_SHIPPED,70,2023-12-19 00:11:56.674638Z -ALL_PARCELS_SHIPPED,71,2023-12-17 16:35:16.674638Z -ALL_PARCELS_SHIPPED,72,2023-12-18 12:11:39.674638Z -ALL_PARCELS_SHIPPED,73,2023-12-17 10:31:15.674638Z -ALL_PARCELS_SHIPPED,74,2023-12-18 16:33:11.674638Z -ALL_PARCELS_SHIPPED,75,2023-12-18 08:27:04.674638Z -ALL_PARCELS_SHIPPED,76,2023-12-17 17:03:57.674638Z -ALL_PARCELS_SHIPPED,77,2023-12-18 14:19:04.674638Z -ALL_PARCELS_SHIPPED,78,2023-12-18 20:06:17.674638Z -ALL_PARCELS_SHIPPED,79,2023-12-18 03:46:15.674638Z -ALL_PARCELS_SHIPPED,80,2023-12-17 23:23:28.674638Z -ALL_PARCELS_SHIPPED,81,2023-12-18 00:59:17.674638Z -ALL_PARCELS_SHIPPED,83,2023-12-18 02:52:26.674638Z -ALL_PARCELS_SHIPPED,84,2023-12-19 04:17:45.674638Z -ALL_PARCELS_SHIPPED,85,2023-12-18 13:07:44.674638Z -ALL_PARCELS_SHIPPED,86,2023-12-19 03:08:28.674638Z -ALL_PARCELS_SHIPPED,87,2023-12-18 16:00:08.674638Z -ALL_PARCELS_SHIPPED,88,2023-12-17 10:18:40.674638Z -ALL_PARCELS_SHIPPED,89,2023-12-17 17:53:19.674638Z -ALL_PARCELS_SHIPPED,90,2023-12-17 13:27:46.674638Z -ALL_PARCELS_SHIPPED,91,2023-12-18 12:56:11.674638Z -ALL_PARCELS_SHIPPED,92,2023-12-17 12:09:09.674638Z -ALL_PARCELS_SHIPPED,94,2023-12-18 18:04:56.674638Z -ALL_PARCELS_SHIPPED,95,2023-12-18 08:44:00.674638Z -ALL_PARCELS_SHIPPED,96,2023-12-17 21:33:36.674638Z -ALL_PARCELS_SHIPPED,97,2023-12-17 22:49:14.674638Z -ALL_PARCELS_SHIPPED,98,2023-12-18 10:28:07.674638Z -ALL_PARCELS_SHIPPED,99,2023-12-17 15:52:47.674638Z -ALL_PARCELS_SHIPPED,100,2023-12-17 18:57:55.674638Z +ALL_PARCELS_SHIPPED,1,2024-03-24 17:33:15.764232Z +ALL_PARCELS_SHIPPED,2,2024-03-24 10:07:32.764232Z +ALL_PARCELS_SHIPPED,3,2024-03-24 19:15:50.764232Z +ALL_PARCELS_SHIPPED,4,2024-03-25 04:26:47.764232Z +ALL_PARCELS_SHIPPED,5,2024-03-24 05:38:15.764232Z +ALL_PARCELS_SHIPPED,6,2024-03-23 19:36:05.764232Z +ALL_PARCELS_SHIPPED,7,2024-03-25 02:23:26.764232Z +ALL_PARCELS_SHIPPED,8,2024-03-23 22:00:24.764232Z +ALL_PARCELS_SHIPPED,9,2024-03-24 07:25:29.764232Z +ALL_PARCELS_SHIPPED,10,2024-03-24 06:44:47.764232Z +ALL_PARCELS_SHIPPED,11,2024-03-25 05:48:47.764232Z +ALL_PARCELS_SHIPPED,12,2024-03-25 05:57:34.764232Z +ALL_PARCELS_SHIPPED,13,2024-03-24 11:32:02.764232Z +ALL_PARCELS_SHIPPED,14,2024-03-25 00:59:42.764232Z +ALL_PARCELS_SHIPPED,15,2024-03-24 15:45:19.764232Z +ALL_PARCELS_SHIPPED,16,2024-03-24 21:01:38.764232Z +ALL_PARCELS_SHIPPED,17,2024-03-24 18:52:54.764232Z +ALL_PARCELS_SHIPPED,18,2024-03-24 21:47:20.764232Z +ALL_PARCELS_SHIPPED,19,2024-03-25 02:37:32.764232Z +ALL_PARCELS_SHIPPED,20,2024-03-24 18:47:44.764232Z +ALL_PARCELS_SHIPPED,21,2024-03-24 14:52:51.764232Z +ALL_PARCELS_SHIPPED,22,2024-03-24 06:32:28.764232Z +ALL_PARCELS_SHIPPED,23,2024-03-23 23:24:15.764232Z +ALL_PARCELS_SHIPPED,24,2024-03-25 09:30:03.764232Z +ALL_PARCELS_SHIPPED,25,2024-03-24 18:07:49.764232Z +ALL_PARCELS_SHIPPED,26,2024-03-25 07:09:28.764232Z +ALL_PARCELS_SHIPPED,27,2024-03-24 01:10:40.764232Z +ALL_PARCELS_SHIPPED,28,2024-03-23 18:32:43.764232Z +ALL_PARCELS_SHIPPED,29,2024-03-25 05:40:13.764232Z +ALL_PARCELS_SHIPPED,30,2024-03-25 11:34:15.764232Z +ALL_PARCELS_SHIPPED,31,2024-03-25 11:12:24.764232Z +ALL_PARCELS_SHIPPED,32,2024-03-24 07:49:52.764232Z +ALL_PARCELS_SHIPPED,33,2024-03-23 22:01:23.764232Z +ALL_PARCELS_SHIPPED,34,2024-03-24 16:27:31.764232Z +ALL_PARCELS_SHIPPED,35,2024-03-25 13:35:26.764232Z +ALL_PARCELS_SHIPPED,36,2024-03-24 01:19:43.764232Z +ALL_PARCELS_SHIPPED,37,2024-03-23 18:55:10.764232Z +ALL_PARCELS_SHIPPED,38,2024-03-24 16:45:11.764232Z +ALL_PARCELS_SHIPPED,39,2024-03-25 05:35:35.764232Z +ALL_PARCELS_SHIPPED,40,2024-03-23 19:19:36.764232Z +ALL_PARCELS_SHIPPED,42,2024-03-24 21:00:11.764232Z +ALL_PARCELS_SHIPPED,43,2024-03-25 07:29:40.764232Z +ALL_PARCELS_SHIPPED,44,2024-03-24 14:04:29.764232Z +ALL_PARCELS_SHIPPED,45,2024-03-24 14:54:48.764232Z +ALL_PARCELS_SHIPPED,46,2024-03-25 04:53:46.764232Z +ALL_PARCELS_SHIPPED,47,2024-03-23 17:57:38.764232Z +ALL_PARCELS_SHIPPED,48,2024-03-24 10:50:10.764232Z +ALL_PARCELS_SHIPPED,49,2024-03-25 09:18:25.764232Z +ALL_PARCELS_SHIPPED,50,2024-03-24 10:28:12.764232Z +ALL_PARCELS_SHIPPED,51,2024-03-24 19:05:32.764232Z +ALL_PARCELS_SHIPPED,52,2024-03-23 17:17:57.764232Z +ALL_PARCELS_SHIPPED,53,2024-03-25 06:46:12.764232Z +ALL_PARCELS_SHIPPED,54,2024-03-25 13:46:40.764232Z +ALL_PARCELS_SHIPPED,55,2024-03-23 17:17:24.764232Z +ALL_PARCELS_SHIPPED,58,2024-03-25 12:05:02.764232Z +ALL_PARCELS_SHIPPED,59,2024-03-24 16:09:13.764232Z +ALL_PARCELS_SHIPPED,60,2024-03-25 01:37:31.764232Z +ALL_PARCELS_SHIPPED,61,2024-03-24 22:45:04.764232Z +ALL_PARCELS_SHIPPED,62,2024-03-24 07:18:31.764232Z +ALL_PARCELS_SHIPPED,63,2024-03-25 04:26:55.764232Z +ALL_PARCELS_SHIPPED,64,2024-03-24 12:55:27.764232Z +ALL_PARCELS_SHIPPED,65,2024-03-25 12:20:21.764232Z +ALL_PARCELS_SHIPPED,66,2024-03-24 18:57:55.764232Z +ALL_PARCELS_SHIPPED,67,2024-03-24 10:39:43.764232Z +ALL_PARCELS_SHIPPED,68,2024-03-24 06:43:28.764232Z +ALL_PARCELS_SHIPPED,69,2024-03-24 09:12:36.764232Z +ALL_PARCELS_SHIPPED,70,2024-03-24 19:07:12.764232Z +ALL_PARCELS_SHIPPED,72,2024-03-24 18:37:32.764232Z +ALL_PARCELS_SHIPPED,73,2024-03-24 18:02:32.764232Z +ALL_PARCELS_SHIPPED,74,2024-03-24 17:13:35.764232Z +ALL_PARCELS_SHIPPED,75,2024-03-24 06:30:29.764232Z +ALL_PARCELS_SHIPPED,76,2024-03-24 19:06:09.764232Z +ALL_PARCELS_SHIPPED,77,2024-03-25 11:55:05.764232Z +ALL_PARCELS_SHIPPED,78,2024-03-25 07:01:31.764232Z +ALL_PARCELS_SHIPPED,79,2024-03-24 21:15:53.764232Z +ALL_PARCELS_SHIPPED,80,2024-03-24 11:12:53.764232Z +ALL_PARCELS_SHIPPED,81,2024-03-24 20:10:07.764232Z +ALL_PARCELS_SHIPPED,82,2024-03-24 09:22:36.764232Z +ALL_PARCELS_SHIPPED,83,2024-03-24 22:29:10.764232Z +ALL_PARCELS_SHIPPED,84,2024-03-25 00:05:00.764232Z +ALL_PARCELS_SHIPPED,85,2024-03-25 06:45:57.764232Z +ALL_PARCELS_SHIPPED,86,2024-03-25 15:28:57.764232Z +ALL_PARCELS_SHIPPED,87,2024-03-24 16:38:56.764232Z +ALL_PARCELS_SHIPPED,88,2024-03-25 00:44:52.764232Z +ALL_PARCELS_SHIPPED,89,2024-03-23 17:47:04.764232Z +ALL_PARCELS_SHIPPED,90,2024-03-23 21:02:56.764232Z +ALL_PARCELS_SHIPPED,91,2024-03-24 02:55:28.764232Z +ALL_PARCELS_SHIPPED,92,2024-03-25 12:40:02.764232Z +ALL_PARCELS_SHIPPED,93,2024-03-24 00:57:07.764232Z +ALL_PARCELS_SHIPPED,94,2024-03-25 07:57:09.764232Z +ALL_PARCELS_SHIPPED,95,2024-03-25 11:22:21.764232Z +ALL_PARCELS_SHIPPED,96,2024-03-24 17:02:32.764232Z +ALL_PARCELS_SHIPPED,97,2024-03-23 20:58:20.764232Z +ALL_PARCELS_SHIPPED,98,2024-03-25 01:05:36.764232Z +ALL_PARCELS_SHIPPED,99,2024-03-23 23:28:07.764232Z +ALL_PARCELS_SHIPPED,100,2024-03-24 17:18:29.764232Z diff --git a/test/examples/parcels/orders.csv b/test/examples/parcels/orders.csv index ce5c0f9..857c2db 100644 --- a/test/examples/parcels/orders.csv +++ b/test/examples/parcels/orders.csv @@ -1,100 +1,100 @@ -ORDER_CREATED,2023-12-17T08:27:29.674638Z,1,2 -ORDER_CREATED,2023-12-17T08:27:30.674638Z,2,4 -ORDER_CREATED,2023-12-17T08:27:32.674638Z,3,1 -ORDER_CREATED,2023-12-17T08:27:33.674638Z,4,1 -ORDER_CREATED,2023-12-17T08:27:40.674638Z,5,5 -ORDER_CREATED,2023-12-17T08:27:44.674638Z,6,2 -ORDER_CREATED,2023-12-17T08:27:47.674638Z,7,5 -ORDER_CREATED,2023-12-17T08:27:53.674638Z,8,2 -ORDER_CREATED,2023-12-17T08:27:54.674638Z,9,4 -ORDER_CREATED,2023-12-17T08:28:03.674638Z,10,4 -ORDER_CREATED,2023-12-17T08:28:11.674638Z,11,1 -ORDER_CREATED,2023-12-17T08:28:19.674638Z,12,5 -ORDER_CREATED,2023-12-17T08:28:25.674638Z,13,3 -ORDER_CREATED,2023-12-17T08:28:28.674638Z,14,3 -ORDER_CREATED,2023-12-17T08:28:31.674638Z,15,4 -ORDER_CREATED,2023-12-17T08:28:35.674638Z,16,5 -ORDER_CREATED,2023-12-17T08:28:41.674638Z,17,1 -ORDER_CREATED,2023-12-17T08:28:42.674638Z,18,1 -ORDER_CREATED,2023-12-17T08:28:51.674638Z,19,3 -ORDER_CREATED,2023-12-17T08:28:52.674638Z,20,3 -ORDER_CREATED,2023-12-17T08:29:02.674638Z,21,1 -ORDER_CREATED,2023-12-17T08:29:10.674638Z,22,3 -ORDER_CREATED,2023-12-17T08:29:12.674638Z,23,5 -ORDER_CREATED,2023-12-17T08:29:18.674638Z,24,3 -ORDER_CREATED,2023-12-17T08:29:22.674638Z,25,3 -ORDER_CREATED,2023-12-17T08:29:30.674638Z,26,2 -ORDER_CREATED,2023-12-17T08:29:32.674638Z,27,1 -ORDER_CREATED,2023-12-17T08:29:41.674638Z,28,1 -ORDER_CREATED,2023-12-17T08:29:42.674638Z,29,1 -ORDER_CREATED,2023-12-17T08:29:46.674638Z,30,1 -ORDER_CREATED,2023-12-17T08:29:55.674638Z,31,5 -ORDER_CREATED,2023-12-17T08:29:56.674638Z,32,2 -ORDER_CREATED,2023-12-17T08:30:06.674638Z,33,1 -ORDER_CREATED,2023-12-17T08:30:08.674638Z,34,2 -ORDER_CREATED,2023-12-17T08:30:16.674638Z,35,3 -ORDER_CREATED,2023-12-17T08:30:21.674638Z,36,5 -ORDER_CREATED,2023-12-17T08:30:28.674638Z,37,3 -ORDER_CREATED,2023-12-17T08:30:33.674638Z,38,5 -ORDER_CREATED,2023-12-17T08:30:40.674638Z,39,1 -ORDER_CREATED,2023-12-17T08:30:45.674638Z,40,2 -ORDER_CREATED,2023-12-17T08:30:48.674638Z,41,2 -ORDER_CREATED,2023-12-17T08:30:54.674638Z,42,5 -ORDER_CREATED,2023-12-17T08:30:58.674638Z,43,4 -ORDER_CREATED,2023-12-17T08:31:04.674638Z,44,2 -ORDER_CREATED,2023-12-17T08:31:08.674638Z,45,3 -ORDER_CREATED,2023-12-17T08:31:16.674638Z,46,2 -ORDER_CREATED,2023-12-17T08:31:24.674638Z,47,4 -ORDER_CREATED,2023-12-17T08:31:32.674638Z,48,2 -ORDER_CREATED,2023-12-17T08:31:41.674638Z,49,3 -ORDER_CREATED,2023-12-17T08:31:47.674638Z,50,5 -ORDER_CREATED,2023-12-17T08:31:53.674638Z,51,3 -ORDER_CREATED,2023-12-17T08:32:02.674638Z,52,2 -ORDER_CREATED,2023-12-17T08:32:05.674638Z,53,2 -ORDER_CREATED,2023-12-17T08:32:15.674638Z,54,4 -ORDER_CREATED,2023-12-17T08:32:24.674638Z,55,4 -ORDER_CREATED,2023-12-17T08:32:34.674638Z,56,1 -ORDER_CREATED,2023-12-17T08:32:36.674638Z,57,1 -ORDER_CREATED,2023-12-17T08:32:39.674638Z,58,3 -ORDER_CREATED,2023-12-17T08:32:42.674638Z,59,2 -ORDER_CREATED,2023-12-17T08:32:44.674638Z,60,4 -ORDER_CREATED,2023-12-17T08:32:50.674638Z,61,1 -ORDER_CREATED,2023-12-17T08:32:55.674638Z,62,2 -ORDER_CREATED,2023-12-17T08:32:57.674638Z,63,1 -ORDER_CREATED,2023-12-17T08:33:04.674638Z,64,5 -ORDER_CREATED,2023-12-17T08:33:09.674638Z,65,5 -ORDER_CREATED,2023-12-17T08:33:12.674638Z,66,5 -ORDER_CREATED,2023-12-17T08:33:17.674638Z,67,2 -ORDER_CREATED,2023-12-17T08:33:18.674638Z,68,1 -ORDER_CREATED,2023-12-17T08:33:26.674638Z,69,3 -ORDER_CREATED,2023-12-17T08:33:30.674638Z,70,1 -ORDER_CREATED,2023-12-17T08:33:38.674638Z,71,4 -ORDER_CREATED,2023-12-17T08:33:39.674638Z,72,4 -ORDER_CREATED,2023-12-17T08:33:40.674638Z,73,4 -ORDER_CREATED,2023-12-17T08:33:44.674638Z,74,5 -ORDER_CREATED,2023-12-17T08:33:54.674638Z,75,2 -ORDER_CREATED,2023-12-17T08:33:56.674638Z,76,5 -ORDER_CREATED,2023-12-17T08:34:01.674638Z,77,5 -ORDER_CREATED,2023-12-17T08:34:11.674638Z,78,2 -ORDER_CREATED,2023-12-17T08:34:12.674638Z,79,3 -ORDER_CREATED,2023-12-17T08:34:15.674638Z,80,2 -ORDER_CREATED,2023-12-17T08:34:17.674638Z,81,1 -ORDER_CREATED,2023-12-17T08:34:27.674638Z,82,5 -ORDER_CREATED,2023-12-17T08:34:34.674638Z,83,3 -ORDER_CREATED,2023-12-17T08:34:39.674638Z,84,1 -ORDER_CREATED,2023-12-17T08:34:45.674638Z,85,3 -ORDER_CREATED,2023-12-17T08:34:54.674638Z,86,3 -ORDER_CREATED,2023-12-17T08:34:55.674638Z,87,2 -ORDER_CREATED,2023-12-17T08:34:59.674638Z,88,3 -ORDER_CREATED,2023-12-17T08:35:04.674638Z,89,2 -ORDER_CREATED,2023-12-17T08:35:11.674638Z,90,4 -ORDER_CREATED,2023-12-17T08:35:12.674638Z,91,1 -ORDER_CREATED,2023-12-17T08:35:19.674638Z,92,3 -ORDER_CREATED,2023-12-17T08:35:23.674638Z,93,5 -ORDER_CREATED,2023-12-17T08:35:31.674638Z,94,1 -ORDER_CREATED,2023-12-17T08:35:32.674638Z,95,2 -ORDER_CREATED,2023-12-17T08:35:33.674638Z,96,5 -ORDER_CREATED,2023-12-17T08:35:34.674638Z,97,5 -ORDER_CREATED,2023-12-17T08:35:41.674638Z,98,1 -ORDER_CREATED,2023-12-17T08:35:44.674638Z,99,3 -ORDER_CREATED,2023-12-17T08:35:46.674638Z,100,3 +ORDER_CREATED,2024-03-23T16:28:48.764232Z,1,1 +ORDER_CREATED,2024-03-23T16:28:57.764232Z,2,5 +ORDER_CREATED,2024-03-23T16:28:58.764232Z,3,1 +ORDER_CREATED,2024-03-23T16:29:02.764232Z,4,4 +ORDER_CREATED,2024-03-23T16:29:10.764232Z,5,5 +ORDER_CREATED,2024-03-23T16:29:14.764232Z,6,1 +ORDER_CREATED,2024-03-23T16:29:18.764232Z,7,2 +ORDER_CREATED,2024-03-23T16:29:21.764232Z,8,1 +ORDER_CREATED,2024-03-23T16:29:25.764232Z,9,4 +ORDER_CREATED,2024-03-23T16:29:28.764232Z,10,1 +ORDER_CREATED,2024-03-23T16:29:29.764232Z,11,1 +ORDER_CREATED,2024-03-23T16:29:33.764232Z,12,4 +ORDER_CREATED,2024-03-23T16:29:36.764232Z,13,5 +ORDER_CREATED,2024-03-23T16:29:37.764232Z,14,3 +ORDER_CREATED,2024-03-23T16:29:46.764232Z,15,2 +ORDER_CREATED,2024-03-23T16:29:51.764232Z,16,3 +ORDER_CREATED,2024-03-23T16:29:54.764232Z,17,4 +ORDER_CREATED,2024-03-23T16:30:04.764232Z,18,2 +ORDER_CREATED,2024-03-23T16:30:11.764232Z,19,5 +ORDER_CREATED,2024-03-23T16:30:19.764232Z,20,5 +ORDER_CREATED,2024-03-23T16:30:22.764232Z,21,2 +ORDER_CREATED,2024-03-23T16:30:26.764232Z,22,1 +ORDER_CREATED,2024-03-23T16:30:34.764232Z,23,3 +ORDER_CREATED,2024-03-23T16:30:40.764232Z,24,4 +ORDER_CREATED,2024-03-23T16:30:42.764232Z,25,3 +ORDER_CREATED,2024-03-23T16:30:43.764232Z,26,4 +ORDER_CREATED,2024-03-23T16:30:52.764232Z,27,4 +ORDER_CREATED,2024-03-23T16:30:56.764232Z,28,4 +ORDER_CREATED,2024-03-23T16:31:00.764232Z,29,4 +ORDER_CREATED,2024-03-23T16:31:07.764232Z,30,5 +ORDER_CREATED,2024-03-23T16:31:09.764232Z,31,1 +ORDER_CREATED,2024-03-23T16:31:11.764232Z,32,2 +ORDER_CREATED,2024-03-23T16:31:19.764232Z,33,5 +ORDER_CREATED,2024-03-23T16:31:28.764232Z,34,3 +ORDER_CREATED,2024-03-23T16:31:33.764232Z,35,4 +ORDER_CREATED,2024-03-23T16:31:35.764232Z,36,5 +ORDER_CREATED,2024-03-23T16:31:43.764232Z,37,3 +ORDER_CREATED,2024-03-23T16:31:46.764232Z,38,2 +ORDER_CREATED,2024-03-23T16:31:53.764232Z,39,1 +ORDER_CREATED,2024-03-23T16:32:02.764232Z,40,3 +ORDER_CREATED,2024-03-23T16:32:11.764232Z,41,5 +ORDER_CREATED,2024-03-23T16:32:13.764232Z,42,2 +ORDER_CREATED,2024-03-23T16:32:21.764232Z,43,1 +ORDER_CREATED,2024-03-23T16:32:24.764232Z,44,5 +ORDER_CREATED,2024-03-23T16:32:29.764232Z,45,4 +ORDER_CREATED,2024-03-23T16:32:30.764232Z,46,4 +ORDER_CREATED,2024-03-23T16:32:40.764232Z,47,4 +ORDER_CREATED,2024-03-23T16:32:46.764232Z,48,5 +ORDER_CREATED,2024-03-23T16:32:52.764232Z,49,2 +ORDER_CREATED,2024-03-23T16:32:54.764232Z,50,2 +ORDER_CREATED,2024-03-23T16:32:57.764232Z,51,5 +ORDER_CREATED,2024-03-23T16:32:59.764232Z,52,3 +ORDER_CREATED,2024-03-23T16:33:07.764232Z,53,4 +ORDER_CREATED,2024-03-23T16:33:10.764232Z,54,5 +ORDER_CREATED,2024-03-23T16:33:17.764232Z,55,1 +ORDER_CREATED,2024-03-23T16:33:24.764232Z,56,5 +ORDER_CREATED,2024-03-23T16:33:34.764232Z,57,5 +ORDER_CREATED,2024-03-23T16:33:35.764232Z,58,3 +ORDER_CREATED,2024-03-23T16:33:43.764232Z,59,4 +ORDER_CREATED,2024-03-23T16:33:48.764232Z,60,4 +ORDER_CREATED,2024-03-23T16:33:57.764232Z,61,4 +ORDER_CREATED,2024-03-23T16:34:00.764232Z,62,4 +ORDER_CREATED,2024-03-23T16:34:02.764232Z,63,1 +ORDER_CREATED,2024-03-23T16:34:08.764232Z,64,2 +ORDER_CREATED,2024-03-23T16:34:11.764232Z,65,3 +ORDER_CREATED,2024-03-23T16:34:17.764232Z,66,3 +ORDER_CREATED,2024-03-23T16:34:19.764232Z,67,3 +ORDER_CREATED,2024-03-23T16:34:29.764232Z,68,4 +ORDER_CREATED,2024-03-23T16:34:39.764232Z,69,3 +ORDER_CREATED,2024-03-23T16:34:43.764232Z,70,1 +ORDER_CREATED,2024-03-23T16:34:51.764232Z,71,5 +ORDER_CREATED,2024-03-23T16:34:53.764232Z,72,5 +ORDER_CREATED,2024-03-23T16:34:54.764232Z,73,1 +ORDER_CREATED,2024-03-23T16:34:56.764232Z,74,3 +ORDER_CREATED,2024-03-23T16:34:58.764232Z,75,3 +ORDER_CREATED,2024-03-23T16:35:05.764232Z,76,4 +ORDER_CREATED,2024-03-23T16:35:14.764232Z,77,2 +ORDER_CREATED,2024-03-23T16:35:15.764232Z,78,3 +ORDER_CREATED,2024-03-23T16:35:24.764232Z,79,1 +ORDER_CREATED,2024-03-23T16:35:34.764232Z,80,5 +ORDER_CREATED,2024-03-23T16:35:39.764232Z,81,5 +ORDER_CREATED,2024-03-23T16:35:42.764232Z,82,2 +ORDER_CREATED,2024-03-23T16:35:49.764232Z,83,2 +ORDER_CREATED,2024-03-23T16:35:54.764232Z,84,2 +ORDER_CREATED,2024-03-23T16:36:00.764232Z,85,5 +ORDER_CREATED,2024-03-23T16:36:09.764232Z,86,4 +ORDER_CREATED,2024-03-23T16:36:11.764232Z,87,2 +ORDER_CREATED,2024-03-23T16:36:14.764232Z,88,2 +ORDER_CREATED,2024-03-23T16:36:19.764232Z,89,1 +ORDER_CREATED,2024-03-23T16:36:27.764232Z,90,4 +ORDER_CREATED,2024-03-23T16:36:37.764232Z,91,2 +ORDER_CREATED,2024-03-23T16:36:40.764232Z,92,2 +ORDER_CREATED,2024-03-23T16:36:47.764232Z,93,2 +ORDER_CREATED,2024-03-23T16:36:54.764232Z,94,5 +ORDER_CREATED,2024-03-23T16:37:01.764232Z,95,2 +ORDER_CREATED,2024-03-23T16:37:10.764232Z,96,2 +ORDER_CREATED,2024-03-23T16:37:18.764232Z,97,5 +ORDER_CREATED,2024-03-23T16:37:23.764232Z,98,5 +ORDER_CREATED,2024-03-23T16:37:29.764232Z,99,3 +ORDER_CREATED,2024-03-23T16:37:34.764232Z,100,4 diff --git a/test/examples/parcels/parcels.csv b/test/examples/parcels/parcels.csv index dd499c0..715a59c 100644 --- a/test/examples/parcels/parcels.csv +++ b/test/examples/parcels/parcels.csv @@ -1,285 +1,316 @@ -PARCEL_SHIPPED,2023-12-18T21:32:04.674638Z,1 -PARCEL_SHIPPED,2023-12-18T19:34:16.674638Z,1 -PARCEL_SHIPPED,2023-12-22T02:26:22.674638Z,2 -PARCEL_SHIPPED,2023-12-20T16:34:30.674638Z,2 -PARCEL_SHIPPED,2023-12-18T19:40:20.674638Z,2 -PARCEL_SHIPPED,2023-12-18T02:25:53.674638Z,2 -PARCEL_SHIPPED,2023-12-18T10:53:23.674638Z,3 -PARCEL_SHIPPED,2023-12-17T16:46:43.674638Z,4 -PARCEL_SHIPPED,2023-12-23T13:24:11.674638Z,5 -PARCEL_SHIPPED,2023-12-22T04:07:06.674638Z,5 -PARCEL_SHIPPED,2023-12-21T17:44:23.674638Z,5 -PARCEL_SHIPPED,2023-12-20T08:28:17.674638Z,5 -PARCEL_SHIPPED,2023-12-19T05:11:17.674638Z,5 -PARCEL_SHIPPED,2023-12-20T02:27:31.674638Z,6 -PARCEL_SHIPPED,2023-12-19T00:31:08.674638Z,6 -PARCEL_SHIPPED,2023-12-20T13:59:29.674638Z,7 -PARCEL_SHIPPED,2023-12-19T23:17:46.674638Z,7 -PARCEL_SHIPPED,2023-12-19T22:23:28.674638Z,7 -PARCEL_SHIPPED,2023-12-19T15:15:25.674638Z,7 -PARCEL_SHIPPED,2023-12-17T22:23:31.674638Z,7 -PARCEL_SHIPPED,2023-12-20T03:36:10.674638Z,8 -PARCEL_SHIPPED,2023-12-18T17:01:25.674638Z,8 -PARCEL_SHIPPED,2023-12-22T00:06:43.674638Z,9 -PARCEL_SHIPPED,2023-12-20T08:50:49.674638Z,9 -PARCEL_SHIPPED,2023-12-18T15:56:15.674638Z,9 -PARCEL_SHIPPED,2023-12-17T17:42:56.674638Z,9 -PARCEL_SHIPPED,2023-12-20T00:48:15.674638Z,10 -PARCEL_SHIPPED,2023-12-19T07:33:01.674638Z,10 -PARCEL_SHIPPED,2023-12-19T01:30:22.674638Z,10 -PARCEL_SHIPPED,2023-12-19T01:26:58.674638Z,10 -PARCEL_SHIPPED,2023-12-18T03:21:44.674638Z,11 -PARCEL_SHIPPED,2023-12-19T18:24:57.674638Z,12 -PARCEL_SHIPPED,2023-12-18T17:51:59.674638Z,12 -PARCEL_SHIPPED,2023-12-17T23:39:50.674638Z,12 -PARCEL_SHIPPED,2023-12-17T23:35:18.674638Z,12 -PARCEL_SHIPPED,2023-12-17T23:28:10.674638Z,12 -PARCEL_SHIPPED,2023-12-19T17:21:38.674638Z,13 -PARCEL_SHIPPED,2023-12-19T13:25:38.674638Z,13 -PARCEL_SHIPPED,2023-12-18T16:38:27.674638Z,13 -PARCEL_SHIPPED,2023-12-19T19:41:28.674638Z,14 -PARCEL_SHIPPED,2023-12-18T20:40:21.674638Z,14 -PARCEL_SHIPPED,2023-12-17T14:53:21.674638Z,14 -PARCEL_SHIPPED,2023-12-20T06:27:32.674638Z,15 -PARCEL_SHIPPED,2023-12-19T14:09:02.674638Z,15 -PARCEL_SHIPPED,2023-12-18T12:51:58.674638Z,15 -PARCEL_SHIPPED,2023-12-17T13:59:55.674638Z,15 -PARCEL_SHIPPED,2023-12-21T10:11:38.674638Z,16 -PARCEL_SHIPPED,2023-12-20T01:21:49.674638Z,16 -PARCEL_SHIPPED,2023-12-19T13:21:33.674638Z,16 -PARCEL_SHIPPED,2023-12-18T11:00:33.674638Z,16 -PARCEL_SHIPPED,2023-12-18T10:32:38.674638Z,16 -PARCEL_SHIPPED,2023-12-18T08:10:32.674638Z,17 -PARCEL_SHIPPED,2023-12-17T15:22:07.674638Z,18 -PARCEL_SHIPPED,2023-12-18T06:02:13.674638Z,19 -PARCEL_SHIPPED,2023-12-18T05:20:27.674638Z,19 -PARCEL_SHIPPED,2023-12-18T01:38:06.674638Z,19 -PARCEL_SHIPPED,2023-12-20T11:08:44.674638Z,20 -PARCEL_SHIPPED,2023-12-19T16:06:09.674638Z,20 -PARCEL_SHIPPED,2023-12-17T19:59:47.674638Z,20 -PARCEL_SHIPPED,2023-12-18T05:20:09.674638Z,21 -PARCEL_SHIPPED,2023-12-20T03:39:09.674638Z,22 -PARCEL_SHIPPED,2023-12-19T09:48:05.674638Z,22 -PARCEL_SHIPPED,2023-12-17T11:38:40.674638Z,22 -PARCEL_SHIPPED,2023-12-22T02:42:50.674638Z,23 -PARCEL_SHIPPED,2023-12-20T14:32:39.674638Z,23 -PARCEL_SHIPPED,2023-12-18T17:27:58.674638Z,23 -PARCEL_SHIPPED,2023-12-18T06:14:42.674638Z,23 -PARCEL_SHIPPED,2023-12-17T20:38:51.674638Z,23 -PARCEL_SHIPPED,2023-12-18T23:47:30.674638Z,24 -PARCEL_SHIPPED,2023-12-18T17:56:27.674638Z,24 -PARCEL_SHIPPED,2023-12-17T15:16:58.674638Z,24 -PARCEL_SHIPPED,2023-12-21T03:58:17.674638Z,25 -PARCEL_SHIPPED,2023-12-19T04:00:08.674638Z,25 -PARCEL_SHIPPED,2023-12-18T10:10:02.674638Z,25 -PARCEL_SHIPPED,2023-12-20T01:16:18.674638Z,26 -PARCEL_SHIPPED,2023-12-18T06:49:07.674638Z,26 -PARCEL_SHIPPED,2023-12-18T01:59:58.674638Z,27 -PARCEL_SHIPPED,2023-12-17T09:00:32.674638Z,28 -PARCEL_SHIPPED,2023-12-19T01:42:07.674638Z,29 -PARCEL_SHIPPED,2023-12-18T17:02:21.674638Z,30 -PARCEL_SHIPPED,2023-12-22T07:43:09.674638Z,31 -PARCEL_SHIPPED,2023-12-20T16:45:35.674638Z,31 -PARCEL_SHIPPED,2023-12-20T11:05:03.674638Z,31 -PARCEL_SHIPPED,2023-12-20T05:26:10.674638Z,31 -PARCEL_SHIPPED,2023-12-18T15:28:26.674638Z,31 -PARCEL_SHIPPED,2023-12-19T23:26:04.674638Z,32 -PARCEL_SHIPPED,2023-12-18T21:17:00.674638Z,32 -PARCEL_SHIPPED,2023-12-18T17:49:57.674638Z,33 -PARCEL_SHIPPED,2023-12-19T14:04:59.674638Z,34 -PARCEL_SHIPPED,2023-12-17T15:02:56.674638Z,34 -PARCEL_SHIPPED,2023-12-21T00:28:00.674638Z,35 -PARCEL_SHIPPED,2023-12-20T10:31:45.674638Z,35 -PARCEL_SHIPPED,2023-12-19T08:07:52.674638Z,35 -PARCEL_SHIPPED,2023-12-22T01:18:44.674638Z,36 -PARCEL_SHIPPED,2023-12-20T19:46:47.674638Z,36 -PARCEL_SHIPPED,2023-12-20T07:06:22.674638Z,36 -PARCEL_SHIPPED,2023-12-18T16:17:52.674638Z,36 -PARCEL_SHIPPED,2023-12-17T10:06:25.674638Z,36 -PARCEL_SHIPPED,2023-12-20T04:38:32.674638Z,37 -PARCEL_SHIPPED,2023-12-18T12:41:58.674638Z,37 -PARCEL_SHIPPED,2023-12-17T14:51:16.674638Z,37 -PARCEL_SHIPPED,2023-12-23T12:26:13.674638Z,38 -PARCEL_SHIPPED,2023-12-22T04:23:55.674638Z,38 -PARCEL_SHIPPED,2023-12-20T05:19:12.674638Z,38 -PARCEL_SHIPPED,2023-12-20T02:37:18.674638Z,38 -PARCEL_SHIPPED,2023-12-19T01:13:37.674638Z,38 -PARCEL_SHIPPED,2023-12-18T08:10:00.674638Z,39 -PARCEL_SHIPPED,2023-12-19T06:12:01.674638Z,40 -PARCEL_SHIPPED,2023-12-17T10:07:38.674638Z,40 -PARCEL_SHIPPED,2023-12-20T01:11:24.674638Z,41 -PARCEL_SHIPPED,2023-12-19T07:01:44.674638Z,41 -PARCEL_SHIPPED,2023-12-21T06:20:19.674638Z,42 -PARCEL_SHIPPED,2023-12-21T03:31:20.674638Z,42 -PARCEL_SHIPPED,2023-12-19T12:50:28.674638Z,42 -PARCEL_SHIPPED,2023-12-19T08:06:31.674638Z,42 -PARCEL_SHIPPED,2023-12-18T18:37:51.674638Z,42 -PARCEL_SHIPPED,2023-12-22T04:13:00.674638Z,43 -PARCEL_SHIPPED,2023-12-20T17:59:48.674638Z,43 -PARCEL_SHIPPED,2023-12-19T09:13:53.674638Z,43 -PARCEL_SHIPPED,2023-12-17T21:45:44.674638Z,43 -PARCEL_SHIPPED,2023-12-19T20:39:40.674638Z,44 -PARCEL_SHIPPED,2023-12-18T16:53:27.674638Z,44 -PARCEL_SHIPPED,2023-12-18T22:54:27.674638Z,45 -PARCEL_SHIPPED,2023-12-18T12:20:24.674638Z,45 -PARCEL_SHIPPED,2023-12-17T09:24:06.674638Z,45 -PARCEL_SHIPPED,2023-12-18T15:03:11.674638Z,46 -PARCEL_SHIPPED,2023-12-17T17:02:04.674638Z,46 -PARCEL_SHIPPED,2023-12-19T04:18:00.674638Z,47 -PARCEL_SHIPPED,2023-12-18T04:59:49.674638Z,47 -PARCEL_SHIPPED,2023-12-17T22:15:03.674638Z,47 -PARCEL_SHIPPED,2023-12-17T20:44:04.674638Z,47 -PARCEL_SHIPPED,2023-12-20T18:32:26.674638Z,48 -PARCEL_SHIPPED,2023-12-19T07:43:15.674638Z,48 -PARCEL_SHIPPED,2023-12-19T03:59:30.674638Z,49 -PARCEL_SHIPPED,2023-12-19T00:00:15.674638Z,49 -PARCEL_SHIPPED,2023-12-18T12:17:16.674638Z,49 -PARCEL_SHIPPED,2023-12-22T23:28:48.674638Z,50 -PARCEL_SHIPPED,2023-12-21T18:44:45.674638Z,50 -PARCEL_SHIPPED,2023-12-19T19:09:39.674638Z,50 -PARCEL_SHIPPED,2023-12-18T17:27:28.674638Z,50 -PARCEL_SHIPPED,2023-12-17T13:34:45.674638Z,50 -PARCEL_SHIPPED,2023-12-20T11:51:15.674638Z,51 -PARCEL_SHIPPED,2023-12-18T21:59:54.674638Z,51 -PARCEL_SHIPPED,2023-12-18T07:26:25.674638Z,51 -PARCEL_SHIPPED,2023-12-19T19:09:46.674638Z,52 -PARCEL_SHIPPED,2023-12-18T01:34:05.674638Z,52 -PARCEL_SHIPPED,2023-12-19T06:55:18.674638Z,53 -PARCEL_SHIPPED,2023-12-18T16:58:53.674638Z,53 -PARCEL_SHIPPED,2023-12-21T14:58:43.674638Z,54 -PARCEL_SHIPPED,2023-12-20T21:32:22.674638Z,54 -PARCEL_SHIPPED,2023-12-20T02:29:38.674638Z,54 -PARCEL_SHIPPED,2023-12-19T03:20:33.674638Z,54 -PARCEL_SHIPPED,2023-12-22T22:30:57.674638Z,55 -PARCEL_SHIPPED,2023-12-21T04:01:00.674638Z,55 -PARCEL_SHIPPED,2023-12-19T07:08:08.674638Z,55 -PARCEL_SHIPPED,2023-12-18T08:30:36.674638Z,55 -PARCEL_SHIPPED,2023-12-18T04:07:13.674638Z,56 -PARCEL_SHIPPED,2023-12-18T16:58:20.674638Z,57 -PARCEL_SHIPPED,2023-12-20T11:47:06.674638Z,58 -PARCEL_SHIPPED,2023-12-18T14:58:37.674638Z,58 -PARCEL_SHIPPED,2023-12-18T10:19:21.674638Z,58 -PARCEL_SHIPPED,2023-12-20T20:21:31.674638Z,59 -PARCEL_SHIPPED,2023-12-19T06:55:37.674638Z,59 -PARCEL_SHIPPED,2023-12-19T21:29:18.674638Z,60 -PARCEL_SHIPPED,2023-12-19T14:45:32.674638Z,60 -PARCEL_SHIPPED,2023-12-18T05:51:03.674638Z,60 -PARCEL_SHIPPED,2023-12-18T02:21:00.674638Z,60 -PARCEL_SHIPPED,2023-12-19T01:48:17.674638Z,61 -PARCEL_SHIPPED,2023-12-19T21:20:34.674638Z,62 -PARCEL_SHIPPED,2023-12-18T21:30:26.674638Z,62 -PARCEL_SHIPPED,2023-12-18T20:39:08.674638Z,63 -PARCEL_SHIPPED,2023-12-22T09:59:56.674638Z,64 -PARCEL_SHIPPED,2023-12-20T22:51:41.674638Z,64 -PARCEL_SHIPPED,2023-12-19T13:27:41.674638Z,64 -PARCEL_SHIPPED,2023-12-19T07:27:53.674638Z,64 -PARCEL_SHIPPED,2023-12-18T02:49:28.674638Z,64 -PARCEL_SHIPPED,2023-12-20T17:10:49.674638Z,65 -PARCEL_SHIPPED,2023-12-20T04:37:45.674638Z,65 -PARCEL_SHIPPED,2023-12-19T20:38:28.674638Z,65 -PARCEL_SHIPPED,2023-12-19T01:36:27.674638Z,65 -PARCEL_SHIPPED,2023-12-19T01:23:41.674638Z,65 -PARCEL_SHIPPED,2023-12-23T03:26:53.674638Z,66 -PARCEL_SHIPPED,2023-12-22T14:48:46.674638Z,66 -PARCEL_SHIPPED,2023-12-20T19:16:15.674638Z,66 -PARCEL_SHIPPED,2023-12-19T02:53:17.674638Z,66 -PARCEL_SHIPPED,2023-12-18T23:47:49.674638Z,66 -PARCEL_SHIPPED,2023-12-19T08:29:18.674638Z,67 -PARCEL_SHIPPED,2023-12-17T19:13:57.674638Z,67 -PARCEL_SHIPPED,2023-12-19T03:12:43.674638Z,68 -PARCEL_SHIPPED,2023-12-22T05:57:58.674638Z,69 -PARCEL_SHIPPED,2023-12-20T14:20:24.674638Z,69 -PARCEL_SHIPPED,2023-12-18T22:03:11.674638Z,69 -PARCEL_SHIPPED,2023-12-19T00:11:56.674638Z,70 -PARCEL_SHIPPED,2023-12-20T15:57:57.674638Z,71 -PARCEL_SHIPPED,2023-12-18T18:30:07.674638Z,71 -PARCEL_SHIPPED,2023-12-18T09:25:58.674638Z,71 -PARCEL_SHIPPED,2023-12-17T16:35:16.674638Z,71 -PARCEL_SHIPPED,2023-12-19T21:43:47.674638Z,72 -PARCEL_SHIPPED,2023-12-19T16:30:39.674638Z,72 -PARCEL_SHIPPED,2023-12-19T10:41:47.674638Z,72 -PARCEL_SHIPPED,2023-12-18T12:11:39.674638Z,72 -PARCEL_SHIPPED,2023-12-20T02:08:01.674638Z,73 -PARCEL_SHIPPED,2023-12-18T13:36:52.674638Z,73 -PARCEL_SHIPPED,2023-12-17T21:36:29.674638Z,73 -PARCEL_SHIPPED,2023-12-17T10:31:15.674638Z,73 -PARCEL_SHIPPED,2023-12-23T13:31:24.674638Z,74 -PARCEL_SHIPPED,2023-12-21T16:06:08.674638Z,74 -PARCEL_SHIPPED,2023-12-21T08:04:36.674638Z,74 -PARCEL_SHIPPED,2023-12-20T07:47:08.674638Z,74 -PARCEL_SHIPPED,2023-12-18T16:33:11.674638Z,74 -PARCEL_SHIPPED,2023-12-18T17:31:15.674638Z,75 -PARCEL_SHIPPED,2023-12-18T08:27:04.674638Z,75 -PARCEL_SHIPPED,2023-12-22T15:44:51.674638Z,76 -PARCEL_SHIPPED,2023-12-21T21:00:46.674638Z,76 -PARCEL_SHIPPED,2023-12-20T14:04:50.674638Z,76 -PARCEL_SHIPPED,2023-12-19T11:57:32.674638Z,76 -PARCEL_SHIPPED,2023-12-17T17:03:57.674638Z,76 -PARCEL_SHIPPED,2023-12-22T22:19:45.674638Z,77 -PARCEL_SHIPPED,2023-12-21T01:14:17.674638Z,77 -PARCEL_SHIPPED,2023-12-20T08:32:45.674638Z,77 -PARCEL_SHIPPED,2023-12-18T16:09:47.674638Z,77 -PARCEL_SHIPPED,2023-12-18T14:19:04.674638Z,77 -PARCEL_SHIPPED,2023-12-20T07:45:48.674638Z,78 -PARCEL_SHIPPED,2023-12-18T20:06:17.674638Z,78 -PARCEL_SHIPPED,2023-12-19T17:15:34.674638Z,79 -PARCEL_SHIPPED,2023-12-19T09:49:26.674638Z,79 -PARCEL_SHIPPED,2023-12-18T03:46:15.674638Z,79 -PARCEL_SHIPPED,2023-12-18T08:45:42.674638Z,80 -PARCEL_SHIPPED,2023-12-17T23:23:28.674638Z,80 -PARCEL_SHIPPED,2023-12-18T00:59:17.674638Z,81 -PARCEL_SHIPPED,2023-12-24T17:26:50.674638Z,82 -PARCEL_SHIPPED,2023-12-22T23:06:48.674638Z,82 -PARCEL_SHIPPED,2023-12-21T13:23:53.674638Z,82 -PARCEL_SHIPPED,2023-12-19T23:35:01.674638Z,82 -PARCEL_SHIPPED,2023-12-18T22:29:31.674638Z,82 -PARCEL_SHIPPED,2023-12-20T09:15:26.674638Z,83 -PARCEL_SHIPPED,2023-12-20T00:04:41.674638Z,83 -PARCEL_SHIPPED,2023-12-18T02:52:26.674638Z,83 -PARCEL_SHIPPED,2023-12-19T04:17:45.674638Z,84 -PARCEL_SHIPPED,2023-12-21T09:01:16.674638Z,85 -PARCEL_SHIPPED,2023-12-20T05:46:09.674638Z,85 -PARCEL_SHIPPED,2023-12-18T13:07:44.674638Z,85 -PARCEL_SHIPPED,2023-12-19T22:02:20.674638Z,86 -PARCEL_SHIPPED,2023-12-19T04:18:52.674638Z,86 -PARCEL_SHIPPED,2023-12-19T03:08:28.674638Z,86 -PARCEL_SHIPPED,2023-12-20T12:14:47.674638Z,87 -PARCEL_SHIPPED,2023-12-18T16:00:08.674638Z,87 -PARCEL_SHIPPED,2023-12-18T14:27:47.674638Z,88 -PARCEL_SHIPPED,2023-12-18T06:35:37.674638Z,88 -PARCEL_SHIPPED,2023-12-17T10:18:40.674638Z,88 -PARCEL_SHIPPED,2023-12-18T17:53:39.674638Z,89 -PARCEL_SHIPPED,2023-12-17T17:53:19.674638Z,89 -PARCEL_SHIPPED,2023-12-20T23:45:39.674638Z,90 -PARCEL_SHIPPED,2023-12-20T02:18:29.674638Z,90 -PARCEL_SHIPPED,2023-12-18T06:55:23.674638Z,90 -PARCEL_SHIPPED,2023-12-17T13:27:46.674638Z,90 -PARCEL_SHIPPED,2023-12-18T12:56:11.674638Z,91 -PARCEL_SHIPPED,2023-12-19T20:19:48.674638Z,92 -PARCEL_SHIPPED,2023-12-17T21:42:26.674638Z,92 -PARCEL_SHIPPED,2023-12-17T12:09:09.674638Z,92 -PARCEL_SHIPPED,2023-12-25T09:03:38.674638Z,93 -PARCEL_SHIPPED,2023-12-23T10:11:43.674638Z,93 -PARCEL_SHIPPED,2023-12-21T14:29:23.674638Z,93 -PARCEL_SHIPPED,2023-12-20T06:40:09.674638Z,93 -PARCEL_SHIPPED,2023-12-18T18:52:34.674638Z,93 -PARCEL_SHIPPED,2023-12-18T18:04:56.674638Z,94 -PARCEL_SHIPPED,2023-12-18T22:29:33.674638Z,95 -PARCEL_SHIPPED,2023-12-18T08:44:00.674638Z,95 -PARCEL_SHIPPED,2023-12-21T08:59:04.674638Z,96 -PARCEL_SHIPPED,2023-12-20T20:36:21.674638Z,96 -PARCEL_SHIPPED,2023-12-20T16:17:30.674638Z,96 -PARCEL_SHIPPED,2023-12-18T22:37:33.674638Z,96 -PARCEL_SHIPPED,2023-12-17T21:33:36.674638Z,96 -PARCEL_SHIPPED,2023-12-20T09:11:03.674638Z,97 -PARCEL_SHIPPED,2023-12-19T02:06:55.674638Z,97 -PARCEL_SHIPPED,2023-12-18T16:13:00.674638Z,97 -PARCEL_SHIPPED,2023-12-18T15:52:59.674638Z,97 -PARCEL_SHIPPED,2023-12-17T22:49:14.674638Z,97 -PARCEL_SHIPPED,2023-12-18T10:28:07.674638Z,98 -PARCEL_SHIPPED,2023-12-19T15:03:27.674638Z,99 -PARCEL_SHIPPED,2023-12-18T08:38:49.674638Z,99 -PARCEL_SHIPPED,2023-12-17T15:52:47.674638Z,99 -PARCEL_SHIPPED,2023-12-18T22:50:37.674638Z,100 -PARCEL_SHIPPED,2023-12-18T07:37:15.674638Z,100 -PARCEL_SHIPPED,2023-12-17T18:57:55.674638Z,100 +PARCEL_SHIPPED,2024-03-24T17:33:15.764232Z,1 +PARCEL_SHIPPED,2024-03-27T15:29:02.764232Z,2 +PARCEL_SHIPPED,2024-03-27T00:54:37.764232Z,2 +PARCEL_SHIPPED,2024-03-25T11:43:32.764232Z,2 +PARCEL_SHIPPED,2024-03-25T05:00:11.764232Z,2 +PARCEL_SHIPPED,2024-03-24T10:07:32.764232Z,2 +PARCEL_SHIPPED,2024-03-24T19:15:50.764232Z,3 +PARCEL_SHIPPED,2024-03-27T13:13:44.764232Z,4 +PARCEL_SHIPPED,2024-03-26T02:45:26.764232Z,4 +PARCEL_SHIPPED,2024-03-25T08:37:34.764232Z,4 +PARCEL_SHIPPED,2024-03-25T04:26:47.764232Z,4 +PARCEL_SHIPPED,2024-03-28T01:01:18.764232Z,5 +PARCEL_SHIPPED,2024-03-26T02:37:35.764232Z,5 +PARCEL_SHIPPED,2024-03-25T12:19:25.764232Z,5 +PARCEL_SHIPPED,2024-03-25T08:24:23.764232Z,5 +PARCEL_SHIPPED,2024-03-24T05:38:15.764232Z,5 +PARCEL_SHIPPED,2024-03-23T19:36:05.764232Z,6 +PARCEL_SHIPPED,2024-03-25T15:46:14.764232Z,7 +PARCEL_SHIPPED,2024-03-25T02:23:26.764232Z,7 +PARCEL_SHIPPED,2024-03-23T22:00:24.764232Z,8 +PARCEL_SHIPPED,2024-03-26T20:27:12.764232Z,9 +PARCEL_SHIPPED,2024-03-26T13:39:07.764232Z,9 +PARCEL_SHIPPED,2024-03-25T09:24:46.764232Z,9 +PARCEL_SHIPPED,2024-03-24T07:25:29.764232Z,9 +PARCEL_SHIPPED,2024-03-24T06:44:47.764232Z,10 +PARCEL_SHIPPED,2024-03-25T05:48:47.764232Z,11 +PARCEL_SHIPPED,2024-03-29T15:36:35.764232Z,12 +PARCEL_SHIPPED,2024-03-28T08:11:24.764232Z,12 +PARCEL_SHIPPED,2024-03-27T02:41:11.764232Z,12 +PARCEL_SHIPPED,2024-03-25T05:57:34.764232Z,12 +PARCEL_SHIPPED,2024-03-28T14:29:55.764232Z,13 +PARCEL_SHIPPED,2024-03-27T06:06:48.764232Z,13 +PARCEL_SHIPPED,2024-03-26T04:38:00.764232Z,13 +PARCEL_SHIPPED,2024-03-25T13:08:18.764232Z,13 +PARCEL_SHIPPED,2024-03-24T11:32:02.764232Z,13 +PARCEL_SHIPPED,2024-03-27T14:47:07.764232Z,14 +PARCEL_SHIPPED,2024-03-25T22:16:47.764232Z,14 +PARCEL_SHIPPED,2024-03-25T00:59:42.764232Z,14 +PARCEL_SHIPPED,2024-03-24T22:39:48.764232Z,15 +PARCEL_SHIPPED,2024-03-24T15:45:19.764232Z,15 +PARCEL_SHIPPED,2024-03-27T14:04:52.764232Z,16 +PARCEL_SHIPPED,2024-03-25T16:57:42.764232Z,16 +PARCEL_SHIPPED,2024-03-24T21:01:38.764232Z,16 +PARCEL_SHIPPED,2024-03-27T08:39:37.764232Z,17 +PARCEL_SHIPPED,2024-03-27T03:19:21.764232Z,17 +PARCEL_SHIPPED,2024-03-25T20:32:55.764232Z,17 +PARCEL_SHIPPED,2024-03-24T18:52:54.764232Z,17 +PARCEL_SHIPPED,2024-03-26T19:58:40.764232Z,18 +PARCEL_SHIPPED,2024-03-24T21:47:20.764232Z,18 +PARCEL_SHIPPED,2024-03-30T14:36:25.764232Z,19 +PARCEL_SHIPPED,2024-03-28T21:23:19.764232Z,19 +PARCEL_SHIPPED,2024-03-27T01:50:46.764232Z,19 +PARCEL_SHIPPED,2024-03-25T22:47:59.764232Z,19 +PARCEL_SHIPPED,2024-03-25T02:37:32.764232Z,19 +PARCEL_SHIPPED,2024-03-26T17:14:29.764232Z,20 +PARCEL_SHIPPED,2024-03-25T11:38:33.764232Z,20 +PARCEL_SHIPPED,2024-03-25T10:58:38.764232Z,20 +PARCEL_SHIPPED,2024-03-24T21:14:37.764232Z,20 +PARCEL_SHIPPED,2024-03-24T18:47:44.764232Z,20 +PARCEL_SHIPPED,2024-03-26T09:56:43.764232Z,21 +PARCEL_SHIPPED,2024-03-24T14:52:51.764232Z,21 +PARCEL_SHIPPED,2024-03-24T06:32:28.764232Z,22 +PARCEL_SHIPPED,2024-03-26T12:07:32.764232Z,23 +PARCEL_SHIPPED,2024-03-25T04:36:08.764232Z,23 +PARCEL_SHIPPED,2024-03-23T23:24:15.764232Z,23 +PARCEL_SHIPPED,2024-03-28T21:14:33.764232Z,24 +PARCEL_SHIPPED,2024-03-27T06:48:03.764232Z,24 +PARCEL_SHIPPED,2024-03-25T20:53:37.764232Z,24 +PARCEL_SHIPPED,2024-03-25T09:30:03.764232Z,24 +PARCEL_SHIPPED,2024-03-27T23:23:35.764232Z,25 +PARCEL_SHIPPED,2024-03-26T17:25:35.764232Z,25 +PARCEL_SHIPPED,2024-03-24T18:07:49.764232Z,25 +PARCEL_SHIPPED,2024-03-28T14:10:42.764232Z,26 +PARCEL_SHIPPED,2024-03-27T23:53:46.764232Z,26 +PARCEL_SHIPPED,2024-03-26T00:34:22.764232Z,26 +PARCEL_SHIPPED,2024-03-25T07:09:28.764232Z,26 +PARCEL_SHIPPED,2024-03-27T20:35:43.764232Z,27 +PARCEL_SHIPPED,2024-03-26T15:16:04.764232Z,27 +PARCEL_SHIPPED,2024-03-25T08:24:03.764232Z,27 +PARCEL_SHIPPED,2024-03-24T01:10:40.764232Z,27 +PARCEL_SHIPPED,2024-03-27T01:47:28.764232Z,28 +PARCEL_SHIPPED,2024-03-26T00:53:01.764232Z,28 +PARCEL_SHIPPED,2024-03-24T04:28:11.764232Z,28 +PARCEL_SHIPPED,2024-03-23T18:32:43.764232Z,28 +PARCEL_SHIPPED,2024-03-29T00:48:38.764232Z,29 +PARCEL_SHIPPED,2024-03-27T12:27:15.764232Z,29 +PARCEL_SHIPPED,2024-03-25T22:07:11.764232Z,29 +PARCEL_SHIPPED,2024-03-25T05:40:13.764232Z,29 +PARCEL_SHIPPED,2024-03-27T20:18:39.764232Z,30 +PARCEL_SHIPPED,2024-03-27T16:08:33.764232Z,30 +PARCEL_SHIPPED,2024-03-27T11:26:50.764232Z,30 +PARCEL_SHIPPED,2024-03-26T03:10:21.764232Z,30 +PARCEL_SHIPPED,2024-03-25T11:34:15.764232Z,30 +PARCEL_SHIPPED,2024-03-25T11:12:24.764232Z,31 +PARCEL_SHIPPED,2024-03-25T04:02:47.764232Z,32 +PARCEL_SHIPPED,2024-03-24T07:49:52.764232Z,32 +PARCEL_SHIPPED,2024-03-28T05:52:23.764232Z,33 +PARCEL_SHIPPED,2024-03-27T04:45:54.764232Z,33 +PARCEL_SHIPPED,2024-03-25T21:06:03.764232Z,33 +PARCEL_SHIPPED,2024-03-25T14:40:38.764232Z,33 +PARCEL_SHIPPED,2024-03-23T22:01:23.764232Z,33 +PARCEL_SHIPPED,2024-03-25T06:23:33.764232Z,34 +PARCEL_SHIPPED,2024-03-25T02:37:44.764232Z,34 +PARCEL_SHIPPED,2024-03-24T16:27:31.764232Z,34 +PARCEL_SHIPPED,2024-03-28T08:24:52.764232Z,35 +PARCEL_SHIPPED,2024-03-27T17:09:28.764232Z,35 +PARCEL_SHIPPED,2024-03-27T02:35:57.764232Z,35 +PARCEL_SHIPPED,2024-03-25T13:35:26.764232Z,35 +PARCEL_SHIPPED,2024-03-28T13:25:14.764232Z,36 +PARCEL_SHIPPED,2024-03-27T16:47:25.764232Z,36 +PARCEL_SHIPPED,2024-03-25T21:34:06.764232Z,36 +PARCEL_SHIPPED,2024-03-25T15:17:35.764232Z,36 +PARCEL_SHIPPED,2024-03-24T01:19:43.764232Z,36 +PARCEL_SHIPPED,2024-03-24T09:24:02.764232Z,37 +PARCEL_SHIPPED,2024-03-24T09:02:35.764232Z,37 +PARCEL_SHIPPED,2024-03-23T18:55:10.764232Z,37 +PARCEL_SHIPPED,2024-03-24T22:36:52.764232Z,38 +PARCEL_SHIPPED,2024-03-24T16:45:11.764232Z,38 +PARCEL_SHIPPED,2024-03-25T05:35:35.764232Z,39 +PARCEL_SHIPPED,2024-03-26T16:27:51.764232Z,40 +PARCEL_SHIPPED,2024-03-24T23:50:13.764232Z,40 +PARCEL_SHIPPED,2024-03-23T19:19:36.764232Z,40 +PARCEL_SHIPPED,2024-03-30T21:47:03.764232Z,41 +PARCEL_SHIPPED,2024-03-29T05:35:15.764232Z,41 +PARCEL_SHIPPED,2024-03-28T14:53:29.764232Z,41 +PARCEL_SHIPPED,2024-03-27T08:54:11.764232Z,41 +PARCEL_SHIPPED,2024-03-25T11:28:19.764232Z,41 +PARCEL_SHIPPED,2024-03-26T06:36:43.764232Z,42 +PARCEL_SHIPPED,2024-03-24T21:00:11.764232Z,42 +PARCEL_SHIPPED,2024-03-25T07:29:40.764232Z,43 +PARCEL_SHIPPED,2024-03-28T16:38:06.764232Z,44 +PARCEL_SHIPPED,2024-03-28T01:08:17.764232Z,44 +PARCEL_SHIPPED,2024-03-26T13:29:39.764232Z,44 +PARCEL_SHIPPED,2024-03-25T17:46:18.764232Z,44 +PARCEL_SHIPPED,2024-03-24T14:04:29.764232Z,44 +PARCEL_SHIPPED,2024-03-26T16:39:35.764232Z,45 +PARCEL_SHIPPED,2024-03-25T17:55:38.764232Z,45 +PARCEL_SHIPPED,2024-03-25T13:55:29.764232Z,45 +PARCEL_SHIPPED,2024-03-24T14:54:48.764232Z,45 +PARCEL_SHIPPED,2024-03-28T12:22:35.764232Z,46 +PARCEL_SHIPPED,2024-03-27T01:02:20.764232Z,46 +PARCEL_SHIPPED,2024-03-25T22:41:16.764232Z,46 +PARCEL_SHIPPED,2024-03-25T04:53:46.764232Z,46 +PARCEL_SHIPPED,2024-03-25T01:04:18.764232Z,47 +PARCEL_SHIPPED,2024-03-24T17:23:47.764232Z,47 +PARCEL_SHIPPED,2024-03-23T23:55:24.764232Z,47 +PARCEL_SHIPPED,2024-03-23T17:57:38.764232Z,47 +PARCEL_SHIPPED,2024-03-29T20:35:51.764232Z,48 +PARCEL_SHIPPED,2024-03-28T16:57:14.764232Z,48 +PARCEL_SHIPPED,2024-03-26T17:10:37.764232Z,48 +PARCEL_SHIPPED,2024-03-26T07:24:51.764232Z,48 +PARCEL_SHIPPED,2024-03-24T10:50:10.764232Z,48 +PARCEL_SHIPPED,2024-03-27T03:33:56.764232Z,49 +PARCEL_SHIPPED,2024-03-25T09:18:25.764232Z,49 +PARCEL_SHIPPED,2024-03-24T21:30:42.764232Z,50 +PARCEL_SHIPPED,2024-03-24T10:28:12.764232Z,50 +PARCEL_SHIPPED,2024-03-29T13:03:37.764232Z,51 +PARCEL_SHIPPED,2024-03-28T23:57:03.764232Z,51 +PARCEL_SHIPPED,2024-03-27T09:08:38.764232Z,51 +PARCEL_SHIPPED,2024-03-26T02:50:27.764232Z,51 +PARCEL_SHIPPED,2024-03-24T19:05:32.764232Z,51 +PARCEL_SHIPPED,2024-03-26T17:15:57.764232Z,52 +PARCEL_SHIPPED,2024-03-24T19:42:52.764232Z,52 +PARCEL_SHIPPED,2024-03-23T17:17:57.764232Z,52 +PARCEL_SHIPPED,2024-03-28T10:00:32.764232Z,53 +PARCEL_SHIPPED,2024-03-27T10:37:38.764232Z,53 +PARCEL_SHIPPED,2024-03-26T03:12:56.764232Z,53 +PARCEL_SHIPPED,2024-03-25T06:46:12.764232Z,53 +PARCEL_SHIPPED,2024-03-29T17:32:58.764232Z,54 +PARCEL_SHIPPED,2024-03-28T23:17:41.764232Z,54 +PARCEL_SHIPPED,2024-03-27T09:02:59.764232Z,54 +PARCEL_SHIPPED,2024-03-26T13:06:02.764232Z,54 +PARCEL_SHIPPED,2024-03-25T13:46:40.764232Z,54 +PARCEL_SHIPPED,2024-03-23T17:17:24.764232Z,55 +PARCEL_SHIPPED,2024-03-30T17:18:45.764232Z,56 +PARCEL_SHIPPED,2024-03-28T17:26:18.764232Z,56 +PARCEL_SHIPPED,2024-03-28T03:10:16.764232Z,56 +PARCEL_SHIPPED,2024-03-27T08:33:44.764232Z,56 +PARCEL_SHIPPED,2024-03-25T10:15:49.764232Z,56 +PARCEL_SHIPPED,2024-03-30T20:06:14.764232Z,57 +PARCEL_SHIPPED,2024-03-29T03:56:04.764232Z,57 +PARCEL_SHIPPED,2024-03-27T15:53:02.764232Z,57 +PARCEL_SHIPPED,2024-03-26T19:15:28.764232Z,57 +PARCEL_SHIPPED,2024-03-25T08:25:54.764232Z,57 +PARCEL_SHIPPED,2024-03-26T17:23:31.764232Z,58 +PARCEL_SHIPPED,2024-03-26T00:18:36.764232Z,58 +PARCEL_SHIPPED,2024-03-25T12:05:02.764232Z,58 +PARCEL_SHIPPED,2024-03-27T09:36:48.764232Z,59 +PARCEL_SHIPPED,2024-03-26T07:57:45.764232Z,59 +PARCEL_SHIPPED,2024-03-25T02:55:57.764232Z,59 +PARCEL_SHIPPED,2024-03-24T16:09:13.764232Z,59 +PARCEL_SHIPPED,2024-03-28T08:52:08.764232Z,60 +PARCEL_SHIPPED,2024-03-26T10:13:10.764232Z,60 +PARCEL_SHIPPED,2024-03-25T08:32:56.764232Z,60 +PARCEL_SHIPPED,2024-03-25T01:37:31.764232Z,60 +PARCEL_SHIPPED,2024-03-28T21:04:11.764232Z,61 +PARCEL_SHIPPED,2024-03-27T22:52:32.764232Z,61 +PARCEL_SHIPPED,2024-03-25T23:50:08.764232Z,61 +PARCEL_SHIPPED,2024-03-24T22:45:04.764232Z,61 +PARCEL_SHIPPED,2024-03-26T08:08:59.764232Z,62 +PARCEL_SHIPPED,2024-03-25T01:36:47.764232Z,62 +PARCEL_SHIPPED,2024-03-24T10:51:53.764232Z,62 +PARCEL_SHIPPED,2024-03-24T07:18:31.764232Z,62 +PARCEL_SHIPPED,2024-03-25T04:26:55.764232Z,63 +PARCEL_SHIPPED,2024-03-24T15:49:01.764232Z,64 +PARCEL_SHIPPED,2024-03-24T12:55:27.764232Z,64 +PARCEL_SHIPPED,2024-03-26T21:15:43.764232Z,65 +PARCEL_SHIPPED,2024-03-25T19:13:35.764232Z,65 +PARCEL_SHIPPED,2024-03-25T12:20:21.764232Z,65 +PARCEL_SHIPPED,2024-03-27T23:20:56.764232Z,66 +PARCEL_SHIPPED,2024-03-26T15:57:41.764232Z,66 +PARCEL_SHIPPED,2024-03-24T18:57:55.764232Z,66 +PARCEL_SHIPPED,2024-03-26T19:23:46.764232Z,67 +PARCEL_SHIPPED,2024-03-26T02:03:05.764232Z,67 +PARCEL_SHIPPED,2024-03-24T10:39:43.764232Z,67 +PARCEL_SHIPPED,2024-03-28T15:18:49.764232Z,68 +PARCEL_SHIPPED,2024-03-27T07:59:29.764232Z,68 +PARCEL_SHIPPED,2024-03-26T01:42:51.764232Z,68 +PARCEL_SHIPPED,2024-03-24T06:43:28.764232Z,68 +PARCEL_SHIPPED,2024-03-24T17:23:33.764232Z,69 +PARCEL_SHIPPED,2024-03-24T10:08:02.764232Z,69 +PARCEL_SHIPPED,2024-03-24T09:12:36.764232Z,69 +PARCEL_SHIPPED,2024-03-24T19:07:12.764232Z,70 +PARCEL_SHIPPED,2024-03-31T04:40:51.764232Z,71 +PARCEL_SHIPPED,2024-03-29T05:12:17.764232Z,71 +PARCEL_SHIPPED,2024-03-28T01:54:16.764232Z,71 +PARCEL_SHIPPED,2024-03-26T19:42:54.764232Z,71 +PARCEL_SHIPPED,2024-03-24T21:06:31.764232Z,71 +PARCEL_SHIPPED,2024-03-29T14:42:22.764232Z,72 +PARCEL_SHIPPED,2024-03-28T10:52:49.764232Z,72 +PARCEL_SHIPPED,2024-03-26T12:22:52.764232Z,72 +PARCEL_SHIPPED,2024-03-25T18:15:02.764232Z,72 +PARCEL_SHIPPED,2024-03-24T18:37:32.764232Z,72 +PARCEL_SHIPPED,2024-03-24T18:02:32.764232Z,73 +PARCEL_SHIPPED,2024-03-27T02:21:26.764232Z,74 +PARCEL_SHIPPED,2024-03-26T03:59:41.764232Z,74 +PARCEL_SHIPPED,2024-03-24T17:13:35.764232Z,74 +PARCEL_SHIPPED,2024-03-27T04:15:30.764232Z,75 +PARCEL_SHIPPED,2024-03-25T15:44:01.764232Z,75 +PARCEL_SHIPPED,2024-03-24T06:30:29.764232Z,75 +PARCEL_SHIPPED,2024-03-28T14:24:38.764232Z,76 +PARCEL_SHIPPED,2024-03-26T21:54:54.764232Z,76 +PARCEL_SHIPPED,2024-03-25T19:18:44.764232Z,76 +PARCEL_SHIPPED,2024-03-24T19:06:09.764232Z,76 +PARCEL_SHIPPED,2024-03-27T03:27:41.764232Z,77 +PARCEL_SHIPPED,2024-03-25T11:55:05.764232Z,77 +PARCEL_SHIPPED,2024-03-26T17:43:51.764232Z,78 +PARCEL_SHIPPED,2024-03-26T08:42:39.764232Z,78 +PARCEL_SHIPPED,2024-03-25T07:01:31.764232Z,78 +PARCEL_SHIPPED,2024-03-24T21:15:53.764232Z,79 +PARCEL_SHIPPED,2024-03-26T15:47:03.764232Z,80 +PARCEL_SHIPPED,2024-03-26T03:23:40.764232Z,80 +PARCEL_SHIPPED,2024-03-25T23:44:53.764232Z,80 +PARCEL_SHIPPED,2024-03-25T06:23:26.764232Z,80 +PARCEL_SHIPPED,2024-03-24T11:12:53.764232Z,80 +PARCEL_SHIPPED,2024-03-26T19:36:55.764232Z,81 +PARCEL_SHIPPED,2024-03-26T13:27:25.764232Z,81 +PARCEL_SHIPPED,2024-03-26T00:16:26.764232Z,81 +PARCEL_SHIPPED,2024-03-25T16:56:53.764232Z,81 +PARCEL_SHIPPED,2024-03-24T20:10:07.764232Z,81 +PARCEL_SHIPPED,2024-03-26T08:55:54.764232Z,82 +PARCEL_SHIPPED,2024-03-24T09:22:36.764232Z,82 +PARCEL_SHIPPED,2024-03-26T08:08:51.764232Z,83 +PARCEL_SHIPPED,2024-03-24T22:29:10.764232Z,83 +PARCEL_SHIPPED,2024-03-25T08:55:56.764232Z,84 +PARCEL_SHIPPED,2024-03-25T00:05:00.764232Z,84 +PARCEL_SHIPPED,2024-03-28T01:20:37.764232Z,85 +PARCEL_SHIPPED,2024-03-27T03:43:37.764232Z,85 +PARCEL_SHIPPED,2024-03-26T01:26:23.764232Z,85 +PARCEL_SHIPPED,2024-03-25T20:10:25.764232Z,85 +PARCEL_SHIPPED,2024-03-25T06:45:57.764232Z,85 +PARCEL_SHIPPED,2024-03-27T20:33:07.764232Z,86 +PARCEL_SHIPPED,2024-03-27T10:48:25.764232Z,86 +PARCEL_SHIPPED,2024-03-27T02:39:52.764232Z,86 +PARCEL_SHIPPED,2024-03-25T15:28:57.764232Z,86 +PARCEL_SHIPPED,2024-03-25T02:32:14.764232Z,87 +PARCEL_SHIPPED,2024-03-24T16:38:56.764232Z,87 +PARCEL_SHIPPED,2024-03-25T06:32:53.764232Z,88 +PARCEL_SHIPPED,2024-03-25T00:44:52.764232Z,88 +PARCEL_SHIPPED,2024-03-23T17:47:04.764232Z,89 +PARCEL_SHIPPED,2024-03-26T09:14:15.764232Z,90 +PARCEL_SHIPPED,2024-03-26T06:58:39.764232Z,90 +PARCEL_SHIPPED,2024-03-24T18:51:11.764232Z,90 +PARCEL_SHIPPED,2024-03-23T21:02:56.764232Z,90 +PARCEL_SHIPPED,2024-03-25T00:51:17.764232Z,91 +PARCEL_SHIPPED,2024-03-24T02:55:28.764232Z,91 +PARCEL_SHIPPED,2024-03-25T19:01:40.764232Z,92 +PARCEL_SHIPPED,2024-03-25T12:40:02.764232Z,92 +PARCEL_SHIPPED,2024-03-25T22:55:58.764232Z,93 +PARCEL_SHIPPED,2024-03-24T00:57:07.764232Z,93 +PARCEL_SHIPPED,2024-03-28T21:21:19.764232Z,94 +PARCEL_SHIPPED,2024-03-28T06:13:32.764232Z,94 +PARCEL_SHIPPED,2024-03-26T11:52:14.764232Z,94 +PARCEL_SHIPPED,2024-03-25T23:04:01.764232Z,94 +PARCEL_SHIPPED,2024-03-25T07:57:09.764232Z,94 +PARCEL_SHIPPED,2024-03-27T02:11:27.764232Z,95 +PARCEL_SHIPPED,2024-03-25T11:22:21.764232Z,95 +PARCEL_SHIPPED,2024-03-25T07:20:27.764232Z,96 +PARCEL_SHIPPED,2024-03-24T17:02:32.764232Z,96 +PARCEL_SHIPPED,2024-03-28T13:15:41.764232Z,97 +PARCEL_SHIPPED,2024-03-26T21:46:16.764232Z,97 +PARCEL_SHIPPED,2024-03-25T18:55:45.764232Z,97 +PARCEL_SHIPPED,2024-03-25T14:48:52.764232Z,97 +PARCEL_SHIPPED,2024-03-23T20:58:20.764232Z,97 +PARCEL_SHIPPED,2024-03-28T11:27:55.764232Z,98 +PARCEL_SHIPPED,2024-03-27T21:14:35.764232Z,98 +PARCEL_SHIPPED,2024-03-27T05:47:33.764232Z,98 +PARCEL_SHIPPED,2024-03-25T12:05:55.764232Z,98 +PARCEL_SHIPPED,2024-03-25T01:05:36.764232Z,98 +PARCEL_SHIPPED,2024-03-26T10:01:17.764232Z,99 +PARCEL_SHIPPED,2024-03-24T13:22:00.764232Z,99 +PARCEL_SHIPPED,2024-03-23T23:28:07.764232Z,99 +PARCEL_SHIPPED,2024-03-27T04:44:20.764232Z,100 +PARCEL_SHIPPED,2024-03-26T08:56:12.764232Z,100 +PARCEL_SHIPPED,2024-03-25T07:37:59.764232Z,100 +PARCEL_SHIPPED,2024-03-24T17:18:29.764232Z,100 diff --git a/test/examples/parcels/threshold_exceeded.csv b/test/examples/parcels/threshold_exceeded.csv index d48261c..c56cd2c 100644 --- a/test/examples/parcels/threshold_exceeded.csv +++ b/test/examples/parcels/threshold_exceeded.csv @@ -1,2 +1,4 @@ -THRESHOLD_EXCEEDED,82,2023-12-24 17:26:50.674638Z -THRESHOLD_EXCEEDED,93,2023-12-25 09:03:38.674638Z +THRESHOLD_EXCEEDED,41,2024-03-30 21:47:03.764232Z +THRESHOLD_EXCEEDED,56,2024-03-30 17:18:45.764232Z +THRESHOLD_EXCEEDED,57,2024-03-30 20:06:14.764232Z +THRESHOLD_EXCEEDED,71,2024-03-31 04:40:51.764232Z diff --git a/test/examples/parcels_test.exs b/test/examples/parcels_test.exs index 6bc0e22..7c266a9 100644 --- a/test/examples/parcels_test.exs +++ b/test/examples/parcels_test.exs @@ -187,9 +187,9 @@ defmodule Strom.Examples.ParcelsTest do def components() do [ source(:orders, ReadLines.new("test/examples/parcels/orders.csv")), - transform([:orders], &__MODULE__.build_order/1), + transform([:orders], &__MODULE__.build_order/1, nil, buffer: 1000), source(:parcels, ReadLines.new("test/examples/parcels/parcels.csv")), - transform([:parcels], &__MODULE__.build_parcel/1), + transform([:parcels], &__MODULE__.build_parcel/1, nil, buffer: 1000), mix([:orders, :parcels], :mixed), transform([:mixed], &ParcelsFlow.force_order/2, %{}), transform([:mixed], &ParcelsFlow.decide/2, %{}),