This looks like the library that precisely and exactly solves a problem I'm having. Unfortunately I'm all in on using pyspark / python for my spark usage, rather than scala. I'm wondering if this is callable / usable from Python?
The example in scala is readable enough - the same example repeated in Python (given that it can be done at all), would get me everything I need.
Thanks!