Streaming One Pass KMeans implementation for Stratosphere in Java