Я не могу найти несколько примеров использования PySpark API для потоковой передачи двоичных данных сокетов. Может кто-то держал меня, пожалуйста?