No, Apache Beam doesn't offer this explicitly. You could accomplish it using State, but perhaps if you clarified what you were trying to accomplish by using these mechanisms there'd be another way to do the same thing.
On Wed, Jan 24, 2018 at 7:03 AM, Tim Ross <[email protected]> wrote: > Is there anything comparable to Apache Storm’s Window.getNew and > Window.getExpired in Apache Beam? How would I determine if an element is > new or expired in consecutive windows? > > > > Thanks, > > Tim > > This e-mail message and any attachments to it are intended only for the > named recipients and may contain legally privileged and/or confidential > information. If you are not one of the intended recipients, do not duplicate > or forward this e-mail message.
