Github user peedeeX21 closed the pull request at:
https://github.com/apache/flink/pull/700
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user peedeeX21 opened a pull request:
https://github.com/apache/flink/pull/909
Updated method documentation in joinDataSet.scala for
UnfinishedJoinOperation.
Changed .isEqualTo(..) to .equalsTo(..)
You can merge this pull request into a Git repository by running
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-118020035
@thvasilo I actually could create a pull request for @sachingoel0101 . So
everything should be fine now. We can even close this PR.
---
If your project is set up
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-117730349
@sachingoel0101 me creating a pull request for your repo would be the best.
But for some reason I can't choose your repo as base fork.
---
If your project is set up
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-117068361
I totally agree on you guys points. We have a little amount of centroids,
and the model is not supposed to be distributed in the end.
The question is now
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33465223
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/clustering/Clustering.scala
---
@@ -0,0 +1,256 @@
+/*
--- End diff
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33469076
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33476507
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33475298
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33471983
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user peedeeX21 commented on a diff in the pull request:
https://github.com/apache/flink/pull/700#discussion_r33475321
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala
---
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-116850459
I am having some trouble to fit our predictor into the new API.
The problem is, that with `PredictOperation` the type of the model has to
be defined. A `DataSet
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-110681501
@tillrohrmann great. no worries. was just not sure what is going on. :)
good luck with the new release!
---
If your project is set up for it, you can reply
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-110621613
@tillrohrmann
Would you please help me out with that pending pull request?
---
If your project is set up for it, you can reply to this email and have your
reply
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/791#issuecomment-109249506
Travis fails executing this test:
`KafkaITCase.testPersistentSourceWithOffsetUpdates`. Unfortunately I have no
idea what the problem is. I am not even sure
GitHub user peedeeX21 opened a pull request:
https://github.com/apache/flink/pull/700
[FLINK-1731] [ml] Implementation of Feature K-Means and Test Suite
Within the IMPRO-3 warm-up task the implementation of K-Means and
corresponding test suite was done.
You can merge this pull
16 matches
Mail list logo
