, 2017 3:34 PM
To: user@flink.apache.org
Cc: Kürşat Kurt <kur...@kursatkurt.com>
Subject: Re: Aggregation problem.
maxBy() is still a member of org.apache.flink.api.scala.GroupedDataSet in the
current sources - what did you upgrade flink to?
Also please make sure the new version i
having the maximum value, maxBy() should be used instead of max().
See this answer for more details :
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Wrong-and-non-consistent-behavior-of-max-tp484p488.html
Best,
Yassine
On Feb 18, 2017 12:28, "Kürşat Kurt&
a bug to me.
Can you open a JIRA and maybe a small testcase to reproduce the issue?
Thank you,
Fabian
2017-02-18 1:06 GMT+01:00 Kürşat Kurt <kur...@kursatkurt.com
<mailto:kur...@kursatkurt.com> >:
Hi;
I have a Dataset like this:
(0,Auto,0.4,1,5.8317538999854194E-5)
Hi;
I have a Dataset like this:
(0,Auto,0.4,1,5.8317538999854194E-5)
(0,Computer,0.2,1,4.8828125E-5)
(0,Sports,0.4,2,1.7495261699956258E-4)
(1,Auto,0.4,1,1.7495261699956258E-4)
(1,Computer,0.2,1,4.8828125E-5)
(1,Sports,0.4,1,5.8317538999854194E-5)
This code;
Hi;
I am trying to learn Flink Ml lib.
Where can i find detailed multiclass classification example?
x = ...
DataSet<Integer, Long> joined =
splittedMain.join(wordIdx).where(1).equalTo(1).with(...)
3) Group by Label:
DataSet<Tuple2<Integer, Long[]>> labelsWithIdx =
joined.groupBy(0).reduceGroup(...) // collect all indexes in list / array
Best, Fabian
2016-10-10 23
Hi;
I have MainDataset (Label,WordList) :
(0,List(a, b, c, d, e, f, g))
(1,List(b, c, f, a, g))
..and, wordIndex dataset(created with .zipWithIndex) :
wordIndex> (0,a)
wordIndex> (1,b)
wordIndex> (2,c)
wordIndex> (3,d)
wordIndex> (4,e)
wordIndex> (5,f)
wordIndex> (6,g)
Hi;
I am trying to train and predict with the same set. I expect that accuracy
shuld be %100, am i wrong?
If i try to predict with the same set; it is failing, also it classifies
like "-1" which is not in the training set.
What is wrong with this code?
Code:
def main(args:
