For mahout-flink (MAHOUT-1570) rows now can only be indexed with integers. Add support for other types: Long, String, etc.
Adding support for Apache Flink as a backend for the Mahout DSL
Mahout DSL for Flink: switch to Flink Scala API
Switching to Scala API may solve this problem
This should be operable but is untested we can test for String keys by adding the NBTestBaseSuite
we still need to implement things like drmParallelizeWithRowLabels(...) to close this out.
Working on this to add functionality for drmParallelizeWithRowLabels(...)
Great! I'll start work on allreduceBlock. should I push a squashed commit of my branch to apacke/flink-binding?
yes, lets start pushing code for 0.12.0 to the flink branch.
All 5 tests in NaiveBayesTestSuite passed for this implementation.
bulk-closing resolved issues
FAILURE: Integrated in Mahout-Quality #3324 (See https://builds.apache.org/job/Mahout-Quality/3324/)
MAHOUT-1747: Flink: support for different key types (alexey.s.grigoriev: rev 19708f46a41d0bc437f904a383876858a3fef35d)