GitHub user chobeat opened a pull request:
https://github.com/apache/flink/pull/2522
Parameterize Flink version in Quickstart bash script
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/radicalbit/flink FLINK-4301
Alternatively
Github user chobeat commented on the issue:
https://github.com/apache/flink/pull/2485
Done, sorry.
---
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
GitHub user chobeat opened a pull request:
https://github.com/apache/flink/pull/2485
[Flink 4599] - Add 'explain()' also to StreamTableEnvironment
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/radicalbit/flink FLINK-4599
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r7389
--- Diff: docs/apis/cli.md ---
@@ -187,6 +187,8 @@ Action "run" compiles and runs
Github user chobeat commented on the issue:
https://github.com/apache/flink/pull/2152
Is travis still broken? I see it worked for one build but failed for the
others. Is there anything more to review on this PR or we can proceed?
---
If your project is set up for it, you can reply
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/2152#discussion_r76575651
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala
---
@@ -0,0 +1,286 @@
+/*
+ * Licensed
Github user chobeat commented on the issue:
https://github.com/apache/flink/pull/2152
Don't worry, take your time. I don't have much time to work on this in the
coming days. I just don't want to lose the work done.
---
If your project is set up for it, you can reply to this email
Github user chobeat commented on the issue:
https://github.com/apache/flink/pull/2152
Any news?
---
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
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/2152#discussion_r68715364
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licensed
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/2152#discussion_r68713373
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licensed
GitHub user chobeat opened a pull request:
https://github.com/apache/flink/pull/2152
[FLINK-3920] Distributed Linear Algebra: block-based matrix
Second part of the distributed linear algebra contribution. This PR
introduces block-partitioned matrices, operations on them
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r68012799
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,162
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65671113
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,166
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65356053
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,166
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1996
@chiwanpark I think it should be better to leave to the user the
computation of the dimensionality. I tried different options and all of them
are sub-optimal. I would leave this feature
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1996
@chiwanpark before merging I need to go over the numRows/numCols issue
again because I noticed they create problems in another project of mine. I
think that the `collect()` there is too risky
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1996
@chiwanpark Yeah I thought I could write the documentation as a third PR
but I would like to review the block matrix first because it may change in
structure. Anyway I will soon begin working
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65318407
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,179
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65143303
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65142014
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65134910
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,182
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65084114
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65081970
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65072614
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65068513
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65067355
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65065451
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65064313
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65061860
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,167
GitHub user chobeat opened a pull request:
https://github.com/apache/flink/pull/1996
[FLINK-3919][flink-ml] Distributed Linear Algebra: row-based matrix
First PR of the Distributed Linear Algebra contribution.
It contains a minimal implementation of a row-based distributed
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1156#issuecomment-217093665
any news?
---
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
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1759#issuecomment-191857083
I tested it too and it works perfectly both on an example case and in the
code where the problem arose.
---
If your project is set up for it, you can reply
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/891#issuecomment-182317008
No news?
---
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
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1186#issuecomment-181790876
I agree with @sachingoel0101 on the import complexity but, from our point
of view, Flink is the perfect platform to evaluate models in streaming and we
are using
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1186#issuecomment-181799783
@sachingoel0101 I agree. Nonetheless, an easy way to store and move a model
generated in batch to a streaming enviroment would be a really useful feature
and we go back
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1186#issuecomment-181757426
Well that wouldn't be a problem for the export: you will create and
therefore export only models that have `double` as datatype for parameters but
that's not an issue
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1186#issuecomment-181442715
Hello,
any news on this PR?
@smarthi PMML is actually an industry standard and widely used to support
model portability in complex infrastructures
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1186#issuecomment-181578375
Hi @chiwanpark,
> What is main purpose to support PMML? Is this feature for only model
portability in FlinkML?
I've used PMML extensively in a previ
38 matches
Mail list logo
