Code implementing parallel latent dirichlet allocation in spark. Work in progress.