Package org.apache.flink.table.runtime.operators.bundle.trigger
-
Interface Summary Interface Description BundleTrigger<T> ABundleTriggerdetermines 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> ACoBundleTriggeris similar withBundleTrigger, and the only differences isCoBundleTriggercan handle two inputs. -
Class Summary Class Description CountBundleTrigger<T> ABundleTriggerthat fires once the count of elements in a bundle reaches the given count.CountCoBundleTrigger<IN1,IN2> ACoBundleTriggerthat fires once the count of elements in a bundle reaches the given count.