You are tasked with developing ETL (Extract, Transform, Load) pipelines for your company's data processing needs, specifically to be executed on an Apache Hadoop cluster. These pipelines need to support both checkpointing mechanisms, which allow the system to resume from a certain point in case of failures, and the ability to split pipelines into more manageable and logically distinct segments. Given these requirements, which method would be most suitable for writing the ETL pipelines?