Package org.apache.flink.table.runtime.operators.bundle.trigger
-
Interface Summary Interface Description BundleTrigger<T> ABundleTrigger
determines when a bundle of input elements should be evaluated and trigger the callback which registered previously.BundleTriggerCallback Interface for bundle trigger callbacks that can be registered to aBundleTrigger
.CoBundleTrigger<IN1,IN2> ACoBundleTrigger
is similar withBundleTrigger
, and the only differences isCoBundleTrigger
can handle two inputs. -
Class Summary Class Description CountBundleTrigger<T> ABundleTrigger
that fires once the count of elements in a bundle reaches the given count.CountCoBundleTrigger<IN1,IN2> ACoBundleTrigger
that fires once the count of elements in a bundle reaches the given count.