Convert Datastream to Collector or List

[Ahmed Nader]

Hi,

I want to pass an object of type DataStream ,after applying map function on it, as a parameter to be used somewhere else. But when i do so, i get an error message of trying to access a null context object.

Is there a way that i can convert this DataStream object to a list or a collector so as to be used somewhere else afterwards.

Thanks,

Ahmed

[Suneel Marthi]

DataStream<String> ds = .......

Iterator<String> iter = DataStreamUtils.collect(ds);

List<String> list = Lists.newArrayList(iterator);

Hope that helps.

On Wed, Mar 16, 2016 at 7:37 AM, Ahmed Nader <[hidden email]> wrote:

Hi,

I want to pass an object of type DataStream ,after applying map function on it, as a parameter to be used somewhere else. But when i do so, i get an error message of trying to access a null context object.

Is there a way that i can convert this DataStream object to a list or a collector so as to be used somewhere else afterwards.

Thanks,

Ahmed

[Ahmed Nader]

Hello Suneel,

Yeah that worked, thanks so much.

On 16 March 2016 at 12:50, Suneel Marthi <[hidden email]> wrote:

DataStream<String> ds = .......

Iterator<String> iter = DataStreamUtils.collect(ds);

List<String> list = Lists.newArrayList(iterator);

Hope that helps.

On Wed, Mar 16, 2016 at 7:37 AM, Ahmed Nader <[hidden email]> wrote:

Hi,

I want to pass an object of type DataStream ,after applying map function on it, as a parameter to be used somewhere else. But when i do so, i get an error message of trying to access a null context object.

Is there a way that i can convert this DataStream object to a list or a collector so as to be used somewhere else afterwards.

Thanks,

Ahmed