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 Description KeyedMapBundleOperator(MapBundleFunction<K,V,IN,OUT> function, BundleTrigger<IN> bundleTrigger)MapBundleOperator(MapBundleFunction<K,V,IN,OUT> function, BundleTrigger<IN> bundleTrigger, org.apache.flink.api.java.functions.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 Description classCountBundleTrigger<T>ABundleTriggerthat fires once the count of elements in a bundle reaches the given count.
-