rdd = sc.binaryFiles('/user/digdug/images')

def f(iterator):
    sizes = []
for i in iterator:
    sizes.append(len(i[1]))
return sizes
rdd.mapPartitions(f).collect()
Самый эффективный способ доступа к двоичным файлам в ADLS с рабочего узла в PySpark?