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

Class Summary

Class	Description
AbstractMapBundleOperator<K,V,IN,OUT>	The AbstractMapBundleOperator simply used a java Map to store the input elements in key-value form.
KeyedMapBundleOperator<K,V,IN,OUT>	The KeyedMapBundleOperator uses framework's key as bundle map key, thus can only be used on KeyedStream.
MapBundleFunction<K,V,IN,OUT>	Basic interface for map bundle processing.
MapBundleOperator<K,V,IN,OUT>	The MapBundleOperator uses a KeySelector to extract bundle key, thus can be used with non-keyed-stream.