Implementing data processing in Apache Spark