i try the following, but it take always maxIterations, maybe someone can
give me a review?
private int benchmarkCounter;
private static int iterationCounter = 1;
private static DataSet oldCentroids;
FlinkMain(int benchmarkCounter) {
this.benchmarkCounter = benchmarkCounte
Use a broadcastset to distribute the old centers to a map which has the new
centers as regular input. Put the old centers in a hashmap in open() and
check the distance to the new centers in map().
On Jul 20, 2015 12:55 PM, "Pa Rö" wrote:
> okay, i have found it. how to compare my old and new cent
okay, i have found it. how to compare my old and new centers?
2015-07-20 12:16 GMT+02:00 Sachin Goel :
> Gah. Sorry.
> In the closeWith call, give a second argument which determines if the
> iteration should be stopped.
>
> -- Sachin Goel
> Computer Science, IIT Delhi
> m. +91-9871457685
> On Jul
Gah. Sorry.
In the closeWith call, give a second argument which determines if the
iteration should be stopped.
-- Sachin Goel
Computer Science, IIT Delhi
m. +91-9871457685
On Jul 20, 2015 3:21 PM, "Pa Rö" wrote:
> i not found the "iterateWithTermination" function, only "iterate" and
> "iterateDe
i not found the "iterateWithTermination" function, only "iterate" and
"iterateDelta". i use flink 0.9.0 with java.
2015-07-20 11:30 GMT+02:00 Sachin Goel :
> Hi
> You can use iterateWithTermination to terminate before max iterations. The
> feedback for iteration then would be (next solution, isCo
Hi
You can use iterateWithTermination to terminate before max iterations. The
feedback for iteration then would be (next solution, isConverged) where
isConverged is an empty data set if you wish to terminate.
However, this is something I have a pull request for:
https://github.com/apache/flink/pull
hello community,
i have write a k-means app in flink, now i want change my terminate
condition from max iteration to checking the changing of the cluster
centers, but i don't know how i can break the flink loop. here my execution
code of flink:
public void run() {
//load properties
