Interface AsyncTriggerConverter
-
@Internal public interface AsyncTriggerConverterA converter fromTriggertoAsyncTrigger.Basic triggers (e.g.,
CountTrigger) are directly converted to their async version.Async-support triggers which implement
AsyncTriggerConvertable(e.g.,ProcessingTimeoutTrigger) will use self-defined async version.Other triggers are wrapped as an
AsyncTrigger, whose internal functions are executed in sync mode.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classAsyncTriggerConverter.UserDefinedAsyncTrigger<T,W extends Window>Convert non-support user-defined trigger toAsyncTrigger.
-
Method Summary
All Methods Static Methods Instance Methods Default Methods Modifier and Type Method Description default ObjectconvertToAsync()Convert to anAsyncTrigger.static <T,W extends Window>
AsyncTrigger<T,W>convertToAsync(Trigger<T,W> trigger)
-
-
-
Method Detail
-
convertToAsync
@Nonnull default Object convertToAsync()
Convert to anAsyncTrigger. The default implementation is only a wrapper of the trigger, whose behaviours are all sync.TODO: Return
AsyncTriggerifAsyncTriggerbecomes @PublicEvolving.- Returns:
- The
AsyncTriggerfor async state processing.
-
convertToAsync
static <T,W extends Window> AsyncTrigger<T,W> convertToAsync(Trigger<T,W> trigger)
-
-