У меня есть ситуация с pyspark, когда у меня есть 4 таблицы и мне нужен ожидаемый результат, указанный на изображении. ⇐ Python

[Anonymous]

Код: Выделить всё

# Step 2: Sample data for the four tables
data_01 = [(787, 10, 1, 2024, '0202410IN D600000787', '7987979')]

data_02 = [
(787, 10, 2, 2024, '00007870202410111439000000000', '7987979jk'),
(787, 10, 2, 2024, '00007870202410011493500000000', '234098032')
]

data_03 = [
(787, 10, 3, 2024, '0000787020241011143900000000001', 'kkhjbhjk'),
(787, 10, 3, 2024, '0000787020241011143900000000002', 'kjk872'),
(787, 10, 3, 2024, '0000787020241001149350000000001', 'kjk872')
]

data_04 = [
(787, 10, 4, 2024, '000078702024101114390000000000101', 'sdfsdf8798'),
(787, 10, 4, 2024, '000078702024101114390000000000201', 'fd4598sd'),
(787, 10, 4, 2024, '000078702024100114935000000000101', '8932hjty'),
(787, 10, 4, 2024, '000078702024100114935000000000102', '79793213jk'),
(787, 10, 4, 2024, '000078702024100114935000000000103', '8479k')
]

# Define schema for all tables
columns = ["emp_no", "month", "indc", "year", "key", "Value"]

Ожидаемый результат



Подробнее здесь: https://stackoverflow.com/questions/790 ... ult-mentio