There was a similar question before the answer was to use
org.apache.flink.api.common.io.OutputFormat to do the conversion.
On Tue, Mar 15, 2016 at 7:48 PM, subash basnet wrote:
> Hello all,
>
> In WikipediaAnalysis.java we get *result *of type *DataStream Long>>*,
>
> I would want to convert *r
Hello all,
In WikipediaAnalysis.java we get *result *of type *DataStream>*,
I would want to convert *result* to *newResult* of type
*DataSet>*,
So tried the following:
DataSet>newResult = result.map(new getResult());
public static final class getResult implements MapFunction, Tuple1> {
@Overri
