How to use it in Scala

[MJeremy2017]

Hi, thanks for sharing this project.

• I am now running a scala project and wondering if it is possible to use your project in scala(may be import ...kmeans, make it into a package).

• My resource is from Kafka rather than a static offline file, may I know how to use this kmeans with Kafka resource?

[kkrugler]

You should be able to call KMeansClustering.build() from your Scala code, assuming you import that package (as you noted in your question).

The current .build() API requires that you pass in a SourceFunction<Feature>. You should provide a DeserializationSchema for the Kafka Connector that converts the binary data in your topic to a Feature object.