0.10 streaming state documentation out of date

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

0.10 streaming state documentation out of date

Martin Neumann-2
Hej,

I'm working with some state full streaming operators at the moment and I
noticed that the Documentation is out of date.

The documentation says:

 @Override
    public void open(Configuration config) {
        counter = getRuntimeContext().getOperatorState(“counter”, 0L, false);
    }


getOperatorState does not exist anymore, instead it should be getKeyValueState.
Also the signature of the function has changed so the description text
might need some update to.

cheers Martin
mxm
Reply | Threaded
Open this post in threaded view
|

Re: 0.10 streaming state documentation out of date

mxm
Hi Martin,

You're right. The documentation needs to be updated. I have already filed a
JIRA for that: https://issues.apache.org/jira/browse/FLINK-2938

It's actually called getKeyValueState(...) now.

Cheers,
Max

On Thu, Nov 5, 2015 at 4:41 PM, Martin Neumann <[hidden email]> wrote:

> Hej,
>
> I'm working with some state full streaming operators at the moment and I
> noticed that the Documentation is out of date.
>
> The documentation says:
>
>  @Override
>     public void open(Configuration config) {
>         counter = getRuntimeContext().getOperatorState(“counter”, 0L,
> false);
>     }
>
>
> getOperatorState does not exist anymore, instead it should be
> getKeyValueState.
> Also the signature of the function has changed so the description text
> might need some update to.
>
> cheers Martin
>
Reply | Threaded
Open this post in threaded view
|

Re: 0.10 streaming state documentation out of date

Stephan Ewen
I am writing an update in the state docs now...

On Thu, Nov 5, 2015 at 5:58 PM, Maximilian Michels <[hidden email]> wrote:

> Hi Martin,
>
> You're right. The documentation needs to be updated. I have already filed a
> JIRA for that: https://issues.apache.org/jira/browse/FLINK-2938
>
> It's actually called getKeyValueState(...) now.
>
> Cheers,
> Max
>
> On Thu, Nov 5, 2015 at 4:41 PM, Martin Neumann <[hidden email]> wrote:
>
> > Hej,
> >
> > I'm working with some state full streaming operators at the moment and I
> > noticed that the Documentation is out of date.
> >
> > The documentation says:
> >
> >  @Override
> >     public void open(Configuration config) {
> >         counter = getRuntimeContext().getOperatorState(“counter”, 0L,
> > false);
> >     }
> >
> >
> > getOperatorState does not exist anymore, instead it should be
> > getKeyValueState.
> > Also the signature of the function has changed so the description text
> > might need some update to.
> >
> > cheers Martin
> >
>
Reply | Threaded
Open this post in threaded view
|

Re: 0.10 streaming state documentation out of date

Stephan Ewen
Fixed the docs. Should be updated on the website once when the build bot
rebuilds them over night.

On Thu, Nov 5, 2015 at 6:03 PM, Stephan Ewen <[hidden email]> wrote:

> I am writing an update in the state docs now...
>
> On Thu, Nov 5, 2015 at 5:58 PM, Maximilian Michels <[hidden email]> wrote:
>
>> Hi Martin,
>>
>> You're right. The documentation needs to be updated. I have already filed
>> a
>> JIRA for that: https://issues.apache.org/jira/browse/FLINK-2938
>>
>> It's actually called getKeyValueState(...) now.
>>
>> Cheers,
>> Max
>>
>> On Thu, Nov 5, 2015 at 4:41 PM, Martin Neumann <[hidden email]> wrote:
>>
>> > Hej,
>> >
>> > I'm working with some state full streaming operators at the moment and I
>> > noticed that the Documentation is out of date.
>> >
>> > The documentation says:
>> >
>> >  @Override
>> >     public void open(Configuration config) {
>> >         counter = getRuntimeContext().getOperatorState(“counter”, 0L,
>> > false);
>> >     }
>> >
>> >
>> > getOperatorState does not exist anymore, instead it should be
>> > getKeyValueState.
>> > Also the signature of the function has changed so the description text
>> > might need some update to.
>> >
>> > cheers Martin
>> >
>>
>
>
mxm
Reply | Threaded
Open this post in threaded view
|

Re: 0.10 streaming state documentation out of date

mxm
Looks good. Thanks for the update Stephan.

On Thu, Nov 5, 2015 at 7:53 PM, Stephan Ewen <[hidden email]> wrote:

> Fixed the docs. Should be updated on the website once when the build bot
> rebuilds them over night.
>
> On Thu, Nov 5, 2015 at 6:03 PM, Stephan Ewen <[hidden email]> wrote:
>
> > I am writing an update in the state docs now...
> >
> > On Thu, Nov 5, 2015 at 5:58 PM, Maximilian Michels <[hidden email]>
> wrote:
> >
> >> Hi Martin,
> >>
> >> You're right. The documentation needs to be updated. I have already
> filed
> >> a
> >> JIRA for that: https://issues.apache.org/jira/browse/FLINK-2938
> >>
> >> It's actually called getKeyValueState(...) now.
> >>
> >> Cheers,
> >> Max
> >>
> >> On Thu, Nov 5, 2015 at 4:41 PM, Martin Neumann <[hidden email]>
> wrote:
> >>
> >> > Hej,
> >> >
> >> > I'm working with some state full streaming operators at the moment
> and I
> >> > noticed that the Documentation is out of date.
> >> >
> >> > The documentation says:
> >> >
> >> >  @Override
> >> >     public void open(Configuration config) {
> >> >         counter = getRuntimeContext().getOperatorState(“counter”, 0L,
> >> > false);
> >> >     }
> >> >
> >> >
> >> > getOperatorState does not exist anymore, instead it should be
> >> > getKeyValueState.
> >> > Also the signature of the function has changed so the description text
> >> > might need some update to.
> >> >
> >> > cheers Martin
> >> >
> >>
> >
> >
>