Skip to content

Commit e289759

Browse files
committed
add tests with NULLs
1 parent bf322c7 commit e289759

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

ydb/tests/fq/generic/streaming/test_join.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -131,6 +131,7 @@ def freeze(json):
131131
('{"id":9,"user":3}', '{"id":9,"user_id":3,"lookup":"ydb30"}'),
132132
('{"id":2,"user":2}', '{"id":2,"user_id":2,"lookup":"ydb20"}'),
133133
('{"id":1,"user":1}', '{"id":1,"user_id":1,"lookup":"ydb10"}'),
134+
('{"id":10,"user":null}', '{"id":10,"user_id":null,"lookup":null}'),
134135
('{"id":4,"user":3}', '{"id":4,"user_id":3,"lookup":"ydb30"}'),
135136
('{"id":5,"user":3}', '{"id":5,"user_id":3,"lookup":"ydb30"}'),
136137
('{"id":6,"user":1}', '{"id":6,"user_id":1,"lookup":"ydb10"}'),
@@ -350,6 +351,10 @@ def freeze(json):
350351
'{"id":3,"za":2,"yb":"1","yc":114,"zd":115}',
351352
'{"a":null,"b":null,"c":null,"d":null,"e":null,"f":null,"za":2,"yb":"1","yc":114,"zd":115}',
352353
),
354+
(
355+
'{"id":3,"za":2,"yb":null,"yc":114,"zd":115}',
356+
'{"a":null,"b":null,"c":null,"d":null,"e":null,"f":null,"za":2,"yb":null,"yc":114,"zd":115}',
357+
),
353358
]
354359
),
355360
),
@@ -391,6 +396,10 @@ def freeze(json):
391396
'{"id":3,"za":2,"yb":"1","yc":114,"zd":115}',
392397
'{"a":null,"b":null,"c":null,"d":null,"e":null,"f":null,"za":2,"yb":"1","yc":114,"zd":115}',
393398
),
399+
(
400+
'{"id":3,"za":null,"yb":"1","yc":114,"zd":115}',
401+
'{"a":null,"b":null,"c":null,"d":null,"e":null,"f":null,"za":null,"yb":"1","yc":114,"zd":115}',
402+
),
394403
]
395404
),
396405
),

0 commit comments

Comments
 (0)