-flink-user-mailing-list-archive.2336050.n4.nabble.com/Retrieving-a-single-element-from-a-DataSet-tp9731p10027.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
gt;
>>
>> --
>> View this message in context: http://apache-flink-user-maili
>> ng-list-archive.2336050.n4.nabble.com/Retrieving-a-single
>> -element-from-a-DataSet-tp9731p9894.html
>> Sent from the Apache Flink User Mailing List archive. mailing list
>> archive at Nabble.com.
>>
>
>
mailing-list-archive.2336050.n4.nabble.com/Retrieving-a-
> single-element-from-a-DataSet-tp9731p9894.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
/Retrieving-a-single-element-from-a-DataSet-tp9731p9894.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
;> this
>> requires me to execute the algorithm on each of the nodes. If i need the
>> id
>> of every node that means i need to Collect() all those nodes as well,
>> which
>> means for a graph of 1000 nodes i have 1000+ execution plans
>>
>>
>
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Retrieving-a-
> single-element-from-a-DataSet-tp9731p9734.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
-flink-user-mailing-list-archive.2336050.n4.nabble.com/Retrieving-a-single-element-from-a-DataSet-tp9731p9734.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
Hi,
I'm also interested in that question/solution.
For now, my workaround looks like this:
> DataSet<...> .filter(... object.Id == NeededElement.Id ...
).collect().get(0)
I filter the DataSet for the element I want to find, collect it into a
List which then returns the first element.
That's a
ent from a set, is that correct?
What would be a good way to fix this issue?
[1]
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Get-1-element-of-DataSet-td688.html
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Retriev
