On Mon, Mar 20, 2017 at 3:25 PM, Aljoscha Krettek wrote:
> I think adding this could be as simple as adding a
> makeWindowContentsQueryable(String) call to WindowedStream. In there, we
> create the StateDescriptor for keeping the window contents so we can call
>
I think adding this could be as simple as adding a
makeWindowContentsQueryable(String) call to WindowedStream. In there, we create
the StateDescriptor for keeping the window contents so we can call
setQueryable() on the StateDescriptor and set the name under which it should be
accessible. If
I have a question regarding the future direction of the queryable state feature.
We are current using this feature in production implemented in a RichFlatMap.
It is doing what we need it to do at the scale we need it done in, with the
resources we have assigned to it. Win.
However, we'd also