You know your use case is fairly atypical when you have to implement your own custom logic for an open-source distributed data processing…