THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
@PublicEvolving public class GlobalWindows extends WindowAssigner<Object, GlobalWindow> { ··· /** * Creates a newGlobalWindows {@link WindowAssigner} with {@link NeverTrigger} that assigns all elements to the same {@link * the same {@link* GlobalWindow}. The window is only useful if you also specify a custom trigger. Otherwise, the * trigger. Otherwise, the* window will never be triggered and no computation will be performed. * / * @return The global window policy with {@link NeverTrigger} as default trigger. */ public static GlobalWindows create() { ... } /** * Creates a new {@link WindowAssigner} with {@link EndOfStreamTrigger} that assigns all * elements to the same {@link GlobalWindow} and the default trigger fires if and only if the * input stream is ended. * * @return The global window policy with {@link EndOfStreamTrigger} as default trigger. */ public static GlobalWindows createWithEndOfStreamTrigger() { ... } } |
...