Quick Question...

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Quick Question...

Steve Jerman
Hi,

I have a quick question…

How do I set the Configuration passed into RichFunction.open?

I *thought* that setting GlobalJobParameters would do it ...

env.getConfig().setGlobalJobParameters(jobParameters);

But it seems not

Steve

Reply | Threaded
Open this post in threaded view
|

Re: Quick Question...

Chesnay Schepler
Hello,

in the DataSet API you can do this when specifying your transformations, something
along the lines of dataset.map(..).withConfiguration.

In the DataStream API you cannot set the Configuration at all.

Note that in both APIs you can also just pass the Configuration into the constructor and
store it in a field.

Regards,
Chesnay

On 22.06.2017 19:56, Steve Jerman wrote:
Hi,

I have a quick question…

How do I set the Configuration passed into RichFunction.open?

I *thought* that setting GlobalJobParameters would do it ...

env.getConfig().setGlobalJobParameters(jobParameters);

But it seems not

Steve


Reply | Threaded
Open this post in threaded view
|

Re: Quick Question...

Steve Jerman
Thx for the quick answer


From: Chesnay Schepler <[hidden email]>
Sent: Thursday, June 22, 2017 12:13:23 PM
To: [hidden email]
Subject: Re: Quick Question...
 
Hello,

in the DataSet API you can do this when specifying your transformations, something
along the lines of dataset.map(..).withConfiguration.

In the DataStream API you cannot set the Configuration at all.

Note that in both APIs you can also just pass the Configuration into the constructor and
store it in a field.

Regards,
Chesnay

On 22.06.2017 19:56, Steve Jerman wrote:
Hi,

I have a quick question…

How do I set the Configuration passed into RichFunction.open?

I *thought* that setting GlobalJobParameters would do it ...

env.getConfig().setGlobalJobParameters(jobParameters);

But it seems not

Steve