Както казвате, DBStorage поддържа само запис на резултати в база данни.
За да заредите данни от MySQL, можете да разгледате проект, наречен sqoop (която копира данни от база данни в HDFS) или можете да изпълните mysql dump и след това да копирате файла в HDFS. И двата начина изискват известно взаимодействие и не могат да се използват директно от Pig.
Трети вариант би бил да разгледате написването на Pig LoadFunc (вие казвате, че сте се опитали да напишете UDF). Не би трябвало да е твърде трудно, ще трябва да подадете почти същите опции като DBStorage (драйвер, идентификационни данни за връзка и SQL заявка за изпълнение) и вероятно можете да използвате някаква проверка на метаданни от набор от резултати, за да генерирате и схема автоматично.
