timeplusd :) create stream test(id nullable(float64), cnt nullable(int64));
timeplusd :) insert into test(id, cnt) values(null, 2)
timeplusd :) insert into test(id, cnt) values(3, null)
timeplusd :) insert into test(id, cnt) values(null, null)

timeplusd :) Bye.

timeplusd :) create stream test_target(id nullable(float64), cnt nullable(int64));


./sling run --src-conn LOCAL --src-stream "test" --tgt-conn LOCAL --tgt-object "test_target" --mode incremental --update-key _tp_time -d

timeplusd :) select * from table(test)

SELECT
  *
FROM
  table(test)

Query id: 75a13e89-09eb-40a2-bcf4-6a3c2950b737

┌───id─┬──cnt─┬────────────────_tp_time─┐
│ ᴺᵁᴸᴸ │ ᴺᵁᴸᴸ │ 2025-06-30 07:39:29.511 │
└──────┴──────┴─────────────────────────┘
┌───id─┬─cnt─┬────────────────_tp_time─┐
│ ᴺᵁᴸᴸ │   2 │ 2025-06-30 07:39:20.532 │
└──────┴─────┴─────────────────────────┘
┌─id─┬──cnt─┬────────────────_tp_time─┐
│  3 │ ᴺᵁᴸᴸ │ 2025-06-30 07:39:26.588 │
└────┴──────┴─────────────────────────┘

3 rows in set. Elapsed: 0.002 sec. 

timeplusd :) select * from table(test_target)

SELECT
  *
FROM
  table(test_target)

Query id: 43ae2429-850a-4203-bf34-380bf7b60b8b

┌───id─┬──cnt─┬────────────────_tp_time─┐
│ ᴺᵁᴸᴸ │ ᴺᵁᴸᴸ │ 2025-06-30 07:39:29.511 │
│    3 │ ᴺᵁᴸᴸ │ 2025-06-30 07:39:26.588 │
│ ᴺᵁᴸᴸ │    2 │ 2025-06-30 07:39:20.532 │
└──────┴──────┴─────────────────────────┘

3 rows in set. Elapsed: 0.001 sec. 

timeplusd :)