For a partitioned table P, for each current hosts which has P's vpn files,  
a. mark which available partitions not yet been covered, say this set of partitions is {partitions}
b. generate one work fragment for each site on this host, and let them process {partitions} data extracted from P's vpn files in parallel 
Original host ids are needed to locate P's .vpn files.