Доработка и оптимизация Spark-лоадера, реализация многопоточной загрузки, оптимизация Spark-джоб, перенос пайплайна в ETL-процесс.