Most of the table/bundle related classes such as MapBundleFunction, MapBundleOperator, and CountBundleTrigger aren't marked as either @Internal or @Public. What was the intention?
I ask because I'm starting to see some interest in using them for implementing pre-aggregation via the DataStream API, and I'm not convinced this is a good idea. E.g., see https://stackoverflow.com/questions/68811184/pre-shuffle-aggregation-in-flink . David
