Where is the source code of datapipes.iter.ShardingFilter?

I’m trying to split the data from a datapipe to several parallel processes. I’m wondering how ShardingFilter is implemented. I’ve looked for it in the pytorch and torchdata repo, but I didn’t find the core codes. Where should I look at?