getClass().getClassLoader() unless you have some custom classloader
> for
> > loading your state backend.
> >
> > Cheers,
> > Max
> >
> > On 04.03.20 01:39, Jin Yi wrote:
> > > Hi Experts,
> > >
> > > I am running
Max
>
> On 04.03.20 01:39, Jin Yi wrote:
> > Hi Experts,
> >
> > I am running Beam application with Flink Runner. I would like to set
> > State Backend to be FsStateBackend instead of MemoryStateBackend.
> >
> > in FlinkPip
gt; >
> > I should be able to call setStateBackendFactory(), but I did not find
> > any provided implementations for FlinkStateBackendFactory interface, so
> > that means I have to implement my own?
> >
> > Thanks a lot!
> > Eleanore
> >
&g
setStateBackendFactory(), but I did not find
any provided implementations for FlinkStateBackendFactory interface, so
that means I have to implement my own?
Thanks a lot!
Eleanore
/**
* State backend to store Beam's state during computation. Note: Only
applicable when executing in
* streaming mode
for FlinkStateBackendFactory interface, so that
means I have to implement my own?
Thanks a lot!
Eleanore
/**
* State backend to store Beam's state during computation. Note: Only
applicable when executing in
* streaming mode.
*/
@Description(
"Sets the state backend factory to use in streaming
