Re: [Java] Accessing state from FinishBundle method

2019-07-31 Thread Kenneth Knowles
Because @FinishBundle is not executed in the context of a window, what state would you be accessing? (analogous to the way that outputs from finish bundle must have an explicit window specified) It may make sense to have a separate method @FinishBundleForWindow (or some better name) that can be ca

[Java] Accessing state from FinishBundle method

2019-07-29 Thread Pablo Estrada
Hello all, I am working on a pipeline where I'd like to write a value to state at the end of processing a bundle. As it turns out, I don't think this is possible, as FinishBundleContext does not provide a method for it; and doing something like so also errors out: == @FinishBundle