Uses of Interface
org.apache.flink.table.runtime.operators.bundle.trigger.BundleTrigger

Packages that use BundleTrigger

Package	Description
org.apache.flink.table.runtime.operators.bundle
org.apache.flink.table.runtime.operators.bundle.trigger

Uses of BundleTrigger in org.apache.flink.table.runtime.operators.bundle

Constructors in org.apache.flink.table.runtime.operators.bundle with parameters of type BundleTrigger

Constructor and Description
KeyedMapBundleOperator(MapBundleFunction<K,V,IN,OUT> function, BundleTrigger<IN> bundleTrigger)
MapBundleOperator(MapBundleFunction<K,V,IN,OUT> function, BundleTrigger<IN> bundleTrigger, KeySelector<IN,K> keySelector)

Uses of BundleTrigger in org.apache.flink.table.runtime.operators.bundle.trigger

Classes in org.apache.flink.table.runtime.operators.bundle.trigger that implement BundleTrigger

Modifier and Type	Class and Description
class	CountBundleTrigger<T> A BundleTrigger that fires once the count of elements in a bundle reaches the given count.