apache-pig - Pig UDF（从 api 加载数据）

Question

我正在尝试编写自己的 UDF 来从端点加载数据。下面是场景

// A = load the user information from the cassandra db 
// B = iterate through the data and make string of userids (1,2,3) 
// C = send it to    some UDF which can go to some external api to fetch the user  information 
// D = join A and C on user id 
// E = group by information fetched from UDF 
// dump E;

据我了解，只有 4 种 UDF。加载、过滤、EvalFunc 和存储。我试过 LoadFunc 但看起来它总是需要一些文件名位置来加载信息。我不想从文件中读取。

有什么办法可以实现上述场景。