Jak říkáte, DBStorage podporuje pouze ukládání výsledků do databáze.
Chcete-li načíst data z MySQL, můžete se podívat do projektu s názvem sqoop (který zkopíruje data z databáze do HDFS), nebo můžete provést výpis mysql a poté zkopírovat soubor do HDFS. Oba způsoby vyžadovaly určitou interakci a nelze je přímo použít zevnitř Pig.
Třetí možností by bylo podívat se na psaní Pig LoadFunc (říkáte, že jste se pokusili napsat UDF). Nemělo by to být příliš obtížné, budete muset předat téměř stejné možnosti jako DBStorage (ovladač, přihlašovací údaje pro připojení a SQL dotaz ke spuštění) a pravděpodobně můžete také použít nějakou inspekci metadat sady výsledků k automatickému generování schématu.